public class TransportConnector extends Object implements Connector, BrokerServiceAware
Modifier and Type | Field and Description |
---|---|
protected CopyOnWriteArrayList<TransportConnection> |
connections |
protected TransportStatusDetector |
statusDector |
Constructor and Description |
---|
TransportConnector() |
TransportConnector(TransportServer server) |
protected CopyOnWriteArrayList<TransportConnection> connections
protected TransportStatusDetector statusDector
public TransportConnector()
public TransportConnector(TransportServer server)
public CopyOnWriteArrayList<TransportConnection> getConnections()
public ManagedTransportConnector asManagedConnector(ManagementContext context, ObjectName connectorName) throws IOException, URISyntaxException
IOException
URISyntaxException
public BrokerInfo getBrokerInfo()
getBrokerInfo
in interface Connector
public void setBrokerInfo(BrokerInfo brokerInfo)
@Deprecated public void setBrokerName(String name)
setBrokerService(BrokerService)
method
instead.public TransportServer getServer() throws IOException, URISyntaxException
IOException
URISyntaxException
public void setServer(TransportServer server)
public URI getUri()
public void setUri(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 Exception
public String getPublishableConnectString() throws Exception
Exception
public String getPublishableConnectString(URI theConnectURI) throws Exception
Exception
protected Connection createConnection(Transport transport) throws IOException
IOException
protected TransportServer createTransportServer() throws IOException, URISyntaxException
IOException
URISyntaxException
public DiscoveryAgent getDiscoveryAgent() throws IOException
IOException
protected DiscoveryAgent createDiscoveryAgent() throws IOException
IOException
public void setDiscoveryAgent(DiscoveryAgent discoveryAgent)
public URI getDiscoveryUri()
public void setDiscoveryUri(URI discoveryUri)
public URI getConnectUri() throws IOException, URISyntaxException
IOException
URISyntaxException
public void setConnectUri(URI transportUri)
public void onStarted(TransportConnection connection)
public void onStopped(TransportConnection connection)
public String getName()
public void setName(String name)
protected ConnectionControl getConnectionControl()
public void addPeerBroker(BrokerInfo info)
public void removePeerBroker(BrokerInfo info)
public LinkedList<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 Broker getBroker()
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 String getUpdateClusterFilter()
public void setUpdateClusterFilter(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–2015 The Apache Software Foundation. All rights reserved.