org.apache.activemq.transport.udp
Class CommandDatagramChannel
java.lang.Object
org.apache.activemq.transport.udp.CommandChannelSupport
org.apache.activemq.transport.udp.CommandDatagramChannel
- All Implemented Interfaces:
- Service, Replayer, CommandChannel
public class CommandDatagramChannel
- extends CommandChannelSupport
A strategy for reading datagrams and de-fragmenting them together.
- Version:
- $Revision: 439111 $
Methods inherited from class org.apache.activemq.transport.udp.CommandChannelSupport |
getDatagramSize, getHeaderMarshaller, getReplayAddress, getReplayBuffer, getTargetAddress, setDatagramSize, setHeaderMarshaller, setReplayAddress, setReplayBuffer, setTargetAddress, toString, write |
CommandDatagramChannel
public CommandDatagramChannel(UdpTransport transport,
OpenWireFormat wireFormat,
int datagramSize,
SocketAddress targetAddress,
DatagramHeaderMarshaller headerMarshaller,
DatagramChannel channel,
ByteBufferPool bufferPool)
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
getBufferPool
public ByteBufferPool getBufferPool()
setBufferPool
public void setBufferPool(ByteBufferPool bufferPool)
- Sets the implementation of the byte buffer pool to use
sendWriteBuffer
protected void sendWriteBuffer(int commandId,
SocketAddress address,
ByteBuffer writeBuffer,
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
Copyright © 2011 Apache Software Foundation. All Rights Reserved.