|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.codehaus.activemq.transport.TransportChannelSupport
org.codehaus.activemq.transport.composite.CompositeTransportChannel
A Compsite implementation of a TransportChannel
Field Summary | |
protected TransportChannel |
channel
|
protected SynchronizedBoolean |
closed
|
protected URI |
currentURI
|
protected long |
failureSleepTime
|
protected int |
maximumRetries
|
protected SynchronizedBoolean |
started
|
protected List |
uris
|
protected WireFormat |
wireFormat
|
Fields inherited from class org.codehaus.activemq.transport.TransportChannelSupport |
pendingStop, transportConnected |
Constructor Summary | |
CompositeTransportChannel(WireFormat wireFormat)
|
|
CompositeTransportChannel(WireFormat wireFormat,
List uris)
|
Method Summary | |
void |
asyncSend(Packet packet)
Asynchronously send a Packet |
protected void |
attemptToConnect(URI uri)
|
boolean |
canProcessWireFormatVersion(int version)
Can this wireformat process packets of this version |
protected void |
configureChannel()
|
protected void |
establishConnection(long timeout)
|
protected URI |
extractURI(List list)
|
protected TransportChannel |
getChannel()
|
int |
getCurrentWireFormatVersion()
|
long |
getEstablishConnectionTimeout()
Return the maximum amount of time spent trying to establish a connection or a negative number to keep going forever |
long |
getFailureSleepTime()
|
int |
getMaximumRetries()
|
List |
getUris()
|
boolean |
isMulticast()
|
Receipt |
send(Packet packet)
synchronously send a Packet |
Receipt |
send(Packet packet,
int timeout)
Synchronously send a Packet |
void |
setEstablishConnectionTimeout(long establishConnectionTimeout)
|
void |
setExceptionListener(ExceptionListener listener)
Set an exception listener to listen for asynchronously generated exceptions |
void |
setFailureSleepTime(long failureSleepTime)
|
void |
setMaximumRetries(int maximumRetries)
|
void |
setPacketListener(PacketListener listener)
Set a listener for Packets |
void |
setUris(List list)
|
void |
start()
start listeneing for events |
void |
stop()
close the channel |
String |
toString()
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Field Detail |
protected WireFormat wireFormat
protected List uris
protected TransportChannel channel
protected SynchronizedBoolean closed
protected SynchronizedBoolean started
protected int maximumRetries
protected long failureSleepTime
protected URI currentURI
Constructor Detail |
public CompositeTransportChannel(WireFormat wireFormat)
public CompositeTransportChannel(WireFormat wireFormat, List uris)
Method Detail |
public String toString()
public void start() throws JMSException
TransportChannel
JMSException
- if an error occurspublic void stop()
stop
in interface TransportChannel
stop
in class TransportChannelSupport
public Receipt send(Packet packet) throws JMSException
TransportChannelSupport
send
in interface TransportChannel
send
in class TransportChannelSupport
packet
-
JMSException
public Receipt send(Packet packet, int timeout) throws JMSException
TransportChannelSupport
send
in interface TransportChannel
send
in class TransportChannelSupport
packet
- packet to sendtimeout
- amount of time to wait for a receipt
JMSException
public void asyncSend(Packet packet) throws JMSException
TransportChannel
packet
-
JMSException
public void setPacketListener(PacketListener listener)
TransportChannelSupport
setPacketListener
in interface TransportChannel
setPacketListener
in class TransportChannelSupport
listener
- public void setExceptionListener(ExceptionListener listener)
TransportChannelSupport
setExceptionListener
in interface TransportChannel
setExceptionListener
in class TransportChannelSupport
listener
- public boolean isMulticast()
public long getEstablishConnectionTimeout()
public void setEstablishConnectionTimeout(long establishConnectionTimeout)
public int getMaximumRetries()
public void setMaximumRetries(int maximumRetries)
public long getFailureSleepTime()
public void setFailureSleepTime(long failureSleepTime)
public List getUris()
public void setUris(List list)
public boolean canProcessWireFormatVersion(int version)
version
- the version number to test
public int getCurrentWireFormatVersion()
protected void establishConnection(long timeout) throws JMSException
JMSException
protected TransportChannel getChannel() throws JMSException
JMSException
protected void configureChannel()
protected URI extractURI(List list) throws JMSException
JMSException
protected void attemptToConnect(URI uri) throws JMSException
JMSException
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |