org.apache.activemq.transport.udp
Class CommandChannelSupport

java.lang.Object
  extended by 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


Field Summary
protected  int datagramSize
           
protected  DatagramHeaderMarshaller headerMarshaller
           
protected  String name
           
protected  SocketAddress replayAddress
           
protected  IntSequenceGenerator sequenceGenerator
           
protected  SocketAddress targetAddress
           
protected  OpenWireFormat wireFormat
           
 
Constructor Summary
CommandChannelSupport(UdpTransport transport, OpenWireFormat wireFormat, int datagramSize, SocketAddress targetAddress, DatagramHeaderMarshaller headerMarshaller)
           
 
Method Summary
 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)
           
 
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.udp.CommandChannel
getReceiveCounter, read, write
 
Methods inherited from interface org.apache.activemq.transport.reliable.Replayer
sendBuffer
 
Methods inherited from interface org.apache.activemq.Service
start, stop
 

Field Detail

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
Constructor Detail

CommandChannelSupport

public CommandChannelSupport(UdpTransport transport,
                             OpenWireFormat wireFormat,
                             int datagramSize,
                             SocketAddress targetAddress,
                             DatagramHeaderMarshaller headerMarshaller)
Method Detail

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 © 2005-2012 The Apache Software Foundation. All Rights Reserved.