Examples of TransportManager

ch.ethz.ssh2.transport.TransportManager
TransportManager. @author Christian Plattner, plattner@inf.ethz.ch @version $Id: TransportManager.java,v 1.16 2006/08/11 12:24:00 cplattne Exp $
com.dianping.cat.message.io.TransportManager
com.sun.corba.ee.spi.transport.TransportManager
com.trilead.ssh2.transport.TransportManager
TransportManager. @author Christian Plattner, plattner@trilead.com @version $Id: TransportManager.java,v 1.2 2008/04/01 12:38:09 cplattne Exp $
net.sourceforge.peers.sip.transport.TransportManager
no.ugland.utransprod.service.TransportManager
Interface for manager for transport @author atle.brekka
org.codehaus.xfire.transport.TransportManager
Registers transports for the SOAP services. @author Dan Diephouse
org.eclipse.persistence.sessions.coordination.TransportManager

Purpose: Provide an abstract class that offers a common API to handling remote command connections.
Description: This class manages the remote connections to other RCM service instances and posts the local connection to this service instance in a name service so that other RCM service instances can connect to it.
@author Steven Vo @since OracleAS TopLink 10g (9.0.4)
org.jacorb.orb.giop.TransportManager
This class manages Transports. On the one hand it creates them, and on the other it enforces an upper limit on the open transports. The class also receives notifications from threads that are about do use a Transport and notifies any interested listeners. "Use" is defined as sending (or handling) a request. @author Nicolas Noffke @version $Id: TransportManager.java,v 1.30 2009-05-03 21:35:56 andre.spiegel Exp $
org.jboss.wsf.spi.transport.TransportManager
A transport abstraction that knows how to create and destroy endpoint listener for
- a particular protocol
- using transport specific properties
@author Heiko.Braun

Examples of org.eclipse.persistence.sessions.coordination.TransportManager

                if (protocol.equalsIgnoreCase(CacheCoordinationProtocol.JGROUPS)) {
                    property = PersistenceUnitProperties.COORDINATION_PROTOCOL;                    
                    value = "org.eclipse.persistence.sessions.coordination.jgroups.JGroupsTransportManager";
                    // Avoid compile and runtime dependency.
                    Class transportClass = findClassForProperty(value, PersistenceUnitProperties.COORDINATION_PROTOCOL, loader);
                    TransportManager transport = (TransportManager)transportClass.newInstance();
                    rcm.setTransportManager(transport);                    
                    String config = getConfigPropertyAsStringLogDebug(PersistenceUnitProperties.COORDINATION_JGROUPS_CONFIG, m, this.session);
                    if (config != null) {
                        transport.setConfig(config);
                    }                    
                } else if (protocol.equalsIgnoreCase(CacheCoordinationProtocol.JMS) || protocol.equalsIgnoreCase(CacheCoordinationProtocol.JMSPublishing)) {
                    JMSPublishingTransportManager transport = null;
                    if (protocol.equalsIgnoreCase(CacheCoordinationProtocol.JMS)) {
                         transport = new JMSTopicTransportManager(rcm);
                    } else {
                        transport = new JMSPublishingTransportManager(rcm);
                    }
                    rcm.setTransportManager(transport);
                    
                    String host = getConfigPropertyAsStringLogDebug(PersistenceUnitProperties.COORDINATION_JMS_HOST, m, this.session);
                    if (host != null) {
                        transport.setTopicHostUrl(host);
                    }
                    String topic = getConfigPropertyAsStringLogDebug(PersistenceUnitProperties.COORDINATION_JMS_TOPIC, m, this.session);
                    if (topic != null) {
                        transport.setTopicName(topic);
                    }
                    String factory = getConfigPropertyAsStringLogDebug(PersistenceUnitProperties.COORDINATION_JMS_FACTORY, m, this.session);
                    if (factory != null) {
                        transport.setTopicConnectionFactoryName(factory);
                    }
                    
                    String reuse_publisher = getConfigPropertyAsStringLogDebug(PersistenceUnitProperties.COORDINATION_JMS_REUSE_PUBLISHER, m, this.session);
                    if (reuse_publisher != null) {
                        transport.setShouldReuseJMSTopicPublisher(reuse_publisher.equalsIgnoreCase("true"));
                    }
                    
                } else if (protocol.equalsIgnoreCase(CacheCoordinationProtocol.RMI) || protocol.equalsIgnoreCase(CacheCoordinationProtocol.RMIIIOP)) {
                    if (protocol.equalsIgnoreCase(CacheCoordinationProtocol.RMIIIOP)) {
                        ((RMITransportManager)rcm.getTransportManager()).setIsRMIOverIIOP(true);

View Full Code Here

Examples of org.jacorb.orb.giop.TransportManager


    public synchronized TransportManager getTransportManager()
    {
        if (transport_manager == null)
        {
            transport_manager = new TransportManager(this);
            try
            {
                transport_manager.configure(configuration);
            }
            catch( ConfigurationException e )

View Full Code Here

Examples of org.jacorb.orb.giop.TransportManager

            {
                throw new ConfigurationException("Listener: Couldn't init", e);
            }


            this.transport_manager =
                new TransportManager( (org.jacorb.orb.ORB) orb );
            this.transport_manager.configure(configuration);
        }

View Full Code Here

Examples of org.jacorb.orb.giop.TransportManager

            {
                throw new ConfigurationException("Listener: Couldn't init", e);
            }


            this.transport_manager =
                new TransportManager( (org.jacorb.orb.ORB) orb );
            this.transport_manager.configure(configuration);
        }

View Full Code Here

Examples of org.jacorb.orb.giop.TransportManager


    public synchronized TransportManager getTransportManager()
    {
        if (transport_manager == null)
        {
            transport_manager = new TransportManager(this);
            try
            {
                transport_manager.configure(configuration);
            }
            catch( ConfigurationException e )

View Full Code Here

Examples of org.jacorb.orb.giop.TransportManager


    public synchronized TransportManager getTransportManager()
    {
        if (transport_manager == null)
        {
            transport_manager = new TransportManager(this);
            try
            {
                transport_manager.configure(configuration);
            }
            catch( ConfigurationException e )

View Full Code Here

Examples of org.jacorb.orb.giop.TransportManager


    public synchronized TransportManager getTransportManager()
    {
        if (transport_manager == null)
        {
            transport_manager = new TransportManager(this);
            try
            {
                transport_manager.configure(configuration);
            }
            catch( ConfigurationException e )

View Full Code Here

Examples of org.jacorb.orb.giop.TransportManager

            catch (Exception e)
            {
                throw new ConfigurationException("Listener: Couldn't init", e);
            }


            this.transport_manager = new TransportManager();
            this.transport_manager.configure(configuration);
        }

View Full Code Here

Examples of org.jacorb.orb.giop.TransportManager

                {
                    throw new ConfigurationException ("SelectorManager initialization failed", e);
                }
            }


            transport_manager = new TransportManager();


            transport_manager.configure(configuration);


            giop_connection_manager = new GIOPConnectionManager();

View Full Code Here

Examples of org.jboss.wsf.spi.transport.TransportManager

      this.httpTransport = httpTransport;
   }


   public TransportManager createTransportManager(Protocol protocol)
   {
      TransportManager manager = null;


      switch(protocol)
      {
         case HTTP:
            manager = httpTransport;

View Full Code Here

0 1 2 3

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.