|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.codehaus.activemq.transport.AbstractTransportChannel
org.codehaus.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
|
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 |
protected void |
connect()
|
protected java.net.DatagramPacket |
createDatagramPacket()
|
protected java.net.DatagramPacket |
createDatagramPacket(Packet packet)
|
protected java.net.DatagramSocket |
createSocket(int port)
|
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 org.codehaus.activemq.transport.AbstractTransportChannel |
addTransportStatusEventListener, doAsyncSend, doConsumePacket, doHandleReceipt, fireStatusEvent, fireStatusEvent, getClientID, getExceptionListener, getPacketListener, getTransportChannelListener, onAsyncException, removeTransportStatusEventListener, send, send, setClientID, setExceptionListener, setPacketListener, setTransportChannelListener, stopExecutor |
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 JMSException
public UdpTransportChannel(WireFormat wireFormat, java.net.URI remoteLocation, int port) throws JMSException
public UdpTransportChannel(WireFormat wireFormat, java.net.DatagramSocket socket) throws JMSException
socket
-
JMSException
public UdpTransportChannel(WireFormat wireFormat, java.net.DatagramSocket socket, int port) throws JMSException
Method Detail |
public void stop()
stop
in interface TransportChannel
stop
in class AbstractTransportChannel
public void start() throws JMSException
start
in interface TransportChannel
JMSException
- if an error occurspublic void asyncSend(Packet packet) throws JMSException
asyncSend
in interface TransportChannel
packet
-
JMSException
public boolean isMulticast()
isMulticast
in interface TransportChannel
public void run()
run
in interface java.lang.Runnable
protected java.net.DatagramPacket createDatagramPacket()
protected java.net.DatagramPacket createDatagramPacket(Packet packet) throws java.io.IOException, JMSException
java.io.IOException
JMSException
protected void connect() throws java.io.IOException
java.io.IOException
protected java.net.DatagramSocket createSocket(int port) throws java.io.IOException
java.io.IOException
public java.lang.String toString()
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |