akka.io
Class UdpConnected

java.lang.Object
  extended by akka.io.UdpConnected
All Implemented Interfaces:
ExtensionId<UdpConnectedExt>, ExtensionIdProvider

public class UdpConnected
extends java.lang.Object
implements ExtensionId<UdpConnectedExt>, ExtensionIdProvider

UDP Extension for Akka’s IO layer.

All contents of the akka.io package is marked “experimental”.

This marker signifies that APIs may still change in response to user feedback through-out the 2.2 release cycle. The implementation itself is considered stable and ready for production use.

This extension implements the connectionless UDP protocol with calling connect on the underlying sockets, i.e. with restricting from whom data can be received. For “unconnected” UDP mode see Udp.

For a full description of the design and philosophy behind this IO implementation please refer to the Akka online documentation.

The Java API for generating UDP commands is available at UdpConnectedMessage.


Nested Class Summary
static interface UdpConnected.Command
          The common type of all commands supported by the UDP implementation.
static class UdpConnected.CommandFailed
          When a command fails it will be replied to with this message type, wrapping the failing command object.
static class UdpConnected.CommandFailed$
           
static class UdpConnected.Connect
          Send this message to the UdpExt.manager() in order to bind to a local port (optionally with the chosen localAddress) and create a UDP socket which is restricted to sending to and receiving from the given remoteAddress.
static class UdpConnected.Connect$
           
static interface UdpConnected.Connected
          This message is sent by the connection actor to the actor which sent the UdpConnected.Connect message when the UDP socket has been bound to the local and remote addresses given.
static class UdpConnected.Connected$
           
static class UdpConnected.Disconnect$
          Send this message to a connection actor (which had previously sent the UdpConnected.Connected message) in order to close the socket.
static interface UdpConnected.Disconnected
          This message is sent by the connection actor to the actor which sent the Disconnect message when the UDP socket has been closed.
static class UdpConnected.Disconnected$
           
static interface UdpConnected.Event
          The common type of all events emitted by the UDP implementation.
static interface UdpConnected.Message
          The common interface for UdpConnected.Command and UdpConnected.Event.
static class UdpConnected.NoAck
          Each UdpConnected.Send can optionally request a positive acknowledgment to be sent to the commanding actor.
static class UdpConnected.NoAck$
          Default UdpConnected.NoAck instance which is used when no acknowledgment information is explicitly provided.
static class UdpConnected.Received
          When a connection actor receives a datagram from its socket it will send it to the handler designated in the Udp.Bind message using this message type.
static class UdpConnected.Received$
           
static class UdpConnected.ResumeReading$
          This message must be sent to the listener actor to re-enable reading from the socket after a SuspendReading command.
static class UdpConnected.Send
          This message is understood by the connection actors to send data to their designated destination.
static class UdpConnected.Send$
           
static class UdpConnected.SuspendReading$
          Send this message to a listener actor (which sent a Udp.Bound message) to have it stop reading datagrams from the network.
 
Constructor Summary
UdpConnected()
           
 
Method Summary
static UdpConnectedExt createExtension(ExtendedActorSystem system)
           
static UdpConnectedExt get(ActorSystem system)
          Java API: retrieve the UdpConnected extension for the given system.
static UdpConnected$ lookup()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface akka.actor.ExtensionId
apply, createExtension, equals, get, hashCode
 
Methods inherited from interface akka.actor.ExtensionIdProvider
lookup
 

Constructor Detail

UdpConnected

public UdpConnected()
Method Detail

lookup

public static UdpConnected$ lookup()

createExtension

public static UdpConnectedExt createExtension(ExtendedActorSystem system)

get

public static UdpConnectedExt get(ActorSystem system)
Java API: retrieve the UdpConnected extension for the given system.