org.codehaus.activemq.transport.ember
Class EmberTransportChannelFactory

java.lang.Object
  extended byorg.codehaus.activemq.transport.ember.EmberSupport
      extended byorg.codehaus.activemq.transport.ember.EmberTransportChannelFactory
All Implemented Interfaces:
TransportChannelFactory

public class EmberTransportChannelFactory
extends EmberSupport
implements TransportChannelFactory

An EmberIO (using NIO) implementation of a TransportChannelFactory

Version:
$Revision: 1.8 $

Field Summary
protected static Log log
           
 
Constructor Summary
EmberTransportChannelFactory()
           
EmberTransportChannelFactory(pyrasun.eio.EIOGlobalContext context, pyrasun.eio.EIOPoolingStrategy ioPoolingStrategy)
           
 
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  pyrasun.eio.services.bytearray.ByteArrayServerClient createClient(pyrasun.eio.services.EmberServiceController controller, URI remoteLocation, String id)
           
protected  pyrasun.eio.services.bytearray.ByteArrayClientService createNioService(pyrasun.eio.services.EmberServiceController controller)
          Factory method to create a new ObjectClientService
 boolean requiresEmbeddedBroker()
          Does this channel require an embedded broker to perform such as VM or multicast based transports
 
Methods inherited from class org.codehaus.activemq.transport.ember.EmberSupport
createJMSException, getContext, getController, getIoPoolingStrategy, getKey, getPoolingStrategyByName
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

log

protected static final Log log
Constructor Detail

EmberTransportChannelFactory

public EmberTransportChannelFactory()

EmberTransportChannelFactory

public EmberTransportChannelFactory(pyrasun.eio.EIOGlobalContext context,
                                    pyrasun.eio.EIOPoolingStrategy ioPoolingStrategy)
Method Detail

create

public TransportChannel create(WireFormat wireFormat,
                               URI remoteLocation)
                        throws JMSException
Create a Channel to a remote Node - e.g. a Broker

Specified by:
create in interface TransportChannelFactory
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
Create a Channel to a remote Node - e.g. a Broker

Specified by:
create in interface TransportChannelFactory
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

Specified by:
requiresEmbeddedBroker in interface TransportChannelFactory
Returns:
true if an embedded broker is a requirement of using the channel

createClient

protected pyrasun.eio.services.bytearray.ByteArrayServerClient createClient(pyrasun.eio.services.EmberServiceController controller,
                                                                            URI remoteLocation,
                                                                            String id)
                                                                     throws JMSException,
                                                                            pyrasun.eio.services.EmberServiceException,
                                                                            IOException
Parameters:
remoteLocation -
id -
Returns:
@throws JMSException
Throws:
pyrasun.eio.services.EmberServiceException
IOException
JMSException

createNioService

protected pyrasun.eio.services.bytearray.ByteArrayClientService createNioService(pyrasun.eio.services.EmberServiceController controller)
                                                                          throws JMSException
Factory method to create a new ObjectClientService

Throws:
JMSException - if it could not be created


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