Package org.apache.pekko.io

Class UdpConnected

java.lang.Object

org.apache.pekko.io.UdpConnected

public class UdpConnected
extends Object

UDP Extension for Akka’s IO layer.

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 Pekko online documentation.

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

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	UdpConnected.Command	The common type of all commands supported by the UDP implementation.
static final 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 final 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 final 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 final 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

Constructors

Constructor	Description
UdpConnected()

Method Summary

Modifier and Type	Method	Description
static T	apply(ActorSystem system)
static T	apply(ClassicActorSystemProvider system)
static UdpConnectedExt	createExtension(ExtendedActorSystem system)
static final boolean	equals(Object other)
static UdpConnectedExt	get(ActorSystem system)	Java API: retrieve the UdpConnected extension for the given system.
static UdpConnectedExt	get(ClassicActorSystemProvider system)
static final int	hashCode()
static UdpConnected$	lookup()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

UdpConnected

public UdpConnected()

Method Details

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.

get

public static UdpConnectedExt get(ClassicActorSystemProvider system)

apply

public static T apply(ActorSystem system)

apply

public static T apply(ClassicActorSystemProvider system)

hashCode

public static final int hashCode()

equals

public static final boolean equals(Object other)