本文整理了Java中org.apache.activemq.broker.Broker.getAdminConnectionContext()
方法的一些代码示例,展示了Broker.getAdminConnectionContext()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Broker.getAdminConnectionContext()
方法的具体详情如下:
包路径:org.apache.activemq.broker.Broker
类名称:Broker
方法名:getAdminConnectionContext
暂无
代码示例来源:origin: apache/activemq
@Override
public ConnectionContext getAdminConnectionContext() {
return getNext().getAdminConnectionContext();
}
代码示例来源: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: apache/activemq
abstractSubscription.setSlowConsumer(true);
for (Destination destination: abstractSubscription.getDestinations()) {
destination.slowConsumer(broker.getAdminConnectionContext(), abstractSubscription);
代码示例来源:origin: pierre/meteo
public ConnectionContext getAdminConnectionContext() {
return next.getAdminConnectionContext();
}
代码示例来源:origin: org.apache.activemq/activemq-osgi
@Override
public ConnectionContext getAdminConnectionContext() {
return getNext().getAdminConnectionContext();
}
代码示例来源:origin: org.apache.activemq/activemq-broker
@Override
public ConnectionContext getAdminConnectionContext() {
return getNext().getAdminConnectionContext();
}
代码示例来源:origin: org.apache.activemq/activemq-all
@Override
public ConnectionContext getAdminConnectionContext() {
return getNext().getAdminConnectionContext();
}
代码示例来源:origin: pierre/meteo
public ConnectionContext getAdminConnectionContext() {
return getNext().getAdminConnectionContext();
}
代码示例来源: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);
}
}
}
内容来源于网络,如有侵权,请联系作者删除!