本文整理了Java中org.apache.activemq.broker.Broker.setAdminConnectionContext()
方法的一些代码示例,展示了Broker.setAdminConnectionContext()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Broker.setAdminConnectionContext()
方法的具体详情如下:
包路径:org.apache.activemq.broker.Broker
类名称:Broker
方法名:setAdminConnectionContext
[英]Sets the default administration connection context used when configuring the broker on startup or via JMX
[中]设置启动时或通过JMX配置代理时使用的默认管理连接上下文
代码示例来源:origin: apache/activemq
@Override
public void setAdminConnectionContext(ConnectionContext adminConnectionContext) {
getNext().setAdminConnectionContext(adminConnectionContext);
}
代码示例来源:origin: apache/activemq
/**
* Returns the broker's administration connection context used for
* configuring the broker at startup
*/
public static ConnectionContext getConnectionContext(Broker broker) {
ConnectionContext adminConnectionContext = broker.getAdminConnectionContext();
if (adminConnectionContext == null) {
adminConnectionContext = createAdminConnectionContext(broker);
broker.setAdminConnectionContext(adminConnectionContext);
}
return adminConnectionContext;
}
代码示例来源:origin: pierre/meteo
public void setAdminConnectionContext(ConnectionContext adminConnectionContext) {
next.setAdminConnectionContext(adminConnectionContext);
}
代码示例来源:origin: org.apache.activemq/activemq-broker
@Override
public void setAdminConnectionContext(ConnectionContext adminConnectionContext) {
getNext().setAdminConnectionContext(adminConnectionContext);
}
代码示例来源:origin: org.apache.activemq/activemq-all
@Override
public void setAdminConnectionContext(ConnectionContext adminConnectionContext) {
getNext().setAdminConnectionContext(adminConnectionContext);
}
代码示例来源:origin: org.apache.activemq/activemq-osgi
@Override
public void setAdminConnectionContext(ConnectionContext adminConnectionContext) {
getNext().setAdminConnectionContext(adminConnectionContext);
}
代码示例来源:origin: pierre/meteo
public void setAdminConnectionContext(ConnectionContext adminConnectionContext) {
getNext().setAdminConnectionContext(adminConnectionContext);
}
代码示例来源:origin: org.apache.activemq/activemq-broker
/**
* Returns the broker's administration connection context used for
* configuring the broker at startup
*/
public static ConnectionContext getConnectionContext(Broker broker) {
ConnectionContext adminConnectionContext = broker.getAdminConnectionContext();
if (adminConnectionContext == null) {
adminConnectionContext = createAdminConnectionContext(broker);
broker.setAdminConnectionContext(adminConnectionContext);
}
return adminConnectionContext;
}
代码示例来源:origin: org.apache.activemq/activemq-all
/**
* Returns the broker's administration connection context used for
* configuring the broker at startup
*/
public static ConnectionContext getConnectionContext(Broker broker) {
ConnectionContext adminConnectionContext = broker.getAdminConnectionContext();
if (adminConnectionContext == null) {
adminConnectionContext = createAdminConnectionContext(broker);
broker.setAdminConnectionContext(adminConnectionContext);
}
return adminConnectionContext;
}
代码示例来源:origin: org.apache.activemq/activemq-osgi
/**
* Returns the broker's administration connection context used for
* configuring the broker at startup
*/
public static ConnectionContext getConnectionContext(Broker broker) {
ConnectionContext adminConnectionContext = broker.getAdminConnectionContext();
if (adminConnectionContext == null) {
adminConnectionContext = createAdminConnectionContext(broker);
broker.setAdminConnectionContext(adminConnectionContext);
}
return adminConnectionContext;
}
代码示例来源:origin: pierre/meteo
/**
* Returns the broker's administration connection context used for
* configuring the broker at startup
*/
public static ConnectionContext getConnectionContext(Broker broker) {
ConnectionContext adminConnectionContext = broker.getAdminConnectionContext();
if (adminConnectionContext == null) {
adminConnectionContext = createAdminConnectionContext(broker);
broker.setAdminConnectionContext(adminConnectionContext);
}
return adminConnectionContext;
}
代码示例来源:origin: pierre/meteo
/**
* Starts all destiantions in persistence store. This includes all inactive
* destinations
*/
protected void startDestinationsInPersistenceStore(Broker broker) throws Exception {
Set destinations = destinationFactory.getDestinations();
if (destinations != null) {
Iterator iter = destinations.iterator();
ConnectionContext adminConnectionContext = broker.getAdminConnectionContext();
if (adminConnectionContext == null) {
ConnectionContext context = new ConnectionContext();
context.setBroker(broker);
adminConnectionContext = context;
broker.setAdminConnectionContext(adminConnectionContext);
}
while (iter.hasNext()) {
ActiveMQDestination destination = (ActiveMQDestination) iter.next();
broker.addDestination(adminConnectionContext, destination,false);
}
}
}
内容来源于网络,如有侵权,请联系作者删除!