org.apache.activemq.broker
Class TransportConnector
java.lang.Object
org.apache.activemq.broker.TransportConnector
- All Implemented Interfaces:
- Connector, Service
- Direct Known Subclasses:
- ManagedTransportConnector
public class TransportConnector
- extends Object
- implements Connector
- Version:
- $Revision: 1.6 $
connections
protected edu.emory.mathcs.backport.java.util.concurrent.CopyOnWriteArrayList connections
statusDector
protected TransportStatusDetector statusDector
TransportConnector
public TransportConnector()
TransportConnector
public TransportConnector(Broker broker,
TransportServer server)
getConnections
public edu.emory.mathcs.backport.java.util.concurrent.CopyOnWriteArrayList getConnections()
- Returns:
- Returns the connections.
asManagedConnector
public ManagedTransportConnector asManagedConnector(MBeanServer mbeanServer,
ObjectName connectorName)
throws IOException,
URISyntaxException
- Factory method to create a JMX managed version of this transport connector
- Throws:
IOException
URISyntaxException
getBrokerInfo
public BrokerInfo getBrokerInfo()
- Specified by:
getBrokerInfo
in interface Connector
- Returns:
setBrokerInfo
public void setBrokerInfo(BrokerInfo brokerInfo)
getServer
public TransportServer getServer()
throws IOException,
URISyntaxException
- Throws:
IOException
URISyntaxException
getBroker
public Broker getBroker()
setBroker
public void setBroker(Broker broker)
setBrokerName
public void setBrokerName(String brokerName)
setServer
public void setServer(TransportServer server)
getUri
public URI getUri()
setUri
public void setUri(URI uri)
- Sets the server transport URI to use if there is not a
TransportServer
configured via the
setServer(TransportServer)
method. This value is used to lazy
create a TransportServer
instance
- Parameters:
uri
-
getTaskRunnerFactory
public TaskRunnerFactory getTaskRunnerFactory()
setTaskRunnerFactory
public void setTaskRunnerFactory(TaskRunnerFactory taskRunnerFactory)
getStatistics
public ConnectorStatistics getStatistics()
- Specified by:
getStatistics
in interface Connector
- Returns:
- the statistics for this connector
getMessageAuthorizationPolicy
public MessageAuthorizationPolicy getMessageAuthorizationPolicy()
setMessageAuthorizationPolicy
public void setMessageAuthorizationPolicy(MessageAuthorizationPolicy messageAuthorizationPolicy)
- Sets the policy used to decide if the current connection is authorized to consume
a given message
start
public void start()
throws Exception
- Specified by:
start
in interface Service
- Throws:
Exception
stop
public void stop()
throws Exception
- Specified by:
stop
in interface Service
- Throws:
Exception
createConnection
protected Connection createConnection(Transport transport)
throws IOException
- Throws:
IOException
createTransportServer
protected TransportServer createTransportServer()
throws IOException,
URISyntaxException
- Throws:
IOException
URISyntaxException
getDiscoveryAgent
public DiscoveryAgent getDiscoveryAgent()
throws IOException
- Throws:
IOException
createDiscoveryAgent
protected DiscoveryAgent createDiscoveryAgent()
throws IOException
- Throws:
IOException
setDiscoveryAgent
public void setDiscoveryAgent(DiscoveryAgent discoveryAgent)
getDiscoveryUri
public URI getDiscoveryUri()
setDiscoveryUri
public void setDiscoveryUri(URI discoveryUri)
getConnectUri
public URI getConnectUri()
throws IOException,
URISyntaxException
- Throws:
IOException
URISyntaxException
setConnectUri
public void setConnectUri(URI transportUri)
onStarted
public void onStarted(TransportConnection connection)
onStopped
public void onStopped(TransportConnection connection)
getName
public String getName()
setName
public void setName(String name)
toString
public String toString()
- Overrides:
toString
in class Object
isDisableAsyncDispatch
public boolean isDisableAsyncDispatch()
setDisableAsyncDispatch
public void setDisableAsyncDispatch(boolean disableAsyncDispatch)
isEnableStatusMonitor
public boolean isEnableStatusMonitor()
- Returns:
- the enableStatusMonitor
setEnableStatusMonitor
public void setEnableStatusMonitor(boolean enableStatusMonitor)
- Parameters:
enableStatusMonitor
- the enableStatusMonitor to set
Copyright © 2011 Apache Software Foundation. All Rights Reserved.