Package | Description |
---|---|
org.apache.activemq.command |
Command objects used via the Command Pattern to communicate among nodes
|
org.apache.activemq.transport.multicast |
A Multicast based Transport implementation.
|
org.apache.activemq.transport.udp |
UDP based Transport implementation.
|
Modifier and Type | Class and Description |
---|---|
class |
BaseEndpoint
A default endpoint.
|
Modifier and Type | Method and Description |
---|---|
Endpoint |
PartialCommand.getFrom() |
Endpoint |
WireFormatInfo.getFrom()
The endpoint within the transport where this message came from.
|
Endpoint |
BaseCommand.getFrom()
The endpoint within the transport where this message came from.
|
Endpoint |
Command.getFrom()
The endpoint within the transport where this message came from which
could be null if the transport only supports a single endpoint.
|
Endpoint |
KeepAliveInfo.getFrom()
The endpoint within the transport where this message came from.
|
Endpoint |
PartialCommand.getTo() |
Endpoint |
WireFormatInfo.getTo()
The endpoint within the transport where this message is going to - null
means all endpoints.
|
Endpoint |
BaseCommand.getTo()
The endpoint within the transport where this message is going to - null
means all endpoints.
|
Endpoint |
Command.getTo()
The endpoint within the transport where this message is going to - null
means all endpoints.
|
Endpoint |
KeepAliveInfo.getTo()
The endpoint within the transport where this message is going to - null
means all endpoints.
|
Modifier and Type | Method and Description |
---|---|
void |
PartialCommand.setFrom(Endpoint from) |
void |
WireFormatInfo.setFrom(Endpoint from) |
void |
BaseCommand.setFrom(Endpoint from) |
void |
Command.setFrom(Endpoint from) |
void |
KeepAliveInfo.setFrom(Endpoint from) |
void |
PartialCommand.setTo(Endpoint to) |
void |
WireFormatInfo.setTo(Endpoint to) |
void |
BaseCommand.setTo(Endpoint to) |
void |
Command.setTo(Endpoint to) |
void |
KeepAliveInfo.setTo(Endpoint to) |
Modifier and Type | Method and Description |
---|---|
Endpoint |
MulticastDatagramHeaderMarshaller.createEndpoint(ByteBuffer readBuffer,
SocketAddress address) |
Modifier and Type | Class and Description |
---|---|
class |
DatagramEndpoint |
Modifier and Type | Method and Description |
---|---|
Endpoint |
DatagramHeaderMarshaller.createEndpoint(ByteBuffer readBuffer,
SocketAddress address)
Reads any header if applicable and then creates an endpoint object
|
Endpoint |
DatagramHeaderMarshaller.createEndpoint(DatagramPacket datagram,
DataInputStream dataIn) |
protected Endpoint |
DatagramHeaderMarshaller.createEndpoint(SocketAddress address) |
protected Endpoint |
DatagramHeaderMarshaller.getEndpoint(SocketAddress address)
Gets the current endpoint object for this address or creates one if not available.
|
Modifier and Type | Method and Description |
---|---|
void |
UdpTransport.setTargetEndpoint(Endpoint newTarget)
We have received the WireFormatInfo from the server on the actual channel
we should use for all future communication with the server, so lets set
the target to be the actual channel that the server has chosen for us to
talk on.
|
Copyright © 2005–2016 FuseSource, Corp.. All rights reserved.