org.codehaus.activemq.transport.jgroups
Class JGroupsTransportChannelFactory

java.lang.Object
  extended byorg.codehaus.activemq.transport.TransportChannelFactorySupport
      extended byorg.codehaus.activemq.transport.jgroups.JGroupsTransportChannelFactory
All Implemented Interfaces:
TransportChannelFactory

public class JGroupsTransportChannelFactory
extends TransportChannelFactorySupport

A JGroups implementation of a TransportChannelFactory

Version:
$Revision: 1.5 $

Constructor Summary
JGroupsTransportChannelFactory()
           
JGroupsTransportChannelFactory(org.jgroups.ChannelFactory channelFactory, Object channelConfiguration, String channelName)
           
 
Method Summary
 TransportChannel create(WireFormat wireFormat, URI remoteLocation)
          Create a Channel to a remote Node - e.g.
 TransportChannel create(WireFormat wireFormat, URI remoteLocation, URI localLocation)
          Create a Channel to a remote Node - e.g.
protected  org.jgroups.Channel createChannel(URI remoteLocation)
           
 Object getChannelConfiguration()
           
 org.jgroups.ChannelFactory getChannelFactory()
           
 String getChannelName()
           
 boolean requiresEmbeddedBroker()
          Does this channel require an embedded broker to perform such as VM or multicast based transports
 void setChannelConfiguration(Object channelConfiguration)
           
 void setChannelFactory(org.jgroups.ChannelFactory channelFactory)
           
 void setChannelName(String channelName)
           
 
Methods inherited from class org.codehaus.activemq.transport.TransportChannelFactorySupport
populateProperties
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

JGroupsTransportChannelFactory

public JGroupsTransportChannelFactory()

JGroupsTransportChannelFactory

public JGroupsTransportChannelFactory(org.jgroups.ChannelFactory channelFactory,
                                      Object channelConfiguration,
                                      String channelName)
Method Detail

create

public TransportChannel create(WireFormat wireFormat,
                               URI remoteLocation)
                        throws JMSException
Description copied from interface: TransportChannelFactory
Create a Channel to a remote Node - e.g. a Broker

Parameters:
wireFormat -
remoteLocation -
Returns:
the TransportChannel bound to the remote node
Throws:
JMSException

create

public TransportChannel create(WireFormat wireFormat,
                               URI remoteLocation,
                               URI localLocation)
                        throws JMSException
Description copied from interface: TransportChannelFactory
Create a Channel to a remote Node - e.g. a Broker

Parameters:
wireFormat -
remoteLocation -
localLocation - - e.g. local InetAddress and local port
Returns:
the TransportChannel bound to the remote node
Throws:
JMSException

requiresEmbeddedBroker

public boolean requiresEmbeddedBroker()
Description copied from interface: TransportChannelFactory
Does this channel require an embedded broker to perform such as VM or multicast based transports

Returns:
true if an embedded broker is a requirement of using the channel

getChannelFactory

public org.jgroups.ChannelFactory getChannelFactory()

setChannelFactory

public void setChannelFactory(org.jgroups.ChannelFactory channelFactory)

getChannelConfiguration

public Object getChannelConfiguration()

setChannelConfiguration

public void setChannelConfiguration(Object channelConfiguration)

getChannelName

public String getChannelName()

setChannelName

public void setChannelName(String channelName)

createChannel

protected org.jgroups.Channel createChannel(URI remoteLocation)
                                     throws org.jgroups.ChannelException
Throws:
org.jgroups.ChannelException


Copyright © 2004 Protique, Ltd.. All Rights Reserved.