java.lang.Object
- akka.remote.transport.AbstractTransportAdapterHandle
- - akka.remote.transport.FailureInjectorHandle

All Implemented Interfaces:

AssociationHandle, AssociationHandle.HandleEventListener, SchemeAugmenter, java.io.Serializable, scala.Equals, scala.Product
```
public final class FailureInjectorHandle
extends AbstractTransportAdapterHandle
implements AssociationHandle.HandleEventListener, scala.Product, java.io.Serializable
```
INTERNAL API

See Also:

Serialized Form

Nested Class Summary
- Nested classes/interfaces inherited from interface akka.remote.transport.AssociationHandle
  AssociationHandle.ActorHandleEventListener, AssociationHandle.ActorHandleEventListener$, AssociationHandle.Disassociated, AssociationHandle.Disassociated$, AssociationHandle.DisassociateInfo, AssociationHandle.HandleEvent, AssociationHandle.HandleEventListener, AssociationHandle.InboundPayload, AssociationHandle.InboundPayload$, AssociationHandle.Quarantined$, AssociationHandle.Shutdown$, AssociationHandle.Unknown$

Constructor Summary

Constructors
Constructor Description

FailureInjectorHandle(AssociationHandle _wrappedHandle, FailureInjectorTransportAdapter gremlinAdapter)

Method Summary

All Methods Static Methods Instance Methods Concrete Methods Deprecated Methods
Modifier and Type	Method	Description
`AssociationHandle`	`_wrappedHandle()`
`static FailureInjectorHandle`	`apply(AssociationHandle _wrappedHandle, FailureInjectorTransportAdapter gremlinAdapter)`
`boolean`	`canEqual(java.lang.Object x$1)`
`FailureInjectorHandle`	`copy(AssociationHandle _wrappedHandle, FailureInjectorTransportAdapter gremlinAdapter)`
`AssociationHandle`	`copy$default$1()`
`FailureInjectorTransportAdapter`	`copy$default$2()`
`void`	`disassociate()`	Deprecated. Use method that states reasons to make sure disassociation reasons are logged.
`void`	`disassociate(java.lang.String reason, LoggingAdapter log)`	Closes the underlying transport link, if needed.
`boolean`	`equals(java.lang.Object x$1)`
`FailureInjectorTransportAdapter`	`gremlinAdapter$access$1()`
`int`	`hashCode()`
`void`	`notify(AssociationHandle.HandleEvent ev)`	Called by the transport to notify the listener about a HandleEvent
`int`	`productArity()`
`java.lang.Object`	`productElement(int x$1)`
`java.lang.String`	`productElementName(int x$1)`
`scala.collection.Iterator<java.lang.Object>`	`productIterator()`
`java.lang.String`	`productPrefix()`
`scala.concurrent.Promise<AssociationHandle.HandleEventListener>`	`readHandlerPromise()`	The Promise returned by this call must be completed with an `AssociationHandle.HandleEventListener` to register a listener responsible for handling incoming payload.
`java.lang.String`	`toString()`
`static scala.Option<scala.Tuple2<AssociationHandle,FailureInjectorTransportAdapter>>`	`unapply(FailureInjectorHandle x$0)`
`boolean`	`write(ByteString payload)`	Asynchronously sends the specified payload to the remote endpoint.

Methods inherited from class akka.remote.transport.AbstractTransportAdapterHandle
addedSchemeIdentifier, localAddress, originalLocalAddress, originalRemoteAddress, remoteAddress, wrappedHandle

Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface akka.remote.transport.SchemeAugmenter
augmentScheme, augmentScheme, removeScheme, removeScheme

- Constructor Detail
  - FailureInjectorHandle
```
public FailureInjectorHandle(AssociationHandle _wrappedHandle,
                             FailureInjectorTransportAdapter gremlinAdapter)
```
- Method Detail
  - apply
```
public static FailureInjectorHandle apply(AssociationHandle _wrappedHandle,
                                          FailureInjectorTransportAdapter gremlinAdapter)
```
  - unapply
```
public static scala.Option<scala.Tuple2<AssociationHandle,FailureInjectorTransportAdapter>> unapply(FailureInjectorHandle x$0)
```
  - gremlinAdapter$access$1
```
public FailureInjectorTransportAdapter gremlinAdapter$access$1()
```
  - _wrappedHandle
```
public AssociationHandle _wrappedHandle()
```
  - readHandlerPromise
```
public scala.concurrent.Promise<AssociationHandle.HandleEventListener> readHandlerPromise()
```
    Description copied from interface: AssociationHandle
    
    The Promise returned by this call must be completed with an AssociationHandle.HandleEventListener to register a listener responsible for handling incoming payload. Until the listener is not registered the transport SHOULD buffer incoming messages.
    
    Specified by:
    
    readHandlerPromise in interface AssociationHandle
    
    Returns:
    
    Promise that must be completed with the listener responsible for handling incoming data.
  - write
