Class NettyTransport
- java.lang.Object
-
- akka.remote.transport.netty.NettyTransport
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface akka.remote.transport.Transport
Transport.ActorAssociationEventListener, Transport.ActorAssociationEventListener$, Transport.AssociationEvent, Transport.AssociationEventListener, Transport.InboundAssociation, Transport.InboundAssociation$, Transport.InvalidAssociationException, Transport.InvalidAssociationException$
-
-
Constructor Summary
Constructors Constructor Description NettyTransport(ExtendedActorSystem system, com.typesafe.config.Config conf)
Deprecated.NettyTransport(NettyTransportSettings settings, ExtendedActorSystem system)
Deprecated.
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Deprecated Methods Modifier and Type Method Description static scala.Option<Address>
addressFromSocketAddress(java.net.SocketAddress addr, java.lang.String schemeIdentifier, java.lang.String systemName, scala.Option<java.lang.String> hostName)
Deprecated.static scala.Option<Address>
addressFromSocketAddress(java.net.SocketAddress addr, java.lang.String schemeIdentifier, java.lang.String systemName, scala.Option<java.lang.String> hostName, scala.Option<java.lang.Object> port)
Deprecated.scala.concurrent.Future<java.net.InetSocketAddress>
addressToSocketAddress(Address addr)
Deprecated.scala.concurrent.Future<AssociationHandle>
associate(Address remoteAddress)
Deprecated.Asynchronously opens a logical duplex link between two Transport Entities over a network.org.jboss.netty.channel.group.DefaultChannelGroup
channelGroup()
Deprecated.scala.concurrent.ExecutionContext
executionContext()
Deprecated.static int
FrameLengthFieldLength()
Deprecated.static void
gracefulClose(org.jboss.netty.channel.Channel channel, scala.concurrent.ExecutionContext ec)
Deprecated.boolean
isResponsibleFor(Address address)
Deprecated.A function that decides whether the specific transport instance is responsible for delivering to a given address.scala.concurrent.Future<scala.Tuple2<Address,scala.concurrent.Promise<Transport.AssociationEventListener>>>
listen()
Deprecated.Asynchronously attempts to setup the transport layer to listen and accept incoming associations.int
maximumPayloadBytes()
Deprecated.Defines the maximum size of payload this transport is able to deliver.java.lang.String
schemeIdentifier()
Deprecated.Returns a string that will be used as the scheme part of the URLs corresponding to this transportNettyTransportSettings
settings()
Deprecated.scala.concurrent.Future<java.lang.Object>
shutdown()
Deprecated.Shuts down the transport layer and releases all the corresponding resources.ExtendedActorSystem
system()
Deprecated.static java.util.concurrent.atomic.AtomicInteger
uniqueIdCounter()
Deprecated.-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface akka.remote.transport.Transport
managementCommand
-
-
-
-
Constructor Detail
-
NettyTransport
public NettyTransport(NettyTransportSettings settings, ExtendedActorSystem system)
Deprecated.
-
NettyTransport
public NettyTransport(ExtendedActorSystem system, com.typesafe.config.Config conf)
Deprecated.
-
-
Method Detail
-
FrameLengthFieldLength
public static int FrameLengthFieldLength()
Deprecated.
-
gracefulClose
public static void gracefulClose(org.jboss.netty.channel.Channel channel, scala.concurrent.ExecutionContext ec)
Deprecated.
-
uniqueIdCounter
public static java.util.concurrent.atomic.AtomicInteger uniqueIdCounter()
Deprecated.
-
addressFromSocketAddress
public static scala.Option<Address> addressFromSocketAddress(java.net.SocketAddress addr, java.lang.String schemeIdentifier, java.lang.String systemName, scala.Option<java.lang.String> hostName, scala.Option<java.lang.Object> port)
Deprecated.
-
addressFromSocketAddress
public static scala.Option<Address> addressFromSocketAddress(java.net.SocketAddress addr, java.lang.String schemeIdentifier, java.lang.String systemName, scala.Option<java.lang.String> hostName)
Deprecated.
-
settings
public NettyTransportSettings settings()
Deprecated.
-
system
public ExtendedActorSystem system()
Deprecated.
-
executionContext
public scala.concurrent.ExecutionContext executionContext()
Deprecated.
-
schemeIdentifier
public java.lang.String schemeIdentifier()
Deprecated.Description copied from interface:Transport
Returns a string that will be used as the scheme part of the URLs corresponding to this transport- Specified by:
schemeIdentifier
in interfaceTransport
- Returns:
- the scheme string
-
maximumPayloadBytes
public int maximumPayloadBytes()
Deprecated.Description copied from interface:Transport
Defines the maximum size of payload this transport is able to deliver. All transports MUST support at least 32kBytes (32000 octets) of payload, but some MAY support larger sizes.- Specified by:
maximumPayloadBytes
in interfaceTransport
- Returns:
-
channelGroup
public org.jboss.netty.channel.group.DefaultChannelGroup channelGroup()
Deprecated.
-
isResponsibleFor
public boolean isResponsibleFor(Address address)
Deprecated.Description copied from interface:Transport
A function that decides whether the specific transport instance is responsible for delivering to a given address. The function must be thread-safe and non-blocking.The purpose of this function is to resolve cases when the scheme part of an URL is not enough to resolve the correct transport i.e. multiple instances of the same transport implementation are loaded. These cases arise when - the same transport, but with different configurations is used for different remote systems - a transport is able to serve one address only (hardware protocols, e.g. Serial port) and multiple instances are needed to be loaded for different endpoints.
- Specified by:
isResponsibleFor
in interfaceTransport
- Returns:
- whether the transport instance is responsible to serve communications to the given address.
-
addressToSocketAddress
public scala.concurrent.Future<java.net.InetSocketAddress> addressToSocketAddress(Address addr)
Deprecated.
-
listen
public scala.concurrent.Future<scala.Tuple2<Address,scala.concurrent.Promise<Transport.AssociationEventListener>>> listen()
Deprecated.Description copied from interface:Transport
Asynchronously attempts to setup the transport layer to listen and accept incoming associations. The result of the attempt is wrapped by a Future returned by this method. The pair contained in the future contains a Promise for an ActorRef. By completing this Promise with anTransport.AssociationEventListener
, that listener becomes responsible for handling incoming associations. Until the Promise is not completed, no associations are processed.
-
associate
public scala.concurrent.Future<AssociationHandle> associate(Address remoteAddress)
Deprecated.Description copied from interface:Transport
Asynchronously opens a logical duplex link between two Transport Entities over a network. It could be backed by a real transport-layer connection (TCP), more lightweight connections provided over datagram protocols (UDP with additional services), substreams of multiplexed connections (SCTP) or physical links (serial port).This call returns a future of an
AssociationHandle
. A failed future indicates that the association attempt was unsuccessful. If the exception isTransport.InvalidAssociationException
then the association request was invalid, and it is impossible to recover.- Specified by:
associate
in interfaceTransport
- Parameters:
remoteAddress
- The address of the remote transport entity.- Returns:
- A status instance representing failure or a success containing an
AssociationHandle
-
shutdown
public scala.concurrent.Future<java.lang.Object> shutdown()
Deprecated.Description copied from interface:Transport
Shuts down the transport layer and releases all the corresponding resources. Shutdown is asynchronous signalling the end of the shutdown by completing the returned future.The transport SHOULD try flushing pending writes before becoming completely closed.
-
-