org.activemq.transport.multicast
Class MulticastTransportChannel
java.lang.Object
org.activemq.transport.TransportChannelSupport
org.activemq.transport.udp.UdpTransportChannel
org.activemq.transport.multicast.MulticastTransportChannel
- All Implemented Interfaces:
- Runnable, Service, TransportChannel
- public class MulticastTransportChannel
- extends UdpTransportChannel
A multicast implementation of a TransportChannel
- Version:
- $Revision: 1.1.1.1 $
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 |
MulticastTransportChannel
public MulticastTransportChannel(WireFormat wireFormat,
URI remoteLocation)
throws JMSException
- Connect to a remote Node - e.g. a Broker
- Parameters:
wireFormat
- remoteLocation
-
- Throws:
JMSException
MulticastTransportChannel
public MulticastTransportChannel(WireFormat wireFormat,
MulticastSocket socket)
throws JMSException
- Parameters:
wireFormat
- socket
-
- Throws:
JMSException
isMulticast
public boolean isMulticast()
- Specified by:
isMulticast
in interface TransportChannel
- Overrides:
isMulticast
in class UdpTransportChannel
- Returns:
- true
toString
public String toString()
- pretty print for object
- Overrides:
toString
in class UdpTransportChannel
- Returns:
- String representation of this object
getTimeToLive
public int getTimeToLive()
- Returns:
- Returns the timeToLive.
setTimeToLive
public void setTimeToLive(int timeToLive)
throws IOException
- Parameters:
timeToLive
- The timeToLive to set.
- Throws:
IOException
connect
protected void connect()
throws IOException
- Overrides:
connect
in class UdpTransportChannel
- Throws:
IOException
createSocket
protected DatagramSocket createSocket(int port)
throws IOException
- Overrides:
createSocket
in class UdpTransportChannel
- Throws:
IOException
Copyright © 2004-2007 Protique, Ltd.. All Rights Reserved.