```
public boolean write(ByteString payload)
```
    Description copied from interface: AssociationHandle
    
    Asynchronously sends the specified payload to the remote endpoint. This method MUST be thread-safe as it might be called from different threads. This method MUST NOT block.
    Writes guarantee ordering of messages, but not their reception. The call to write returns with a Boolean indicating if the channel was ready for writes or not. A return value of false indicates that the channel is not yet ready for delivery (e.g.: the write buffer is full) and the sender needs to wait until the channel becomes ready again. Returning false also means that the current write was dropped (this MUST be guaranteed to ensure duplication-free delivery).
    
    Specified by:
    
    write in interface AssociationHandle
    
    Parameters:
    
    payload - The payload to be delivered to the remote endpoint.
    
    Returns:
    
    Boolean indicating the availability of the association for subsequent writes.
  - disassociate
```
public void disassociate(java.lang.String reason,
                         LoggingAdapter log)
```
    Description copied from interface: AssociationHandle
    
    Closes the underlying transport link, if needed. Some transports might not need an explicit teardown (UDP) and some transports may not support it (hardware connections). Remote endpoint of the channel or connection MAY be notified, but this is not guaranteed. The Transport that provides the handle MUST guarantee that disassociate() could be called arbitrarily many times.
    
    Specified by:
    
    disassociate in interface AssociationHandle
  - disassociate
```
public void disassociate()
```
    Deprecated.
    Use method that states reasons to make sure disassociation reasons are logged. Since 2.5.3.
    
    Description copied from interface: AssociationHandle
    
    Closes the underlying transport link, if needed. Some transports might not need an explicit teardown (UDP) and some transports may not support it (hardware connections). Remote endpoint of the channel or connection MAY be notified, but this is not guaranteed. The Transport that provides the handle MUST guarantee that disassociate() could be called arbitrarily many times.
    
    Specified by:
    
    disassociate in interface AssociationHandle
  - notify
```
public void notify(AssociationHandle.HandleEvent ev)
```
    Description copied from interface: AssociationHandle.HandleEventListener
    
    Called by the transport to notify the listener about a HandleEvent
    
    Specified by:
    
    notify in interface AssociationHandle.HandleEventListener
    
    Parameters:
    
    ev - The HandleEvent of the handle
  - copy
```
public FailureInjectorHandle copy(AssociationHandle _wrappedHandle,
                                  FailureInjectorTransportAdapter gremlinAdapter)
```
  - copy$default$1
```
public AssociationHandle copy$default$1()
```
  - copy$default$2
```
public FailureInjectorTransportAdapter copy$default$2()
```
  - productPrefix
```
public java.lang.String productPrefix()
```
    Specified by:
    
    productPrefix in interface scala.Product
  - productArity
```
public int productArity()
```
    Specified by:
    
    productArity in interface scala.Product
  - productElement
```
public java.lang.Object productElement(int x$1)
```
    Specified by:
    
    productElement in interface scala.Product
  - productIterator
```
public scala.collection.Iterator<java.lang.Object> productIterator()
```
    Specified by:
    
    productIterator in interface scala.Product
  - canEqual
```
public boolean canEqual(java.lang.Object x$1)
```
    Specified by:
    
    canEqual in interface scala.Equals
  - productElementName
```
public java.lang.String productElementName(int x$1)
```
  - hashCode
```
public int hashCode()
```
    Overrides:
    
    hashCode in class java.lang.Object
  - toString
```
public java.lang.String toString()
```
    Overrides:
    
    toString in class java.lang.Object
  - equals
```
public boolean equals(java.lang.Object x$1)
```
    Specified by:
    
    equals in interface scala.Equals
    
    Overrides:
    
    equals in class java.lang.Object

Class FailureInjectorHandle

Nested Class Summary

Nested classes/interfaces inherited from interface akka.remote.transport.AssociationHandle

Constructor Summary

Method Summary

Methods inherited from class akka.remote.transport.AbstractTransportAdapterHandle

Methods inherited from class java.lang.Object

Methods inherited from interface akka.remote.transport.SchemeAugmenter

Constructor Detail

FailureInjectorHandle

Method Detail

apply

unapply

gremlinAdapter$access$1

_wrappedHandle

readHandlerPromise

write

disassociate

disassociate

notify

copy

copy$default$1

copy$default$2

productPrefix

productArity

productElement

productIterator

canEqual

productElementName

hashCode

toString

equals