public interface Connector extends Service
Modifier and Type | Method and Description |
---|---|
int |
connectionCount() |
BrokerInfo |
getBrokerInfo() |
ConnectorStatistics |
getStatistics() |
String |
getUpdateClusterFilter() |
boolean |
isAllowLinkStealing()
If enabled, older connections with the same clientID are stopped
|
boolean |
isRebalanceClusterClients() |
boolean |
isUpdateClusterClients() |
boolean |
isUpdateClusterClientsOnRemove() |
void |
updateClientClusterInfo()
Update all the connections with information
about the connected brokers in the cluster
|
BrokerInfo getBrokerInfo()
ConnectorStatistics getStatistics()
boolean isUpdateClusterClients()
boolean isRebalanceClusterClients()
void updateClientClusterInfo()
boolean isUpdateClusterClientsOnRemove()
int connectionCount()
boolean isAllowLinkStealing()
String getUpdateClusterFilter()
Copyright © 2005–2018 The Apache Software Foundation. All rights reserved.