org.apache.activemq.broker.Broker.send()方法的使用及代码示例

x33g5p2x  于2022-01-17 转载在 其他  
字(9.6k)|赞(0)|评价(0)|浏览(83)

本文整理了Java中org.apache.activemq.broker.Broker.send()方法的一些代码示例，展示了Broker.send()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Broker.send()方法的具体详情如下：
包路径：org.apache.activemq.broker.Broker
类名称：Broker
方法名：send

Broker.send介绍

[英]A message needs to go the a DLQ
[中]需要通过DLQ发送消息

代码示例

代码示例来源：origin: apache/activemq

@Override
public void send(ProducerBrokerExchange producerExchange, Message messageSend) throws Exception {
  next.send(producerExchange, messageSend);
  Broker brokers[] = getListeners();
  for (int i = 0; i < brokers.length; i++) {
    brokers[i].send(producerExchange, messageSend);
  }
}

代码示例来源：origin: apache/activemq

@Override
public void send(ProducerBrokerExchange producerExchange, Message messageSend) throws Exception {
  getNext().send(producerExchange, messageSend);
}

代码示例来源：origin: apache/activemq

/** Sets the persistence mode
 * @see org.apache.activemq.broker.BrokerFilter#send(org.apache.activemq.broker.ProducerBrokerExchange, org.apache.activemq.command.Message)
 */
public void send(ProducerBrokerExchange producerExchange, Message messageSend) throws Exception {
 messageSend.getMessage().setPersistent(isPersistent());
 next.send(producerExchange, messageSend);
}

代码示例来源：origin: apache/activemq

@Override
public Response processMessage(Message messageSend) throws Exception {
  ProducerId producerId = messageSend.getProducerId();
  ProducerBrokerExchange producerExchange = getProducerBrokerExchange(producerId);
  if (producerExchange.canDispatch(messageSend)) {
    broker.send(producerExchange, messageSend);
  }
  return null;
}

代码示例来源：origin: apache/activemq

/**
 * 
 */
public void send(ProducerBrokerExchange producerExchange, Message message) throws Exception {
  ActiveMQDestination destination = message.getDestination();
  if (destination.isComposite()) {
    ActiveMQDestination[] destinations = destination.getCompositeDestinations();
    for (int i = 0; i < destinations.length; i++) {
      if (i != 0) {
        message = message.copy();
        message.setMemoryUsage(null);
      }
      message.setOriginalDestination(destination);
      message.setDestination(destinations[i]);
      next.send(producerExchange, message);
    }
  } else {
    next.send(producerExchange, message);
  }
}

代码示例来源：origin: apache/activemq

private void doForward(ProducerBrokerExchange context, Message message, Broker regionBroker, ActiveMQDestination destination) throws Exception {
    Message forwardedMessage = message.copy();
    forwardedMessage.setMemoryUsage(null);

    forwardedMessage.setOriginalDestination( message.getDestination() );
    forwardedMessage.setDestination(destination);

    // Send it back through the region broker for routing.
    context.setMutable(true);
    regionBroker.send(context, forwardedMessage);
  }
}

代码示例来源：origin: apache/activemq

public void send(ProducerBrokerExchange producerExchange, final Message message) throws Exception {
  // This method may be invoked recursively.
  // Track original tx so that it can be restored.
  final ConnectionContext context = producerExchange.getConnectionContext();
  Transaction originalTx = context.getTransaction();
  Transaction transaction = null;
  if (message.getTransactionId() != null) {
    transaction = getTransaction(context, message.getTransactionId(), false);
  }
  context.setTransaction(transaction);
  try {
    next.send(producerExchange, message);
  } finally {
    context.setTransaction(originalTx);
  }
}

代码示例来源：origin: apache/activemq

private void scheduleRedelivery(ConnectionContext context, MessageReference messageReference, long delay, int redeliveryCount) throws Exception {
  if (LOG.isTraceEnabled()) {
    Destination regionDestination = (Destination) messageReference.getRegionDestination();
    LOG.trace("redelivery #{} of: {} with delay: {}, dest: {}", new Object[]{
        redeliveryCount, messageReference.getMessageId(), delay, regionDestination.getActiveMQDestination()
    });
  }
  final Message old = messageReference.getMessage();
  Message message = old.copy();
  message.setTransactionId(null);
  message.setMemoryUsage(null);
  message.removeProperty(ScheduledMessage.AMQ_SCHEDULED_ID);
  message.setProperty(REDELIVERY_DELAY, delay);
  message.setProperty(ScheduledMessage.AMQ_SCHEDULED_DELAY, delay);
  message.setRedeliveryCounter(redeliveryCount);
  boolean originalFlowControl = context.isProducerFlowControl();
  try {
    context.setProducerFlowControl(false);
    ProducerInfo info = new ProducerInfo();
    ProducerState state = new ProducerState(info);
    ProducerBrokerExchange producerExchange = new ProducerBrokerExchange();
    producerExchange.setProducerState(state);
    producerExchange.setMutable(true);
    producerExchange.setConnectionContext(context);
    context.getBroker().send(producerExchange, message);
  } finally {
    context.setProducerFlowControl(originalFlowControl);
  }
}

代码示例来源：origin: apache/activemq

