org.apache.activemq.transport.udp
Class CommandDatagramSocket
java.lang.Object
org.apache.activemq.transport.udp.CommandChannelSupport
org.apache.activemq.transport.udp.CommandDatagramSocket
- All Implemented Interfaces:
- Service, Replayer, CommandChannel
public class CommandDatagramSocket
- extends CommandChannelSupport
A strategy for reading datagrams and de-fragmenting them together.
- Version:
- $Revision: 439111 $
CommandDatagramSocket
public CommandDatagramSocket(UdpTransport transport,
OpenWireFormat wireFormat,
int datagramSize,
SocketAddress targetAddress,
DatagramHeaderMarshaller headerMarshaller,
DatagramSocket channel)
start
public void start()
throws Exception
- Throws:
Exception
stop
public void stop()
throws Exception
- Throws:
Exception
read
public Command read()
throws IOException
- Throws:
IOException
write
public void write(Command command,
SocketAddress address)
throws IOException
- Throws:
IOException
getDatagramSize
public int getDatagramSize()
- Specified by:
getDatagramSize
in interface CommandChannel
- Overrides:
getDatagramSize
in class CommandChannelSupport
setDatagramSize
public void setDatagramSize(int datagramSize)
- Description copied from class:
CommandChannelSupport
- Sets the default size of a datagram on the network.
- Specified by:
setDatagramSize
in interface CommandChannel
- Overrides:
setDatagramSize
in class CommandChannelSupport
sendWriteBuffer
protected void sendWriteBuffer(SocketAddress address,
ByteArrayOutputStream writeBuffer,
int commandId)
throws IOException
- Throws:
IOException
sendWriteBuffer
protected void sendWriteBuffer(int commandId,
SocketAddress address,
byte[] data,
boolean redelivery)
throws IOException
- Throws:
IOException
sendBuffer
public void sendBuffer(int commandId,
Object buffer)
throws IOException
- Description copied from interface:
Replayer
- Sends the given buffer back to the transport
if the buffer could be found - otherwise maybe send some kind
of exception
- Parameters:
commandId
- the command IDbuffer
- the buffer to be sent - or null if the buffer no longer exists in the buffer
- Throws:
IOException
createDatagramPacket
protected DatagramPacket createDatagramPacket()
remaining
protected int remaining(ByteArrayOutputStream buffer)
createByteArrayOutputStream
protected ByteArrayOutputStream createByteArrayOutputStream()
Copyright © 2011 Apache Software Foundation. All Rights Reserved.