org.codehaus.activemq.transport.jgroups
Class JGroupsTransportChannelFactory
java.lang.Object
org.codehaus.activemq.transport.TransportChannelFactorySupport
org.codehaus.activemq.transport.jgroups.JGroupsTransportChannelFactory
- All Implemented Interfaces:
- TransportChannelFactory
- public class JGroupsTransportChannelFactory
- extends TransportChannelFactorySupport
A JGroups implementation of a TransportChannelFactory
- Version:
- $Revision: 1.5 $
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
JGroupsTransportChannelFactory
public JGroupsTransportChannelFactory()
JGroupsTransportChannelFactory
public JGroupsTransportChannelFactory(org.jgroups.ChannelFactory channelFactory,
Object channelConfiguration,
String channelName)
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.