akka.io
Class UdpConnection

java.lang.Object
  extended by akka.io.UdpConnection
All Implemented Interfaces:
Actor, ActorLogging, RequiresMessageQueue<UnboundedMessageQueueSemantics>

public class UdpConnection
extends java.lang.Object
implements Actor, ActorLogging, RequiresMessageQueue<UnboundedMessageQueueSemantics>

INTERNAL API


Nested Class Summary
 
Nested classes/interfaces inherited from interface akka.actor.Actor
Actor.emptyBehavior$
 
Constructor Summary
UdpConnection(UdpConnectedExt udpConn, ChannelRegistry channelRegistry, ActorRef commander, UdpConnected.Connect connect)
           
 
Method Summary
 java.nio.channels.DatagramChannel channel()
           
 scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> connected(ChannelRegistration registration)
           
 void doRead(ChannelRegistration registration, ActorRef handler)
           
 void doWrite()
           
 scala.Tuple2<UdpConnected.Send,ActorRef> pendingSend()
           
 void postStop()
          User overridable callback.
 scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()
          This defines the initial actor behavior, it must return a partial function with the actor logic.
 boolean writePending()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface akka.actor.Actor
aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, postRestart, preRestart, preStart, self, sender, supervisorStrategy, unhandled
 
Methods inherited from interface akka.actor.ActorLogging
_log, log
 

Constructor Detail

UdpConnection

public UdpConnection(UdpConnectedExt udpConn,
                     ChannelRegistry channelRegistry,
                     ActorRef commander,
                     UdpConnected.Connect connect)
Method Detail

pendingSend

public scala.Tuple2<UdpConnected.Send,ActorRef> pendingSend()

writePending

public boolean writePending()

channel

public java.nio.channels.DatagramChannel channel()

receive

public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()
Description copied from interface: Actor
This defines the initial actor behavior, it must return a partial function with the actor logic.

Specified by:
receive in interface Actor
Returns:
(undocumented)

connected

public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> connected(ChannelRegistration registration)

doRead

public void doRead(ChannelRegistration registration,
                   ActorRef handler)

doWrite

public final void doWrite()

postStop

public void postStop()
Description copied from interface: Actor
User overridable callback.

Is called asynchronously after 'actor.stop()' is invoked. Empty default implementation.

Specified by:
postStop in interface Actor