本文整理了Java中org.apache.activemq.broker.Broker.addProducer()
方法的一些代码示例,展示了Broker.addProducer()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Broker.addProducer()
方法的具体详情如下:
包路径:org.apache.activemq.broker.Broker
类名称:Broker
方法名:addProducer
[英]Adds a producer.
[中]添加一个制作人。
代码示例来源:origin: apache/activemq
@Override
public void addProducer(ConnectionContext context, ProducerInfo info) throws Exception {
next.addProducer(context, info);
Broker brokers[] = getListeners();
for (int i = 0; i < brokers.length; i++) {
brokers[i].addProducer(context, info);
}
}
代码示例来源:origin: apache/activemq
@Override
public void addProducer(ConnectionContext context, ProducerInfo info) throws Exception {
getNext().addProducer(context, info);
}
代码示例来源:origin: apache/activemq
/**
* A producer may register to send to multiple destinations via a composite
* destination.
*/
public void addProducer(ConnectionContext context, ProducerInfo info) throws Exception {
// The destination may be null.
ActiveMQDestination destination = info.getDestination();
if (destination != null && destination.isComposite()) {
ActiveMQDestination[] destinations = destination.getCompositeDestinations();
for (int i = 0; i < destinations.length; i++) {
ProducerInfo copy = info.copy();
copy.setDestination(destinations[i]);
next.addProducer(context, copy);
}
} else {
next.addProducer(context, info);
}
}
代码示例来源:origin: apache/activemq
broker.addProducer(cs.getContext(), info);
try {
ss.addProducer(info);
代码示例来源:origin: pierre/meteo
public void addProducer(ConnectionContext context, ProducerInfo info) throws Exception {
next.addProducer(context, info);
}
代码示例来源:origin: org.apache.activemq/activemq-broker
@Override
public void addProducer(ConnectionContext context, ProducerInfo info) throws Exception {
next.addProducer(context, info);
Broker brokers[] = getListeners();
for (int i = 0; i < brokers.length; i++) {
brokers[i].addProducer(context, info);
}
}
代码示例来源:origin: org.apache.activemq/activemq-all
@Override
public void addProducer(ConnectionContext context, ProducerInfo info) throws Exception {
next.addProducer(context, info);
Broker brokers[] = getListeners();
for (int i = 0; i < brokers.length; i++) {
brokers[i].addProducer(context, info);
}
}
代码示例来源:origin: pierre/meteo
@Override
public void addProducer(ConnectionContext context, ProducerInfo info) throws Exception {
next.addProducer(context, info);
Broker brokers[] = getListeners();
for (int i = 0; i < brokers.length; i++) {
brokers[i].addProducer(context, info);
}
}
代码示例来源:origin: org.apache.activemq/activemq-osgi
@Override
public void addProducer(ConnectionContext context, ProducerInfo info) throws Exception {
next.addProducer(context, info);
Broker brokers[] = getListeners();
for (int i = 0; i < brokers.length; i++) {
brokers[i].addProducer(context, info);
}
}
代码示例来源:origin: org.apache.activemq/activemq-all
@Override
public void addProducer(ConnectionContext context, ProducerInfo info) throws Exception {
getNext().addProducer(context, info);
}
代码示例来源:origin: org.apache.activemq/activemq-broker
@Override
public void addProducer(ConnectionContext context, ProducerInfo info) throws Exception {
getNext().addProducer(context, info);
}
代码示例来源:origin: org.apache.activemq/activemq-osgi
@Override
public void addProducer(ConnectionContext context, ProducerInfo info) throws Exception {
getNext().addProducer(context, info);
}
代码示例来源:origin: pierre/meteo
public void addProducer(ConnectionContext context, ProducerInfo info) throws Exception {
getNext().addProducer(context, info);
}
代码示例来源:origin: org.apache.activemq/activemq-broker
/**
* A producer may register to send to multiple destinations via a composite
* destination.
*/
public void addProducer(ConnectionContext context, ProducerInfo info) throws Exception {
// The destination may be null.
ActiveMQDestination destination = info.getDestination();
if (destination != null && destination.isComposite()) {
ActiveMQDestination[] destinations = destination.getCompositeDestinations();
for (int i = 0; i < destinations.length; i++) {
ProducerInfo copy = info.copy();
copy.setDestination(destinations[i]);
next.addProducer(context, copy);
}
} else {
next.addProducer(context, info);
}
}
代码示例来源:origin: org.apache.activemq/activemq-all
/**
* A producer may register to send to multiple destinations via a composite
* destination.
*/
public void addProducer(ConnectionContext context, ProducerInfo info) throws Exception {
// The destination may be null.
ActiveMQDestination destination = info.getDestination();
if (destination != null && destination.isComposite()) {
ActiveMQDestination[] destinations = destination.getCompositeDestinations();
for (int i = 0; i < destinations.length; i++) {
ProducerInfo copy = info.copy();
copy.setDestination(destinations[i]);
next.addProducer(context, copy);
}
} else {
next.addProducer(context, info);
}
}
代码示例来源:origin: org.apache.activemq/activemq-osgi
/**
* A producer may register to send to multiple destinations via a composite
* destination.
*/
public void addProducer(ConnectionContext context, ProducerInfo info) throws Exception {
// The destination may be null.
ActiveMQDestination destination = info.getDestination();
if (destination != null && destination.isComposite()) {
ActiveMQDestination[] destinations = destination.getCompositeDestinations();
for (int i = 0; i < destinations.length; i++) {
ProducerInfo copy = info.copy();
copy.setDestination(destinations[i]);
next.addProducer(context, copy);
}
} else {
next.addProducer(context, info);
}
}
代码示例来源:origin: pierre/meteo
/**
* A producer may register to send to multiple destinations via a composite
* destination.
*/
public void addProducer(ConnectionContext context, ProducerInfo info) throws Exception {
// The destination may be null.
ActiveMQDestination destination = info.getDestination();
if (destination != null && destination.isComposite()) {
ActiveMQDestination[] destinations = destination.getCompositeDestinations();
for (int i = 0; i < destinations.length; i++) {
ProducerInfo copy = info.copy();
copy.setDestination(destinations[i]);
next.addProducer(context, copy);
}
} else {
next.addProducer(context, info);
}
}
代码示例来源:origin: pierre/meteo
public Response processAddProducer(ProducerInfo info) throws Exception {
SessionId sessionId = info.getProducerId().getParentId();
ConnectionId connectionId = sessionId.getParentId();
TransportConnectionState cs = lookupConnectionState(connectionId);
SessionState ss = cs.getSessionState(sessionId);
if (ss == null) {
throw new IllegalStateException("Cannot add a producer to a session that had not been registered: "
+ sessionId);
}
// Avoid replaying dup commands
if (!ss.getProducerIds().contains(info.getProducerId())) {
broker.addProducer(cs.getContext(), info);
try {
ss.addProducer(info);
} catch (IllegalStateException e) {
broker.removeProducer(cs.getContext(), info);
}
}
return null;
}
代码示例来源:origin: org.apache.activemq/activemq-broker
broker.addProducer(cs.getContext(), info);
try {
ss.addProducer(info);
代码示例来源:origin: org.apache.activemq/activemq-all
broker.addProducer(cs.getContext(), info);
try {
ss.addProducer(info);
内容来源于网络,如有侵权,请联系作者删除!