本文整理了Java中org.apache.activemq.broker.Broker.addConsumer()
方法的一些代码示例,展示了Broker.addConsumer()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Broker.addConsumer()
方法的具体详情如下:
包路径:org.apache.activemq.broker.Broker
类名称:Broker
方法名:addConsumer
暂无
代码示例来源:origin: apache/activemq
@Override
public Subscription addConsumer(ConnectionContext context, ConsumerInfo info) throws Exception {
Subscription answer = next.addConsumer(context, info);
Broker brokers[] = getListeners();
for (int i = 0; i < brokers.length; i++) {
brokers[i].addConsumer(context, info);
}
return answer;
}
代码示例来源:origin: apache/activemq
@Override
public Subscription addConsumer(ConnectionContext context, ConsumerInfo info) throws Exception {
return getNext().addConsumer(context, info);
}
代码示例来源:origin: apache/activemq
broker.addConsumer(cs.getContext(), info);
try {
ss.addConsumer(info);
代码示例来源:origin: pierre/meteo
public Subscription addConsumer(ConnectionContext context, ConsumerInfo info) throws Exception {
return next.addConsumer(context, info);
}
代码示例来源:origin: org.apache.activemq/activemq-all
@Override
public Subscription addConsumer(ConnectionContext context, ConsumerInfo info) throws Exception {
Subscription answer = next.addConsumer(context, info);
Broker brokers[] = getListeners();
for (int i = 0; i < brokers.length; i++) {
brokers[i].addConsumer(context, info);
}
return answer;
}
代码示例来源:origin: pierre/meteo
@Override
public Subscription addConsumer(ConnectionContext context, ConsumerInfo info) throws Exception {
Subscription answer = next.addConsumer(context, info);
Broker brokers[] = getListeners();
for (int i = 0; i < brokers.length; i++) {
brokers[i].addConsumer(context, info);
}
return answer;
}
代码示例来源:origin: org.apache.activemq/activemq-osgi
@Override
public Subscription addConsumer(ConnectionContext context, ConsumerInfo info) throws Exception {
Subscription answer = next.addConsumer(context, info);
Broker brokers[] = getListeners();
for (int i = 0; i < brokers.length; i++) {
brokers[i].addConsumer(context, info);
}
return answer;
}
代码示例来源:origin: org.apache.activemq/activemq-broker
@Override
public Subscription addConsumer(ConnectionContext context, ConsumerInfo info) throws Exception {
Subscription answer = next.addConsumer(context, info);
Broker brokers[] = getListeners();
for (int i = 0; i < brokers.length; i++) {
brokers[i].addConsumer(context, info);
}
return answer;
}
代码示例来源:origin: org.apache.activemq/activemq-broker
@Override
public Subscription addConsumer(ConnectionContext context, ConsumerInfo info) throws Exception {
return getNext().addConsumer(context, info);
}
代码示例来源:origin: pierre/meteo
public Subscription addConsumer(ConnectionContext context, ConsumerInfo info) throws Exception {
return getNext().addConsumer(context, info);
}
代码示例来源:origin: org.apache.activemq/activemq-all
@Override
public Subscription addConsumer(ConnectionContext context, ConsumerInfo info) throws Exception {
return getNext().addConsumer(context, info);
}
代码示例来源:origin: org.apache.activemq/activemq-osgi
@Override
public Subscription addConsumer(ConnectionContext context, ConsumerInfo info) throws Exception {
return getNext().addConsumer(context, info);
}
代码示例来源:origin: pierre/meteo
public Response processAddConsumer(ConsumerInfo info) throws Exception {
SessionId sessionId = info.getConsumerId().getParentId();
ConnectionId connectionId = sessionId.getParentId();
TransportConnectionState cs = lookupConnectionState(connectionId);
SessionState ss = cs.getSessionState(sessionId);
if (ss == null) {
throw new IllegalStateException(broker.getBrokerName()
+ " Cannot add a consumer to a session that had not been registered: " + sessionId);
}
// Avoid replaying dup commands
if (!ss.getConsumerIds().contains(info.getConsumerId())) {
broker.addConsumer(cs.getContext(), info);
try {
ss.addConsumer(info);
} catch (IllegalStateException e) {
broker.removeConsumer(cs.getContext(), info);
}
}
return null;
}
代码示例来源:origin: org.apache.activemq/activemq-broker
broker.addConsumer(cs.getContext(), info);
try {
ss.addConsumer(info);
代码示例来源:origin: org.apache.activemq/activemq-all
broker.addConsumer(cs.getContext(), info);
try {
ss.addConsumer(info);
代码示例来源:origin: org.apache.activemq/activemq-osgi
broker.addConsumer(cs.getContext(), info);
try {
ss.addConsumer(info);
内容来源于网络,如有侵权,请联系作者删除!