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

Field Summary

Fields

Modifier and Type	Field and Description
protected int	datagramSize
protected DatagramHeaderMarshaller	headerMarshaller
protected java.lang.String	name
protected java.net.SocketAddress	replayAddress
protected IntSequenceGenerator	sequenceGenerator
protected java.net.SocketAddress	targetAddress
protected OpenWireFormat	wireFormat

Constructor Summary

Constructors

Constructor and Description
CommandChannelSupport(UdpTransport transport, OpenWireFormat wireFormat, int datagramSize, java.net.SocketAddress targetAddress, DatagramHeaderMarshaller headerMarshaller)

Method Summary

Methods

Modifier and Type	Method and Description
int	getDatagramSize()
DatagramHeaderMarshaller	getHeaderMarshaller()
java.net.SocketAddress	getReplayAddress()
ReplayBuffer	getReplayBuffer()
java.net.SocketAddress	getTargetAddress()
void	setDatagramSize(int datagramSize) Sets the default size of a datagram on the network.
void	setHeaderMarshaller(DatagramHeaderMarshaller headerMarshaller)
void	setReplayAddress(java.net.SocketAddress replayAddress)
void	setReplayBuffer(ReplayBuffer replayBuffer)
void	setTargetAddress(java.net.SocketAddress targetAddress)
java.lang.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 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

Constructor Detail

CommandChannelSupport

public CommandChannelSupport(UdpTransport transport,
                     OpenWireFormat wireFormat,
                     int datagramSize,
                     java.net.SocketAddress targetAddress,
                     DatagramHeaderMarshaller headerMarshaller)

Method Detail

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