|
|||||||||||
| 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.udp.UdpTransportChannel
A UDP implementation of a TransportChannel
| Field Summary | |
protected java.net.InetAddress |
inetAddress
|
protected int |
port
|
protected java.net.DatagramSocket |
socket
|
| Fields inherited from class org.activemq.transport.TransportChannelSupport |
cachingEnabled, currentWireFormat, noDelay, pendingStop, transportConnected, usedInternally |
| Constructor Summary | |
protected |
UdpTransportChannel(WireFormat wireFormat)
Construct basic helpers |
|
UdpTransportChannel(WireFormat wireFormat,
java.net.DatagramSocket socket)
|
|
UdpTransportChannel(WireFormat wireFormat,
java.net.DatagramSocket socket,
int port)
|
|
UdpTransportChannel(WireFormat wireFormat,
java.net.URI remoteLocation)
|
|
UdpTransportChannel(WireFormat wireFormat,
java.net.URI remoteLocation,
int port)
|
| Method Summary | |
void |
asyncSend(Packet packet)
Asynchronously send a Packet |
boolean |
canProcessWireFormatVersion(int version)
Can this wireformat process packets of this version |
protected void |
connect()
|
protected java.net.DatagramPacket |
createDatagramPacket()
|
protected java.net.DatagramPacket |
createDatagramPacket(Packet packet)
|
protected java.net.DatagramSocket |
createSocket(int port)
|
void |
forceDisconnect()
Forces an immediate transport-level disconnect which will be asynchronously reported as an exception to the exceptionListener. |
int |
getCurrentWireFormatVersion()
|
boolean |
isMulticast()
|
void |
run()
reads packets from a Socket |
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 |
| Field Detail |
protected java.net.DatagramSocket socket
protected int port
protected java.net.InetAddress inetAddress
| Constructor Detail |
protected UdpTransportChannel(WireFormat wireFormat)
public UdpTransportChannel(WireFormat wireFormat,
java.net.URI remoteLocation)
throws javax.jms.JMSException
public UdpTransportChannel(WireFormat wireFormat,
java.net.URI remoteLocation,
int port)
throws javax.jms.JMSException
public UdpTransportChannel(WireFormat wireFormat,
java.net.DatagramSocket socket)
throws javax.jms.JMSException
socket -
javax.jms.JMSException
public UdpTransportChannel(WireFormat wireFormat,
java.net.DatagramSocket socket,
int port)
throws javax.jms.JMSException
| Method Detail |
public void stop()
stop in interface TransportChannelstop in class TransportChannelSupportpublic void forceDisconnect()
TransportChannel
forceDisconnect in interface TransportChannel
public void start()
throws javax.jms.JMSException
start in interface TransportChanneljavax.jms.JMSException - if an error occurs
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 boolean canProcessWireFormatVersion(int version)
canProcessWireFormatVersion in interface TransportChannelcanProcessWireFormatVersion in class TransportChannelSupportversion - the version number to test
public int getCurrentWireFormatVersion()
getCurrentWireFormatVersion in interface TransportChannelgetCurrentWireFormatVersion in class TransportChannelSupportprotected java.net.DatagramPacket createDatagramPacket()
protected java.net.DatagramPacket createDatagramPacket(Packet packet)
throws java.io.IOException,
javax.jms.JMSException
java.io.IOException
javax.jms.JMSException
protected void connect()
throws java.io.IOException
java.io.IOException
protected java.net.DatagramSocket createSocket(int port)
throws java.io.IOException
java.io.IOExceptionpublic java.lang.String toString()
|
|||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||||