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

Message.setConnection介绍

暂无

代码示例

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

@Override
public Response processMessageDispatch(MessageDispatch md) throws Exception {
  waitForTransportInterruptionProcessingToComplete();
  ActiveMQDispatcher dispatcher = dispatchers.get(md.getConsumerId());
  if (dispatcher != null) {
    // Copy in case a embedded broker is dispatching via
    // vm://
    // md.getMessage() == null to signal end of queue
    // browse.
    Message msg = md.getMessage();
    if (msg != null) {
      msg = msg.copy();
      msg.setReadOnlyBody(true);
      msg.setReadOnlyProperties(true);
      msg.setRedeliveryCounter(md.getRedeliveryCounter());
      msg.setConnection(ActiveMQConnection.this);
      msg.setMemoryUsage(null);
      md.setMessage(msg);
    }
    dispatcher.dispatch(md);
  } else {
    LOG.debug("{} no dispatcher for {} in {}", this, md, dispatchers);
  }
  return null;
}

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

@Override
public Response processMessageDispatch(MessageDispatch md) throws Exception {
  waitForTransportInterruptionProcessingToComplete();
  ActiveMQDispatcher dispatcher = dispatchers.get(md.getConsumerId());
  if (dispatcher != null) {
    // Copy in case a embedded broker is dispatching via
    // vm://
    // md.getMessage() == null to signal end of queue
    // browse.
    Message msg = md.getMessage();
    if (msg != null) {
      msg = msg.copy();
      msg.setReadOnlyBody(true);
      msg.setReadOnlyProperties(true);
      msg.setRedeliveryCounter(md.getRedeliveryCounter());
      msg.setConnection(ActiveMQConnection.this);
      msg.setMemoryUsage(null);
      md.setMessage(msg);
    }
    dispatcher.dispatch(md);
  } else {
    LOG.debug("{} no dispatcher for {} in {}", this, md, dispatchers);
  }
  return null;
}

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

@Override
public Response processMessageDispatch(MessageDispatch md) throws Exception {
  waitForTransportInterruptionProcessingToComplete();
  ActiveMQDispatcher dispatcher = dispatchers.get(md.getConsumerId());
  if (dispatcher != null) {
    // Copy in case a embedded broker is dispatching via
    // vm://
    // md.getMessage() == null to signal end of queue
    // browse.
    Message msg = md.getMessage();
    if (msg != null) {
      msg = msg.copy();
      msg.setReadOnlyBody(true);
      msg.setReadOnlyProperties(true);
      msg.setRedeliveryCounter(md.getRedeliveryCounter());
      msg.setConnection(ActiveMQConnection.this);
      msg.setMemoryUsage(null);
      md.setMessage(msg);
    }
    dispatcher.dispatch(md);
  } else {
    LOG.debug("{} no dispatcher for {} in {}", this, md, dispatchers);
  }
  return null;
}

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

@Override
public Response processMessageDispatch(MessageDispatch md) throws Exception {
  waitForTransportInterruptionProcessingToComplete();
  ActiveMQDispatcher dispatcher = dispatchers.get(md.getConsumerId());
  if (dispatcher != null) {
    // Copy in case a embedded broker is dispatching via
    // vm://
    // md.getMessage() == null to signal end of queue
    // browse.
    Message msg = md.getMessage();
    if (msg != null) {
      msg = msg.copy();
      msg.setReadOnlyBody(true);
      msg.setReadOnlyProperties(true);
      msg.setRedeliveryCounter(md.getRedeliveryCounter());
      msg.setConnection(ActiveMQConnection.this);
      msg.setMemoryUsage(null);
      md.setMessage(msg);
    }
    dispatcher.dispatch(md);
  } else {
    LOG.debug("{} no dispatcher for {} in {}", this, md, dispatchers);
  }
  return null;
}

代码示例来源：origin: pierre/meteo

@Override
public Response processMessageDispatch(MessageDispatch md) throws Exception {
  waitForTransportInterruptionProcessingToComplete();
  ActiveMQDispatcher dispatcher = dispatchers.get(md.getConsumerId());
  if (dispatcher != null) {
    // Copy in case a embedded broker is dispatching via
    // vm://
    // md.getMessage() == null to signal end of queue
    // browse.
    Message msg = md.getMessage();
    if (msg != null) {
      msg = msg.copy();
      msg.setReadOnlyBody(true);
      msg.setReadOnlyProperties(true);
      msg.setRedeliveryCounter(md.getRedeliveryCounter());
      msg.setConnection(ActiveMQConnection.this);
      md.setMessage(msg);
    }
    dispatcher.dispatch(md);
  }
  return null;
}