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 java.lang.Object
- implements CommandChannel
- Version:
- $Revision: 426366 $
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Methods inherited from interface org.apache.activemq.transport.reliable.Replayer |
sendBuffer |
wireFormat
protected OpenWireFormat wireFormat
datagramSize
protected int datagramSize
targetAddress
protected java.net.SocketAddress targetAddress
replayAddress
protected java.net.SocketAddress replayAddress
name
protected final java.lang.String name
sequenceGenerator
protected final IntSequenceGenerator sequenceGenerator
headerMarshaller
protected DatagramHeaderMarshaller headerMarshaller
CommandChannelSupport
public CommandChannelSupport(UdpTransport transport,
OpenWireFormat wireFormat,
int datagramSize,
java.net.SocketAddress targetAddress,
DatagramHeaderMarshaller headerMarshaller)
write
public void write(Command command)
throws java.io.IOException
- Throws:
java.io.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 java.net.SocketAddress getTargetAddress()
setTargetAddress
public void setTargetAddress(java.net.SocketAddress targetAddress)
- Specified by:
setTargetAddress
in interface CommandChannel
getReplayAddress
public java.net.SocketAddress getReplayAddress()
setReplayAddress
public void setReplayAddress(java.net.SocketAddress replayAddress)
- Specified by:
setReplayAddress
in interface CommandChannel
toString
public java.lang.String toString()
- Overrides:
toString
in class java.lang.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 © 2010 Apache Software Foundation. All Rights Reserved.