org.apache.activemq.transport.udp
Class CommandChannelSupport
java.lang.Object
org.apache.activemq.transport.udp.CommandChannelSupport
- All Implemented Interfaces:
- Service, Replayer, CommandChannel
- Direct Known Subclasses:
- CommandDatagramChannel, CommandDatagramSocket
public abstract class CommandChannelSupport
- extends Object
- implements CommandChannel
- Version:
- $Revision: 426366 $
Methods inherited from interface org.apache.activemq.transport.reliable.Replayer |
sendBuffer |
wireFormat
protected OpenWireFormat wireFormat
datagramSize
protected int datagramSize
targetAddress
protected SocketAddress targetAddress
replayAddress
protected SocketAddress replayAddress
name
protected final String name
sequenceGenerator
protected final IntSequenceGenerator sequenceGenerator
headerMarshaller
protected DatagramHeaderMarshaller headerMarshaller
CommandChannelSupport
public CommandChannelSupport(UdpTransport transport,
OpenWireFormat wireFormat,
int datagramSize,
SocketAddress targetAddress,
DatagramHeaderMarshaller headerMarshaller)
write
public void write(Command command)
throws IOException
- Throws:
IOException
getDatagramSize
public int getDatagramSize()
- Specified by:
getDatagramSize
in interface CommandChannel
setDatagramSize
public void setDatagramSize(int datagramSize)
- Sets the default size of a datagram on the network.
- Specified by:
setDatagramSize
in interface CommandChannel
getTargetAddress
public SocketAddress getTargetAddress()
setTargetAddress
public void setTargetAddress(SocketAddress targetAddress)
- Specified by:
setTargetAddress
in interface CommandChannel
getReplayAddress
public SocketAddress getReplayAddress()
setReplayAddress
public void setReplayAddress(SocketAddress replayAddress)
- Specified by:
setReplayAddress
in interface CommandChannel
toString
public String toString()
- Overrides:
toString
in class Object
getHeaderMarshaller
public DatagramHeaderMarshaller getHeaderMarshaller()
- Specified by:
getHeaderMarshaller
in interface CommandChannel
setHeaderMarshaller
public void setHeaderMarshaller(DatagramHeaderMarshaller headerMarshaller)
- Specified by:
setHeaderMarshaller
in interface CommandChannel
getReplayBuffer
public ReplayBuffer getReplayBuffer()
setReplayBuffer
public void setReplayBuffer(ReplayBuffer replayBuffer)
- Specified by:
setReplayBuffer
in interface CommandChannel
Copyright © 2011 Apache Software Foundation. All Rights Reserved.