org.apache.activemq.broker
Class TransportConnector

java.lang.Object
  extended by org.apache.activemq.broker.TransportConnector
All Implemented Interfaces:
BrokerServiceAware, Connector, Service
Direct Known Subclasses:
ManagedTransportConnector

public class TransportConnector
extends Object
implements Connector, BrokerServiceAware


Field Summary
protected  CopyOnWriteArrayList<TransportConnection> connections
           
protected  TransportStatusDetector statusDector
           
 
Constructor Summary
TransportConnector()
           
TransportConnector(TransportServer server)
           
 
Method Summary
 void addPeerBroker(BrokerInfo info)
           
 ManagedTransportConnector asManagedConnector(ManagementContext context, ObjectName connectorName)
          Factory method to create a JMX managed version of this transport connector
 int connectionCount()
           
protected  Connection createConnection(Transport transport)
           
protected  DiscoveryAgent createDiscoveryAgent()
           
protected  TransportServer createTransportServer()
           
 Broker getBroker()
           
 BrokerInfo getBrokerInfo()
           
 BrokerService getBrokerService()
           
protected  ConnectionControl getConnectionControl()
           
 CopyOnWriteArrayList<TransportConnection> getConnections()
           
 URI getConnectUri()
           
 DiscoveryAgent getDiscoveryAgent()
           
 URI getDiscoveryUri()
           
 int getMaximumConsumersAllowedPerConnection()
           
 int getMaximumProducersAllowedPerConnection()
           
 MessageAuthorizationPolicy getMessageAuthorizationPolicy()
           
 String getName()
           
 LinkedList<String> getPeerBrokers()
           
 String getPublishableConnectString()
           
 PublishedAddressPolicy getPublishedAddressPolicy()
          Gets the currently configured policy for creating the published connection address of this TransportConnector.
 TransportServer getServer()
           
 ConnectorStatistics getStatistics()
           
 TaskRunnerFactory getTaskRunnerFactory()
           
 String getUpdateClusterFilter()
           
 URI getUri()
           
 boolean isAuditNetworkProducers()
           
 boolean isDisableAsyncDispatch()
           
 boolean isEnableStatusMonitor()
           
 boolean isRebalanceClusterClients()
           
 boolean isUpdateClusterClients()
           
 boolean isUpdateClusterClientsOnRemove()
           
 void onStarted(TransportConnection connection)
           
 void onStopped(TransportConnection connection)
           
 void removePeerBroker(BrokerInfo info)
           
 void setAuditNetworkProducers(boolean auditNetworkProducers)
          Enable a producer audit on network connections, Traps the case of a missing send reply and resend.
 void setBrokerInfo(BrokerInfo brokerInfo)
           
 void setBrokerService(BrokerService brokerService)
          This is called by the BrokerService right before it starts the transport.
 void setDisableAsyncDispatch(boolean disableAsyncDispatch)
           
 void setDiscoveryAgent(DiscoveryAgent discoveryAgent)
           
 void setDiscoveryUri(URI discoveryUri)
           
 void setEnableStatusMonitor(boolean enableStatusMonitor)
           
 void setMaximumConsumersAllowedPerConnection(int maximumConsumersAllowedPerConnection)
           
 void setMaximumProducersAllowedPerConnection(int maximumProducersAllowedPerConnection)
           
 void setMessageAuthorizationPolicy(MessageAuthorizationPolicy messageAuthorizationPolicy)
          Sets the policy used to decide if the current connection is authorized to consume a given message
 void setName(String name)
           
 void setPublishedAddressPolicy(PublishedAddressPolicy publishedAddressPolicy)
          Sets the configured policy for creating the published connection address of this TransportConnector.
 void setRebalanceClusterClients(boolean rebalanceClusterClients)
           
 void setServer(TransportServer server)
           
 void setTaskRunnerFactory(TaskRunnerFactory taskRunnerFactory)
           
 void setUpdateClusterClients(boolean updateClusterClients)
           
 void setUpdateClusterClientsOnRemove(boolean updateClusterClientsOnRemove)
           
 void setUpdateClusterFilter(String updateClusterFilter)
           
 void setUri(URI uri)
          Sets the server transport URI to use if there is not a TransportServer configured via the setServer(TransportServer) method.
 void start()
           
 void stop()
           
 String toString()
           
 void updateClientClusterInfo()
          Update all the connections with information about the connected brokers in the cluster
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Field Detail

connections

protected final CopyOnWriteArrayList<TransportConnection> connections

statusDector

protected TransportStatusDetector statusDector
Constructor Detail

TransportConnector

public TransportConnector()

TransportConnector

public TransportConnector(TransportServer server)
Method Detail

getConnections

public CopyOnWriteArrayList<TransportConnection> getConnections()
Returns:
Returns the connections.

asManagedConnector

public ManagedTransportConnector asManagedConnector(ManagementContext context,
                                                    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:
brokerInfo

setBrokerInfo

public void setBrokerInfo(BrokerInfo brokerInfo)

getServer

public TransportServer getServer()
                          throws IOException,
                                 URISyntaxException
Throws:
IOException
URISyntaxException

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

getPublishableConnectString

public String getPublishableConnectString()
                                   throws Exception
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

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

getConnectionControl

protected ConnectionControl getConnectionControl()

addPeerBroker

public void addPeerBroker(BrokerInfo info)

removePeerBroker

public void removePeerBroker(BrokerInfo info)

getPeerBrokers

public LinkedList<String> getPeerBrokers()

updateClientClusterInfo

public void updateClientClusterInfo()
Description copied from interface: Connector
Update all the connections with information about the connected brokers in the cluster

Specified by:
updateClientClusterInfo in interface Connector

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

setBrokerService

public void setBrokerService(BrokerService brokerService)
This is called by the BrokerService right before it starts the transport.

Specified by:
setBrokerService in interface BrokerServiceAware

getBroker

public Broker getBroker()

getBrokerService

public BrokerService getBrokerService()

isUpdateClusterClients

public boolean isUpdateClusterClients()
Specified by:
isUpdateClusterClients in interface Connector
Returns:
the updateClusterClients

setUpdateClusterClients

public void setUpdateClusterClients(boolean updateClusterClients)
Parameters:
updateClusterClients - the updateClusterClients to set

isRebalanceClusterClients

public boolean isRebalanceClusterClients()
Specified by:
isRebalanceClusterClients in interface Connector
Returns:
the rebalanceClusterClients

setRebalanceClusterClients

public void setRebalanceClusterClients(boolean rebalanceClusterClients)
Parameters:
rebalanceClusterClients - the rebalanceClusterClients to set

isUpdateClusterClientsOnRemove

public boolean isUpdateClusterClientsOnRemove()
Specified by:
isUpdateClusterClientsOnRemove in interface Connector
Returns:
the updateClusterClientsOnRemove

setUpdateClusterClientsOnRemove

public void setUpdateClusterClientsOnRemove(boolean updateClusterClientsOnRemove)
Parameters:
updateClusterClientsOnRemove - the updateClusterClientsOnRemove to set

getUpdateClusterFilter

public String getUpdateClusterFilter()
Returns:
the updateClusterFilter

setUpdateClusterFilter

public void setUpdateClusterFilter(String updateClusterFilter)
Parameters:
updateClusterFilter - the updateClusterFilter to set

connectionCount

public int connectionCount()
Specified by:
connectionCount in interface Connector

isAuditNetworkProducers

public boolean isAuditNetworkProducers()

setAuditNetworkProducers

public void setAuditNetworkProducers(boolean auditNetworkProducers)
Enable a producer audit on network connections, Traps the case of a missing send reply and resend. Note: does not work with conduit=false, networked composite destinations or networked virtual topics

Parameters:
auditNetworkProducers -

getMaximumProducersAllowedPerConnection

public int getMaximumProducersAllowedPerConnection()

setMaximumProducersAllowedPerConnection

public void setMaximumProducersAllowedPerConnection(int maximumProducersAllowedPerConnection)

getMaximumConsumersAllowedPerConnection

public int getMaximumConsumersAllowedPerConnection()

setMaximumConsumersAllowedPerConnection

public void setMaximumConsumersAllowedPerConnection(int maximumConsumersAllowedPerConnection)

getPublishedAddressPolicy

public PublishedAddressPolicy getPublishedAddressPolicy()
Gets the currently configured policy for creating the published connection address of this TransportConnector.

Returns:
the publishedAddressPolicy

setPublishedAddressPolicy

public void setPublishedAddressPolicy(PublishedAddressPolicy publishedAddressPolicy)
Sets the configured policy for creating the published connection address of this TransportConnector.



Copyright © 2005-2013 The Apache Software Foundation. All Rights Reserved.