|
|||||||||||
| 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.vm.VmTransportChannel
A VM implementation of a TransportChannel
| Field Summary |
| Fields inherited from class org.activemq.transport.TransportChannelSupport |
cachingEnabled, currentWireFormat, noDelay, pendingStop, transportConnected, usedInternally |
| Constructor Summary | |
VmTransportChannel()
|
|
VmTransportChannel(EDU.oswego.cs.dl.util.concurrent.Channel sendChannel,
EDU.oswego.cs.dl.util.concurrent.Channel receiveChannel)
|
|
VmTransportChannel(int capacity)
|
|
| Method Summary | |
void |
asyncSend(Packet packet)
Asynchronously send a Packet |
boolean |
canProcessWireFormatVersion(int version)
Can this wireformat process packets of this version |
void |
connect(BrokerConnector brokerConnector)
Connects the client side transport channel with the broker |
protected EDU.oswego.cs.dl.util.concurrent.Channel |
createChannel(int capacity)
|
protected PacketListener |
createPacketListenerSender()
Creates a sender PacketListener which handles any receipts then delegates to the ultimate PacketListener (typically the JMS client) |
VmTransportChannel |
createServerSide()
Creates the server side version of this client side channel. |
protected void |
doClose(java.lang.Exception ex)
|
boolean |
doesSupportMessageCompression()
Some transports/wireformats will not be able to understand compressed messages |
boolean |
doesSupportMessageFragmentation()
some transports/wire formats will implement their own fragementation |
boolean |
doesSupportWireFormatVersioning()
Does the transport support wire format version info |
void |
forceDisconnect()
Forces an immediate transport-level disconnect which will be asynchronously reported as an exception to the exceptionListener. |
int |
getCurrentWireFormatVersion()
|
protected static int |
getNextThreadId()
|
int |
getReceiveCapacity()
|
EDU.oswego.cs.dl.util.concurrent.Channel |
getReceiveChannel()
|
int |
getSendCapacity()
|
EDU.oswego.cs.dl.util.concurrent.Channel |
getSendChannel()
|
PacketListener |
getSendListener()
|
boolean |
isAsyncSend()
|
boolean |
isMulticast()
|
void |
run()
reads packets from a Socket |
void |
setAsyncSend(boolean asyncSend)
|
void |
setPacketListener(PacketListener listener)
Set a listener for Packets |
void |
setReceiveCapacity(int receiveCapacity)
|
void |
setReceiveChannel(EDU.oswego.cs.dl.util.concurrent.Channel receiveChannel)
|
void |
setSendCapacity(int sendCapacity)
|
void |
setSendChannel(EDU.oswego.cs.dl.util.concurrent.Channel sendChannel)
|
void |
setSendListener(PacketListener sendListener)
|
void |
start()
start listeneing for events |
void |
stop()
close the channel |
java.lang.String |
toString()
pretty print for object |
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
| Constructor Detail |
public VmTransportChannel()
public VmTransportChannel(EDU.oswego.cs.dl.util.concurrent.Channel sendChannel,
EDU.oswego.cs.dl.util.concurrent.Channel receiveChannel)
public VmTransportChannel(int capacity)
| 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
asyncSend in interface TransportChannelpacket -
javax.jms.JMSExceptionpublic boolean isMulticast()
isMulticast in interface TransportChannelisMulticast in class TransportChannelSupportpublic void run()
run in interface java.lang.Runnablepublic java.lang.String toString()
public void connect(BrokerConnector brokerConnector)
throws javax.jms.JMSException
javax.jms.JMSException
public VmTransportChannel createServerSide()
throws javax.jms.JMSException
javax.jms.JMSExceptionpublic void setPacketListener(PacketListener listener)
TransportChannelSupport
setPacketListener in interface TransportChannelsetPacketListener in class TransportChannelSupportlistener - public boolean canProcessWireFormatVersion(int version)
canProcessWireFormatVersion in interface TransportChannelcanProcessWireFormatVersion in class TransportChannelSupportversion - the version number to test
public boolean doesSupportWireFormatVersioning()
doesSupportWireFormatVersioning in interface TransportChanneldoesSupportWireFormatVersioning in class TransportChannelSupportpublic int getCurrentWireFormatVersion()
getCurrentWireFormatVersion in interface TransportChannelgetCurrentWireFormatVersion in class TransportChannelSupportpublic boolean doesSupportMessageFragmentation()
doesSupportMessageFragmentation in interface TransportChanneldoesSupportMessageFragmentation in class TransportChannelSupportpublic boolean doesSupportMessageCompression()
doesSupportMessageCompression in interface TransportChanneldoesSupportMessageCompression in class TransportChannelSupportpublic int getReceiveCapacity()
public void setReceiveCapacity(int receiveCapacity)
public int getSendCapacity()
public void setSendCapacity(int sendCapacity)
public boolean isAsyncSend()
public void setAsyncSend(boolean asyncSend)
public EDU.oswego.cs.dl.util.concurrent.Channel getSendChannel()
public void setSendChannel(EDU.oswego.cs.dl.util.concurrent.Channel sendChannel)
public EDU.oswego.cs.dl.util.concurrent.Channel getReceiveChannel()
public void setReceiveChannel(EDU.oswego.cs.dl.util.concurrent.Channel receiveChannel)
protected static int getNextThreadId()
protected EDU.oswego.cs.dl.util.concurrent.Channel createChannel(int capacity)
protected PacketListener createPacketListenerSender()
protected void doClose(java.lang.Exception ex)
public PacketListener getSendListener()
public void setSendListener(PacketListener sendListener)
|
|||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||||