org.apache.activemq.transport.peer
Class PeerTransportFactory

java.lang.Object
  extended by org.apache.activemq.transport.TransportFactory
      extended by org.apache.activemq.transport.peer.PeerTransportFactory

public class PeerTransportFactory
extends TransportFactory


Field Summary
static edu.emory.mathcs.backport.java.util.concurrent.ConcurrentHashMap brokers
           
static edu.emory.mathcs.backport.java.util.concurrent.ConcurrentHashMap connectors
           
static edu.emory.mathcs.backport.java.util.concurrent.ConcurrentHashMap servers
           
 
Constructor Summary
PeerTransportFactory()
           
 
Method Summary
 TransportServer doBind(java.lang.String brokerId, java.net.URI location)
           
 Transport doCompositeConnect(java.net.URI location)
           
 Transport doConnect(java.net.URI location)
           
 
Methods inherited from class org.apache.activemq.transport.TransportFactory
bind, compositeConfigure, compositeConnect, compositeConnect, configure, connect, connect, createTransport, createWireFormat, createWireFormatFactory, doCompositeConnect, doConnect, getDefaultWireFormatType, serverConfigure
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

brokers

public static final edu.emory.mathcs.backport.java.util.concurrent.ConcurrentHashMap brokers

connectors

public static final edu.emory.mathcs.backport.java.util.concurrent.ConcurrentHashMap connectors

servers

public static final edu.emory.mathcs.backport.java.util.concurrent.ConcurrentHashMap servers
Constructor Detail

PeerTransportFactory

public PeerTransportFactory()
Method Detail

doConnect

public Transport doConnect(java.net.URI location)
                    throws java.lang.Exception
Overrides:
doConnect in class TransportFactory
Throws:
java.lang.Exception

doCompositeConnect

public Transport doCompositeConnect(java.net.URI location)
                             throws java.lang.Exception
Overrides:
doCompositeConnect in class TransportFactory
Throws:
java.lang.Exception

doBind

public TransportServer doBind(java.lang.String brokerId,
                              java.net.URI location)
                       throws java.io.IOException
Specified by:
doBind in class TransportFactory
Throws:
java.io.IOException


Copyright © 2011 Apache Software Foundation. All Rights Reserved.