public abstract class CommandChannelSupport extends Object implements CommandChannel
Modifier and Type | Field and Description |
---|---|
protected int |
datagramSize |
protected DatagramHeaderMarshaller |
headerMarshaller |
protected String |
name |
protected SocketAddress |
replayAddress |
protected IntSequenceGenerator |
sequenceGenerator |
protected SocketAddress |
targetAddress |
protected OpenWireFormat |
wireFormat |
Constructor and Description |
---|
CommandChannelSupport(UdpTransport transport,
OpenWireFormat wireFormat,
int datagramSize,
SocketAddress targetAddress,
DatagramHeaderMarshaller headerMarshaller) |
Modifier and Type | Method and Description |
---|---|
int |
getDatagramSize() |
DatagramHeaderMarshaller |
getHeaderMarshaller() |
SocketAddress |
getReplayAddress() |
ReplayBuffer |
getReplayBuffer() |
SocketAddress |
getTargetAddress() |
void |
setDatagramSize(int datagramSize)
Sets the default size of a datagram on the network.
|
void |
setHeaderMarshaller(DatagramHeaderMarshaller headerMarshaller) |
void |
setReplayAddress(SocketAddress replayAddress) |
void |
setReplayBuffer(ReplayBuffer replayBuffer) |
void |
setTargetAddress(SocketAddress targetAddress) |
String |
toString() |
void |
write(Command command) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getReceiveCounter, read, write
sendBuffer
protected OpenWireFormat wireFormat
protected int datagramSize
protected SocketAddress targetAddress
protected SocketAddress replayAddress
protected final IntSequenceGenerator sequenceGenerator
protected DatagramHeaderMarshaller headerMarshaller
public CommandChannelSupport(UdpTransport transport, OpenWireFormat wireFormat, int datagramSize, SocketAddress targetAddress, DatagramHeaderMarshaller headerMarshaller)
public void write(Command command) throws IOException
IOException
public int getDatagramSize()
getDatagramSize
in interface CommandChannel
public void setDatagramSize(int datagramSize)
setDatagramSize
in interface CommandChannel
public SocketAddress getTargetAddress()
public void setTargetAddress(SocketAddress targetAddress)
setTargetAddress
in interface CommandChannel
public SocketAddress getReplayAddress()
public void setReplayAddress(SocketAddress replayAddress)
setReplayAddress
in interface CommandChannel
public DatagramHeaderMarshaller getHeaderMarshaller()
getHeaderMarshaller
in interface CommandChannel
public void setHeaderMarshaller(DatagramHeaderMarshaller headerMarshaller)
setHeaderMarshaller
in interface CommandChannel
public ReplayBuffer getReplayBuffer()
public void setReplayBuffer(ReplayBuffer replayBuffer)
setReplayBuffer
in interface CommandChannel
Copyright © 2005–2016 FuseSource, Corp.. All rights reserved.