|
||||||||||
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
public class 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(Channel sendChannel,
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 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(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()
|
Channel |
getReceiveChannel()
|
int |
getSendCapacity()
|
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(Channel receiveChannel)
|
void |
setSendCapacity(int sendCapacity)
|
void |
setSendChannel(Channel sendChannel)
|
void |
setSendListener(PacketListener sendListener)
|
void |
start()
Called to start the service |
void |
stop()
close the channel |
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(Channel sendChannel, Channel receiveChannel)
public VmTransportChannel(int capacity)
Method Detail |
---|
public void start() throws JMSException
Service
start
in interface Service
start
in interface TransportChannel
JMSException
- if an error occurspublic void stop()
TransportChannelSupport
stop
in interface Service
stop
in interface TransportChannel
stop
in class TransportChannelSupport
public void forceDisconnect()
TransportChannel
forceDisconnect
in interface TransportChannel
public void asyncSend(Packet packet) throws JMSException
asyncSend
in interface TransportChannel
packet
-
JMSException
public boolean isMulticast()
isMulticast
in interface TransportChannel
isMulticast
in class TransportChannelSupport
public void run()
run
in interface Runnable
public String toString()
toString
in class Object
public void connect(BrokerConnector brokerConnector) throws JMSException
JMSException
public VmTransportChannel createServerSide() throws JMSException
JMSException
public void setPacketListener(PacketListener listener)
TransportChannelSupport
setPacketListener
in interface TransportChannel
setPacketListener
in class TransportChannelSupport
public boolean canProcessWireFormatVersion(int version)
canProcessWireFormatVersion
in interface TransportChannel
canProcessWireFormatVersion
in class TransportChannelSupport
version
- the version number to test
public boolean doesSupportWireFormatVersioning()
doesSupportWireFormatVersioning
in interface TransportChannel
doesSupportWireFormatVersioning
in class TransportChannelSupport
public int getCurrentWireFormatVersion()
getCurrentWireFormatVersion
in interface TransportChannel
getCurrentWireFormatVersion
in class TransportChannelSupport
public boolean doesSupportMessageFragmentation()
doesSupportMessageFragmentation
in interface TransportChannel
doesSupportMessageFragmentation
in class TransportChannelSupport
public boolean doesSupportMessageCompression()
doesSupportMessageCompression
in interface TransportChannel
doesSupportMessageCompression
in class TransportChannelSupport
public int getReceiveCapacity()
public void setReceiveCapacity(int receiveCapacity)
public int getSendCapacity()
public void setSendCapacity(int sendCapacity)
public boolean isAsyncSend()
public void setAsyncSend(boolean asyncSend)
public Channel getSendChannel()
public void setSendChannel(Channel sendChannel)
public Channel getReceiveChannel()
public void setReceiveChannel(Channel receiveChannel)
protected static int getNextThreadId()
protected Channel createChannel(int capacity)
protected PacketListener createPacketListenerSender()
protected void doClose(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 |