|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.activemq.transport.TransportChannelSupport
org.activemq.transport.composite.CompositeTransportChannel
org.activemq.transport.reliable.ReliableTransportChannel
public class ReliableTransportChannel
A Compsite implementation of a TransportChannel
Field Summary |
---|
Fields inherited from class org.activemq.transport.composite.CompositeTransportChannel |
---|
channel, closed, currentURI, establishConnectionTimeout, failureSleepTime, incrementTimeout, maximumRetries, maximumTimeout, started, uris |
Fields inherited from class org.activemq.transport.TransportChannelSupport |
---|
cachingEnabled, currentWireFormat, noDelay, pendingStop, transportConnected, usedInternally |
Constructor Summary | |
---|---|
ReliableTransportChannel(WireFormat wireFormat)
Construct this transport |
|
ReliableTransportChannel(WireFormat wireFormat,
List uris)
Construct this transport |
Method Summary | |
---|---|
void |
asyncSend(Packet packet)
Asynchronously send a Packet |
ReceiptHolder |
asyncSendWithReceipt(Packet packet)
Asynchronously send a Packet with receipt. |
protected void |
configureChannel()
|
void |
consume(Packet packet)
consume a packet from the enbedded channel |
protected void |
doClose()
|
protected void |
doReconnect(TransportChannel currentChannel,
long timeout)
|
protected URI |
extractURI(List list)
|
protected void |
fireException(JMSException jmsEx)
Fire a JMSException to the exception listener |
protected TransportChannel |
getEstablishedChannel(long timeout)
|
long |
getKeepAliveTimeout()
|
void |
onException(JMSException jmsEx)
handle exception from the embedded channel |
Receipt |
send(Packet packet,
int timeout)
Synchronously send a Packet |
void |
setKeepAliveTimeout(long timeoutInterval)
Sets the number of milliseconds this channel can be idle after a keep-alive packet has been sent without being disconnected. |
void |
stop()
stop this channel |
String |
toString()
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Constructor Detail |
---|
public ReliableTransportChannel(WireFormat wireFormat)
wireFormat
- public ReliableTransportChannel(WireFormat wireFormat, List uris)
wireFormat
- uris
- Method Detail |
---|
public String toString()
toString
in class CompositeTransportChannel
public void setKeepAliveTimeout(long timeoutInterval)
timeoutInterval
- the timeout intervalpublic long getKeepAliveTimeout()
public Receipt send(Packet packet, int timeout) throws JMSException
TransportChannelSupport
send
in interface TransportChannel
send
in class CompositeTransportChannel
packet
- timeout
-
JMSException
public void asyncSend(Packet packet) throws JMSException
TransportChannel
asyncSend
in interface TransportChannel
asyncSend
in class CompositeTransportChannel
packet
-
JMSException
public ReceiptHolder asyncSendWithReceipt(Packet packet) throws JMSException
TransportChannelSupport
asyncSendWithReceipt
in interface TransportChannel
asyncSendWithReceipt
in class CompositeTransportChannel
packet
- the packet to send
JMSException
protected void configureChannel()
configureChannel
in class CompositeTransportChannel
protected URI extractURI(List list) throws JMSException
extractURI
in class CompositeTransportChannel
JMSException
public void consume(Packet packet)
consume
in interface PacketListener
packet
- to consumepublic void onException(JMSException jmsEx)
onException
in interface ExceptionListener
jmsEx
- public void stop()
stop
in interface Service
stop
in interface TransportChannel
stop
in class CompositeTransportChannel
protected void fireException(JMSException jmsEx)
jmsEx
- protected TransportChannel getEstablishedChannel(long timeout) throws JMSException
JMSException
protected void doReconnect(TransportChannel currentChannel, long timeout) throws JMSException
JMSException
protected void doClose()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |