org.apache.activemq.broker
public class TransportConnector extends java.lang.Object implements Connector, BrokerServiceAware
Modifier and Type | Field and Description |
---|---|
protected java.util.concurrent.CopyOnWriteArrayList<TransportConnection> |
connections |
protected TransportStatusDetector |
statusDector |
Constructor and Description |
---|
TransportConnector() |
TransportConnector(TransportServer server) |
Modifier and Type | Method and Description |
---|---|
void |
addPeerBroker(BrokerInfo info) |
ManagedTransportConnector |
asManagedConnector(ManagementContext context,
javax.management.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() |
java.util.concurrent.CopyOnWriteArrayList<TransportConnection> |
getConnections() |
java.net.URI |
getConnectUri() |
DiscoveryAgent |
getDiscoveryAgent() |
java.net.URI |
getDiscoveryUri() |
int |
getMaximumConsumersAllowedPerConnection() |
int |
getMaximumProducersAllowedPerConnection() |
MessageAuthorizationPolicy |
getMessageAuthorizationPolicy() |
java.lang.String |
getName() |
java.util.LinkedList<java.lang.String> |
getPeerBrokers() |
java.lang.String |
getPublishableConnectString() |
java.lang.String |
getPublishableConnectString(java.net.URI theConnectURI) |
TransportServer |
getServer() |
ConnectorStatistics |
getStatistics() |
TaskRunnerFactory |
getTaskRunnerFactory() |
java.lang.String |
getUpdateClusterFilter() |
java.net.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 |
setBrokerName(java.lang.String name)
Deprecated.
use the
setBrokerService(BrokerService) method
instead. |
void |
setBrokerService(BrokerService brokerService)
This is called by the BrokerService right before it starts the transport.
|
void |
setConnectUri(java.net.URI transportUri) |
void |
setDisableAsyncDispatch(boolean disableAsyncDispatch) |
void |
setDiscoveryAgent(DiscoveryAgent discoveryAgent) |
void |
setDiscoveryUri(java.net.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(java.lang.String name) |
void |
setRebalanceClusterClients(boolean rebalanceClusterClients) |
void |
setServer(TransportServer server) |
void |
setTaskRunnerFactory(TaskRunnerFactory taskRunnerFactory) |
void |
setUpdateClusterClients(boolean updateClusterClients) |
void |
setUpdateClusterClientsOnRemove(boolean updateClusterClientsOnRemove) |
void |
setUpdateClusterFilter(java.lang.String updateClusterFilter) |
void |
setUri(java.net.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() |
java.lang.String |
toString() |
void |
updateClientClusterInfo()
Update all the connections with information
about the connected brokers in the cluster
|
protected java.util.concurrent.CopyOnWriteArrayList<TransportConnection> connections
protected TransportStatusDetector statusDector
public TransportConnector()
public TransportConnector(TransportServer server)
public java.util.concurrent.CopyOnWriteArrayList<TransportConnection> getConnections()
public ManagedTransportConnector asManagedConnector(ManagementContext context, javax.management.ObjectName connectorName) throws java.io.IOException, java.net.URISyntaxException
java.io.IOException
java.net.URISyntaxException
public BrokerInfo getBrokerInfo()
getBrokerInfo
in interface Connector
public void setBrokerInfo(BrokerInfo brokerInfo)
@Deprecated public void setBrokerName(java.lang.String name)
setBrokerService(BrokerService)
method
instead.public TransportServer getServer() throws java.io.IOException, java.net.URISyntaxException
java.io.IOException
java.net.URISyntaxException
public void setServer(TransportServer server)
public java.net.URI getUri()
public void setUri(java.net.URI uri)
TransportServer
configured via the
setServer(TransportServer)
method. This value is used to lazy
create a TransportServer
instanceuri
- public TaskRunnerFactory getTaskRunnerFactory()
public void setTaskRunnerFactory(TaskRunnerFactory taskRunnerFactory)
public ConnectorStatistics getStatistics()
getStatistics
in interface Connector
public MessageAuthorizationPolicy getMessageAuthorizationPolicy()
public void setMessageAuthorizationPolicy(MessageAuthorizationPolicy messageAuthorizationPolicy)
public void start() throws java.lang.Exception
public java.lang.String getPublishableConnectString() throws java.lang.Exception
java.lang.Exception
public java.lang.String getPublishableConnectString(java.net.URI theConnectURI) throws java.lang.Exception
java.lang.Exception
public void stop() throws java.lang.Exception
protected Connection createConnection(Transport transport) throws java.io.IOException
java.io.IOException
protected TransportServer createTransportServer() throws java.io.IOException, java.net.URISyntaxException
java.io.IOException
java.net.URISyntaxException
public DiscoveryAgent getDiscoveryAgent() throws java.io.IOException
java.io.IOException
protected DiscoveryAgent createDiscoveryAgent() throws java.io.IOException
java.io.IOException
public void setDiscoveryAgent(DiscoveryAgent discoveryAgent)
public java.net.URI getDiscoveryUri()
public void setDiscoveryUri(java.net.URI discoveryUri)
public java.net.URI getConnectUri() throws java.io.IOException, java.net.URISyntaxException
java.io.IOException
java.net.URISyntaxException
public void setConnectUri(java.net.URI transportUri)
public void onStarted(TransportConnection connection)
public void onStopped(TransportConnection connection)
public java.lang.String getName()
public void setName(java.lang.String name)
public java.lang.String toString()
toString
in class java.lang.Object
protected ConnectionControl getConnectionControl()
public void addPeerBroker(BrokerInfo info)
public void removePeerBroker(BrokerInfo info)
public java.util.LinkedList<java.lang.String> getPeerBrokers()
public void updateClientClusterInfo()
Connector
updateClientClusterInfo
in interface Connector
public boolean isDisableAsyncDispatch()
public void setDisableAsyncDispatch(boolean disableAsyncDispatch)
public boolean isEnableStatusMonitor()
public void setEnableStatusMonitor(boolean enableStatusMonitor)
enableStatusMonitor
- the enableStatusMonitor to setpublic void setBrokerService(BrokerService brokerService)
setBrokerService
in interface BrokerServiceAware
public BrokerService getBrokerService()
public boolean isUpdateClusterClients()
isUpdateClusterClients
in interface Connector
public void setUpdateClusterClients(boolean updateClusterClients)
updateClusterClients
- the updateClusterClients to setpublic boolean isRebalanceClusterClients()
isRebalanceClusterClients
in interface Connector
public void setRebalanceClusterClients(boolean rebalanceClusterClients)
rebalanceClusterClients
- the rebalanceClusterClients to setpublic boolean isUpdateClusterClientsOnRemove()
isUpdateClusterClientsOnRemove
in interface Connector
public void setUpdateClusterClientsOnRemove(boolean updateClusterClientsOnRemove)
updateClusterClientsOnRemove
- the updateClusterClientsOnRemove to setpublic java.lang.String getUpdateClusterFilter()
public void setUpdateClusterFilter(java.lang.String updateClusterFilter)
updateClusterFilter
- the updateClusterFilter to setpublic int connectionCount()
connectionCount
in interface Connector
public boolean isAuditNetworkProducers()
public void setAuditNetworkProducers(boolean auditNetworkProducers)
auditNetworkProducers
- public int getMaximumProducersAllowedPerConnection()
public void setMaximumProducersAllowedPerConnection(int maximumProducersAllowedPerConnection)
public int getMaximumConsumersAllowedPerConnection()
public void setMaximumConsumersAllowedPerConnection(int maximumConsumersAllowedPerConnection)
Copyright © 2005-2014. All Rights Reserved.