protected void sendStats(ConnectionContext context, ActiveMQMapMessage msg, ActiveMQDestination replyTo)
    throws Exception {
  msg.setPersistent(false);
  msg.setTimestamp(System.currentTimeMillis());
  msg.setPriority((byte) javax.jms.Message.DEFAULT_PRIORITY);
  msg.setType(AdvisorySupport.ADIVSORY_MESSAGE_TYPE);
  msg.setMessageId(new MessageId(this.advisoryProducerId, this.messageIdGenerator.getNextSequenceId()));
  msg.setDestination(replyTo);
  msg.setResponseRequired(false);
  msg.setProducerId(this.advisoryProducerId);
  boolean originalFlowControl = context.isProducerFlowControl();
  final ProducerBrokerExchange producerExchange = new ProducerBrokerExchange();
  producerExchange.setConnectionContext(context);
  producerExchange.setMutable(true);
  producerExchange.setProducerState(new ProducerState(new ProducerInfo()));
  try {
    context.setProducerFlowControl(false);
    this.next.send(producerExchange, msg);
  } finally {
    context.setProducerFlowControl(originalFlowControl);
  }
}

代码示例来源：origin: apache/activemq

try {
  context.setProducerFlowControl(false);
  this.next.send(producerExchange, msg);
} finally {
  context.setProducerFlowControl(originalFlowControl);

代码示例来源：origin: apache/activemq

public static void doResend(final ConnectionContext context, Message originalMessage, ActiveMQDestination deadLetterDestination, boolean copy) throws Exception {
  Message message = copy ? originalMessage.copy() : originalMessage;
  message.setOriginalDestination(message.getDestination());
  message.setOriginalTransactionId(message.getTransactionId());
  message.setDestination(deadLetterDestination);
  message.setTransactionId(null);
  message.setMemoryUsage(null);
  message.setRedeliveryCounter(0);
  message.getMessageId().setDataLocator(null);
  boolean originalFlowControl = context.isProducerFlowControl();
  try {
    context.setProducerFlowControl(false);
    ProducerInfo info = new ProducerInfo();
    ProducerState state = new ProducerState(info);
    ProducerBrokerExchange producerExchange = new ProducerBrokerExchange();
    producerExchange.setProducerState(state);
    producerExchange.setMutable(true);
    producerExchange.setConnectionContext(context);
    context.getBroker().send(producerExchange, message);
  } finally {
    context.setProducerFlowControl(originalFlowControl);
  }
}

代码示例来源：origin: apache/activemq

try {
  context.setProducerFlowControl(false);
  next.send(producerExchange, advisoryMessage);
} finally {
  context.setProducerFlowControl(originalFlowControl);

代码示例来源：origin: apache/activemq

producerExchange.setConnectionContext(context);
  producerExchange.setProducerState(new ProducerState(new ProducerInfo()));
  context.getBroker().send(producerExchange, message);
} finally {
  context.setProducerFlowControl(originalFlowControl);

代码示例来源：origin: org.apache.activemq/activemq-broker

@Override
public void send(ProducerBrokerExchange producerExchange, Message messageSend) throws Exception {
  next.send(producerExchange, messageSend);
  Broker brokers[] = getListeners();
  for (int i = 0; i < brokers.length; i++) {
    brokers[i].send(producerExchange, messageSend);
  }
}

代码示例来源：origin: org.apache.activemq/activemq-osgi

@Override
public void send(ProducerBrokerExchange producerExchange, Message messageSend) throws Exception {
  next.send(producerExchange, messageSend);
  Broker brokers[] = getListeners();
  for (int i = 0; i < brokers.length; i++) {
    brokers[i].send(producerExchange, messageSend);
  }
}

代码示例来源：origin: org.apache.activemq/activemq-all

/** Sets the persistence mode
 * @see org.apache.activemq.broker.BrokerFilter#send(org.apache.activemq.broker.ProducerBrokerExchange, org.apache.activemq.command.Message)
 */
public void send(ProducerBrokerExchange producerExchange, Message messageSend) throws Exception {
 messageSend.getMessage().setPersistent(isPersistent());
 next.send(producerExchange, messageSend);
}

代码示例来源：origin: org.apache.activemq/activemq-broker

/** Sets the persistence mode
 * @see org.apache.activemq.broker.BrokerFilter#send(org.apache.activemq.broker.ProducerBrokerExchange, org.apache.activemq.command.Message)
 */
public void send(ProducerBrokerExchange producerExchange, Message messageSend) throws Exception {
 messageSend.getMessage().setPersistent(isPersistent());
 next.send(producerExchange, messageSend);
}

代码示例来源：origin: org.apache.activemq/activemq-broker

@Override
public Response processMessage(Message messageSend) throws Exception {
  ProducerId producerId = messageSend.getProducerId();
  ProducerBrokerExchange producerExchange = getProducerBrokerExchange(producerId);
  if (producerExchange.canDispatch(messageSend)) {
    broker.send(producerExchange, messageSend);
  }
  return null;
}

代码示例来源：origin: org.apache.activemq/activemq-broker

private void doForward(ProducerBrokerExchange context, Message message, Broker regionBroker, ActiveMQDestination destination) throws Exception {
    Message forwardedMessage = message.copy();
    forwardedMessage.setMemoryUsage(null);

    forwardedMessage.setOriginalDestination( message.getDestination() );
    forwardedMessage.setDestination(destination);

    // Send it back through the region broker for routing.
    context.setMutable(true);
    regionBroker.send(context, forwardedMessage);
  }
}

代码示例来源：origin: org.apache.activemq/activemq-all

private void doForward(ProducerBrokerExchange context, Message message, Broker regionBroker, ActiveMQDestination destination) throws Exception {
    Message forwardedMessage = message.copy();
    forwardedMessage.setMemoryUsage(null);

    forwardedMessage.setOriginalDestination( message.getDestination() );
    forwardedMessage.setDestination(destination);

    // Send it back through the region broker for routing.
    context.setMutable(true);
    regionBroker.send(context, forwardedMessage);
  }
}

内容来源于网络，如有侵权，请联系作者删除！

Broker

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多

    Broker类方法

    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com