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:
org.codehaus.activemq.transport.TransportChannelFactory

public class EmberTransportChannelFactory
extends EmberSupport
implements org.codehaus.activemq.transport.TransportChannelFactory

An EmberIO (using NIO) implementation of a TransportChannelFactory

Version:
$Revision: 1.2 $

Field Summary
protected static Log log
           
 
Constructor Summary
EmberTransportChannelFactory()
           
EmberTransportChannelFactory(pyrasun.eio.EIOGlobalContext context, pyrasun.eio.EIOPoolingStrategy ioPoolingStrategy)
           
 
Method Summary
 org.codehaus.activemq.transport.TransportChannel create(org.codehaus.activemq.io.WireFormat wireFormat, URI remoteLocation)
          Create a Channel to a remote Node - e.g.
 org.codehaus.activemq.transport.TransportChannel create(org.codehaus.activemq.io.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()
           
 
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 org.codehaus.activemq.transport.TransportChannel create(org.codehaus.activemq.io.WireFormat wireFormat,
                                                               URI remoteLocation)
                                                        throws JMSException
Create a Channel to a remote Node - e.g. a Broker

Specified by:
create in interface org.codehaus.activemq.transport.TransportChannelFactory
Parameters:
wireFormat -
remoteLocation -
Returns:
the TransportChannel bound to the remote node
Throws:
JMSException

create

public org.codehaus.activemq.transport.TransportChannel create(org.codehaus.activemq.io.WireFormat wireFormat,
                                                               URI remoteLocation,
                                                               URI localLocation)
                                                        throws JMSException
Create a Channel to a remote Node - e.g. a Broker

Specified by:
create in interface org.codehaus.activemq.transport.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()
Specified by:
requiresEmbeddedBroker in interface org.codehaus.activemq.transport.TransportChannelFactory

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