org.codehaus.activemq.transport.multicast
Class MulticastTransportChannel

java.lang.Object
  extended byorg.codehaus.activemq.transport.TransportChannelSupport
      extended byorg.codehaus.activemq.transport.udp.UdpTransportChannel
          extended byorg.codehaus.activemq.transport.multicast.MulticastTransportChannel
All Implemented Interfaces:
Runnable, Service, TransportChannel

public class MulticastTransportChannel
extends UdpTransportChannel

A multicast implementation of a TransportChannel

Version:
$Revision: 1.3 $

Field Summary
 
Fields inherited from class org.codehaus.activemq.transport.udp.UdpTransportChannel
inetAddress, port, socket
 
Fields inherited from class org.codehaus.activemq.transport.TransportChannelSupport
pendingStop, transportConnected
 
Constructor Summary
MulticastTransportChannel(WireFormat wireFormat, MulticastSocket socket)
           
MulticastTransportChannel(WireFormat wireFormat, URI remoteLocation)
          Connect to a remote Node - e.g.
 
Method Summary
protected  void connect()
           
protected  DatagramSocket createSocket(int port)
           
 int getTimeToLive()
           
 boolean isMulticast()
           
 void setTimeToLive(int timeToLive)
           
 String toString()
          pretty print for object
 
Methods inherited from class org.codehaus.activemq.transport.udp.UdpTransportChannel
asyncSend, canProcessWireFormatVersion, createDatagramPacket, createDatagramPacket, forceDisconnect, getCurrentWireFormatVersion, run, start, stop
 
Methods inherited from class org.codehaus.activemq.transport.TransportChannelSupport
addTransportStatusEventListener, asyncSendWithReceipt, doAsyncSend, doConsumePacket, doConsumePacket, doHandleReceipt, doHandleWireFormat, fireStatusEvent, fireStatusEvent, getClientID, getEmbeddedBrokerConnector, getExceptionListener, getLastReceiptTimestamp, getPacketListener, getTransportChannelListener, isPendingStop, isServerSide, isTransportConnected, onAsyncException, removeTransportStatusEventListener, requiresEmbeddedBroker, send, send, setClientID, setExceptionListener, setPacketListener, setPendingStop, setServerSide, setTransportChannelListener, setTransportConnected, stopExecutor
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

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
Method Detail

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-2005 Protique, Ltd.. All Rights Reserved.