|
||||||||||
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.jrms.JRMSTransportChannel
public class JRMSTransportChannel
A JRMS implementation of a TransportChannel
Field Summary |
---|
Fields inherited from class org.activemq.transport.TransportChannelSupport |
---|
cachingEnabled, currentWireFormat, noDelay, pendingStop, transportConnected, usedInternally |
Constructor Summary | |
---|---|
protected |
JRMSTransportChannel(org.activemq.io.WireFormat wireFormat)
Construct basic helpers |
|
JRMSTransportChannel(org.activemq.io.WireFormat wireFormat,
URI remoteLocation)
Connect to a remote Node - e.g. |
Method Summary | |
---|---|
void |
asyncSend(org.activemq.message.Packet packet)
Asynchronously send a Packet |
boolean |
canProcessWireFormatVersion(int version)
Can this wireformat process packets of this version |
protected DatagramPacket |
createDatagramPacket()
|
protected DatagramPacket |
createDatagramPacket(org.activemq.message.Packet packet)
|
void |
forceDisconnect()
|
int |
getCurrentWireFormatVersion()
|
boolean |
isMulticast()
|
void |
run()
reads packets from a Socket |
void |
start()
start listeneing for events |
void |
stop()
close the channel |
String |
toString()
pretty print for object |
Methods inherited from class org.activemq.transport.TransportChannelSupport |
---|
addTransportStatusEventListener, asyncSendWithReceipt, doAsyncSend, doConsumePacket, doConsumePacket, doesSupportMessageCompression, doesSupportMessageFragmentation, doesSupportWireFormatVersioning, doHandleReceipt, doHandleWireFormat, fireStatusEvent, fireStatusEvent, getClientID, getEmbeddedBrokerConnector, getExceptionListener, getLastReceiptTimestamp, getPacketListener, getTransportChannelListener, getWireFormat, isCachingEnabled, isNoDelay, isPendingStop, isServerSide, isTransportConnected, isUsedInternally, onAsyncException, removeTransportStatusEventListener, requiresEmbeddedBroker, send, send, setCachingEnabled, setClientID, setExceptionListener, setNoDelay, setPacketListener, setPendingStop, setServerSide, setTransportChannelListener, setTransportConnected, setUsedInternally, setWireFormat, stopExecutor |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Constructor Detail |
---|
protected JRMSTransportChannel(org.activemq.io.WireFormat wireFormat)
public JRMSTransportChannel(org.activemq.io.WireFormat wireFormat, URI remoteLocation) throws JMSException
remoteLocation
-
JMSException
Method Detail |
---|
public void stop()
stop
in interface org.activemq.service.Service
stop
in interface org.activemq.transport.TransportChannel
stop
in class org.activemq.transport.TransportChannelSupport
public void start() throws JMSException
start
in interface org.activemq.service.Service
start
in interface org.activemq.transport.TransportChannel
JMSException
- if an error occurspublic void asyncSend(org.activemq.message.Packet packet) throws JMSException
asyncSend
in interface org.activemq.transport.TransportChannel
packet
-
JMSException
public boolean isMulticast()
isMulticast
in interface org.activemq.transport.TransportChannel
isMulticast
in class org.activemq.transport.TransportChannelSupport
public void run()
run
in interface Runnable
public boolean canProcessWireFormatVersion(int version)
canProcessWireFormatVersion
in interface org.activemq.transport.TransportChannel
canProcessWireFormatVersion
in class org.activemq.transport.TransportChannelSupport
version
- the version number to test
public int getCurrentWireFormatVersion()
getCurrentWireFormatVersion
in interface org.activemq.transport.TransportChannel
getCurrentWireFormatVersion
in class org.activemq.transport.TransportChannelSupport
protected DatagramPacket createDatagramPacket()
protected DatagramPacket createDatagramPacket(org.activemq.message.Packet packet) throws IOException, JMSException
IOException
JMSException
public String toString()
toString
in class Object
public void forceDisconnect()
forceDisconnect
in interface org.activemq.transport.TransportChannel
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |