|
|||||||||||
| 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.activeio.ActiveIOTransportChannel
A tcp implementation of a TransportChannel
| Field Summary |
| Fields inherited from class org.activemq.transport.TransportChannelSupport |
cachingEnabled, currentWireFormat, noDelay, pendingStop, transportConnected, usedInternally |
| Constructor Summary | |
ActiveIOTransportChannel(WireFormat wireFormat,
org.activeio.AsynchChannel asynchChannel)
|
|
| Method Summary | |
void |
asyncSend(Packet packet)
Asynchronously send a Packet |
protected Packet |
doAsyncSend(Packet packet)
send a Packet to the raw underlying transport This method is here to allow specific implementations to override this method |
void |
forceDisconnect()
Forces an immediate transport-level disconnect which will be asynchronously reported as an exception to the exceptionListener. |
org.activeio.AsynchChannel |
getAsynchChannel()
|
int |
getCurrentWireFormatVersion()
|
void |
onPacket(org.activeio.Packet packet)
|
void |
onPacketError(java.io.IOException ex)
|
void |
start()
start listeneing for events |
void |
stop()
close the channel |
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
| Constructor Detail |
public ActiveIOTransportChannel(WireFormat wireFormat,
org.activeio.AsynchChannel asynchChannel)
| Method Detail |
public void start()
throws javax.jms.JMSException
TransportChannel
start in interface TransportChanneljavax.jms.JMSException - if an error occurspublic void stop()
TransportChannelSupport
stop in interface TransportChannelstop in class TransportChannelSupportpublic void forceDisconnect()
TransportChannel
forceDisconnect in interface TransportChannel
public void asyncSend(Packet packet)
throws javax.jms.JMSException
TransportChannel
asyncSend in interface TransportChannelpacket - the packet to send
javax.jms.JMSException
protected Packet doAsyncSend(Packet packet)
throws javax.jms.JMSException
TransportChannelSupport
doAsyncSend in class TransportChannelSupportpacket -
javax.jms.JMSExceptionpublic void onPacket(org.activeio.Packet packet)
onPacket in interface org.activeio.AsynchChannelListenerpublic void onPacketError(java.io.IOException ex)
onPacketError in interface org.activeio.AsynchChannelListenerpublic org.activeio.AsynchChannel getAsynchChannel()
public int getCurrentWireFormatVersion()
getCurrentWireFormatVersion in interface TransportChannelgetCurrentWireFormatVersion in class TransportChannelSupport
|
|||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||||