org.codehaus.activemq.transport.jgroups
Class JGroupsTransportChannel

java.lang.Object
  org.codehaus.activemq.transport.AbstractTransportChannel
      org.codehaus.activemq.transport.jgroups.JGroupsTransportChannel

All Implemented Interfaces:

java.lang.Runnable, Service, TransportChannel

public class JGroupsTransportChannel

extends AbstractTransportChannel

implements java.lang.Runnable

A JGroups implementation of a TransportChannel

Version:

$Revision: 1.5 $

Constructor Summary

JGroupsTransportChannel(WireFormat wireFormat, org.jgroups.Channel channel, Executor executor)

Method Summary

void	asyncSend(Packet packet) Asynchronously send a Packet
boolean	isMulticast()
void	run() reads packets from a Socket
void	start() start listeneing for events
void	stop() close the channel
java.lang.String	toString()
protected void	writePacket(Packet packet) writes the packet to the channel

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

Constructor Detail

JGroupsTransportChannel

public JGroupsTransportChannel(WireFormat wireFormat,
                               org.jgroups.Channel channel,
                               Executor executor)

Method Detail

toString

public java.lang.String toString()

stop

public void stop()

close the channel

Specified by:

stop in interface TransportChannel

Overrides:

stop in class AbstractTransportChannel

start

public void start()
           throws JMSException

start listeneing for events

Specified by:

start in interface TransportChannel

Throws:

JMSException - if an error occurs

asyncSend

public void asyncSend(Packet packet)
               throws JMSException

Asynchronously send a Packet

Specified by:

asyncSend in interface TransportChannel

Parameters:

packet -

Throws:

JMSException

isMulticast

public boolean isMulticast()

Specified by:

isMulticast in interface TransportChannel

Returns:

true if this transport is multicast based (i.e. broadcasts to multiple nodes)

run

public void run()

reads packets from a Socket

Specified by:

run in interface java.lang.Runnable

writePacket

protected void writePacket(Packet packet)
                    throws JMSException

writes the packet to the channel

Throws:

JMSException