本文整理了Java中org.apache.activemq.broker.Broker.getPeerBrokerInfos()
方法的一些代码示例,展示了Broker.getPeerBrokerInfos()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Broker.getPeerBrokerInfos()
方法的具体详情如下:
包路径:org.apache.activemq.broker.Broker
类名称:Broker
方法名:getPeerBrokerInfos
[英]Get the BrokerInfo's of any connected Brokers
[中]获取任何相关经纪人的经纪人信息
代码示例来源:origin: apache/activemq
@Override
public BrokerInfo[] getPeerBrokerInfos() {
return getNext().getPeerBrokerInfos();
}
代码示例来源:origin: apache/activemq
BrokerInfo info = connector.getBrokerInfo().copy();
if (connector.isUpdateClusterClients()) {
info.setPeerBrokerInfos(this.broker.getPeerBrokerInfos());
} else {
info.setPeerBrokerInfos(null);
代码示例来源:origin: apache/activemq
brokerInfo.setBrokerName(broker.getBrokerName());
brokerInfo.setBrokerId(broker.getBrokerId());
brokerInfo.setPeerBrokerInfos(broker.getPeerBrokerInfos());
brokerInfo.setFaultTolerantConfiguration(broker.isFaultTolerantConfiguration());
brokerInfo.setBrokerURL(broker.getBrokerService().getDefaultSocketURIString());
代码示例来源:origin: pierre/meteo
public BrokerInfo[] getPeerBrokerInfos() {
return next.getPeerBrokerInfos();
}
代码示例来源:origin: org.apache.activemq/activemq-all
@Override
public BrokerInfo[] getPeerBrokerInfos() {
return getNext().getPeerBrokerInfos();
}
代码示例来源:origin: org.apache.activemq/activemq-osgi
@Override
public BrokerInfo[] getPeerBrokerInfos() {
return getNext().getPeerBrokerInfos();
}
代码示例来源:origin: org.apache.activemq/activemq-broker
@Override
public BrokerInfo[] getPeerBrokerInfos() {
return getNext().getPeerBrokerInfos();
}
代码示例来源:origin: pierre/meteo
public BrokerInfo[] getPeerBrokerInfos() {
return getNext().getPeerBrokerInfos();
}
代码示例来源:origin: pierre/meteo
protected ConnectionControl getConnectionControl() {
boolean rebalance = isRebalanceClusterClients();
String connectedBrokers = "";
String self = "";
if (isUpdateClusterClients()) {
if (brokerService.getDefaultSocketURIString() != null) {
self += brokerService.getDefaultSocketURIString();
self += ",";
}
if (rebalance == false) {
connectedBrokers += self;
}
if (this.broker.getPeerBrokerInfos() != null) {
for (BrokerInfo info : this.broker.getPeerBrokerInfos()) {
if (isMatchesClusterFilter(info.getBrokerName())) {
connectedBrokers += info.getBrokerURL();
connectedBrokers += ",";
}
}
}
if (rebalance) {
connectedBrokers += self;
}
}
ConnectionControl control = new ConnectionControl();
control.setConnectedBrokers(connectedBrokers);
control.setRebalanceConnection(rebalance);
return control;
}
代码示例来源:origin: org.apache.activemq/activemq-all
BrokerInfo info = connector.getBrokerInfo().copy();
if (connector.isUpdateClusterClients()) {
info.setPeerBrokerInfos(this.broker.getPeerBrokerInfos());
} else {
info.setPeerBrokerInfos(null);
代码示例来源:origin: org.apache.activemq/activemq-broker
BrokerInfo info = connector.getBrokerInfo().copy();
if (connector.isUpdateClusterClients()) {
info.setPeerBrokerInfos(this.broker.getPeerBrokerInfos());
} else {
info.setPeerBrokerInfos(null);
代码示例来源:origin: org.apache.activemq/activemq-osgi
BrokerInfo info = connector.getBrokerInfo().copy();
if (connector.isUpdateClusterClients()) {
info.setPeerBrokerInfos(this.broker.getPeerBrokerInfos());
} else {
info.setPeerBrokerInfos(null);
代码示例来源:origin: pierre/meteo
BrokerInfo info = connector.getBrokerInfo().copy();
if (connector.isUpdateClusterClients()) {
info.setPeerBrokerInfos(this.broker.getPeerBrokerInfos());
} else {
info.setPeerBrokerInfos(null);
代码示例来源:origin: pierre/meteo
protected void startBridge() throws Exception {
connectionInfo = new ConnectionInfo();
connectionInfo.setConnectionId(new ConnectionId(idGenerator.generateId()));
connectionInfo.setClientId(idGenerator.generateId());
connectionInfo.setUserName(userName);
connectionInfo.setPassword(password);
connectionInfo.setBrokerMasterConnector(true);
sessionInfo = new SessionInfo(connectionInfo, 1);
producerInfo = new ProducerInfo(sessionInfo, 1);
producerInfo.setResponseRequired(false);
if (connector != null) {
brokerInfo = connector.getBrokerInfo();
} else {
brokerInfo = new BrokerInfo();
}
brokerInfo.setBrokerName(broker.getBrokerName());
brokerInfo.setPeerBrokerInfos(broker.getBroker().getPeerBrokerInfos());
brokerInfo.setSlaveBroker(true);
brokerInfo.setPassiveSlave(broker.isPassiveSlave());
restartBridge();
LOG.info("Slave connection between " + localBroker + " and " + remoteBroker + " has been established.");
}
代码示例来源:origin: pierre/meteo
brokerInfo.setBrokerName(broker.getBrokerName());
brokerInfo.setBrokerId(broker.getBrokerId());
brokerInfo.setPeerBrokerInfos(broker.getPeerBrokerInfos());
brokerInfo.setFaultTolerantConfiguration(broker.isFaultTolerantConfiguration());
brokerInfo.setBrokerURL(getServer().getConnectURI().toString());
代码示例来源:origin: org.apache.activemq/activemq-all
brokerInfo.setBrokerName(broker.getBrokerName());
brokerInfo.setBrokerId(broker.getBrokerId());
brokerInfo.setPeerBrokerInfos(broker.getPeerBrokerInfos());
brokerInfo.setFaultTolerantConfiguration(broker.isFaultTolerantConfiguration());
brokerInfo.setBrokerURL(broker.getBrokerService().getDefaultSocketURIString());
代码示例来源:origin: org.apache.activemq/activemq-osgi
brokerInfo.setBrokerName(broker.getBrokerName());
brokerInfo.setBrokerId(broker.getBrokerId());
brokerInfo.setPeerBrokerInfos(broker.getPeerBrokerInfos());
brokerInfo.setFaultTolerantConfiguration(broker.isFaultTolerantConfiguration());
brokerInfo.setBrokerURL(broker.getBrokerService().getDefaultSocketURIString());
代码示例来源:origin: org.apache.activemq/activemq-broker
brokerInfo.setBrokerName(broker.getBrokerName());
brokerInfo.setBrokerId(broker.getBrokerId());
brokerInfo.setPeerBrokerInfos(broker.getPeerBrokerInfos());
brokerInfo.setFaultTolerantConfiguration(broker.isFaultTolerantConfiguration());
brokerInfo.setBrokerURL(broker.getBrokerService().getDefaultSocketURIString());
内容来源于网络,如有侵权,请联系作者删除!