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

Message.setReadOnlyBody介绍

暂无

代码示例

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

/**
 * Browses the current destination with the given selector returning a list
 * of messages
 */
@Override
public List<Object> browseMessages(String selector) throws InvalidSelectorException {
  Message[] messages = destination.browse();
  ArrayList<Object> answer = new ArrayList<Object>();
  NonCachedMessageEvaluationContext ctx = new NonCachedMessageEvaluationContext();
  ctx.setDestination(destination.getActiveMQDestination());
  BooleanExpression selectorExpression = selector == null ? null : SelectorParser.parse(selector);
  for (int i = 0; i < messages.length; i++) {
    try {
      Message message = messages[i];
      message.setReadOnlyBody(true);
      if (selectorExpression == null) {
        answer.add(message);
      } else {
        ctx.setMessageReference(message);
        if (selectorExpression.matches(ctx)) {
          answer.add(message);
        }
      }
    } catch (Throwable e) {
      LOG.warn("exception browsing destination", e);
    }
  }
  return answer;
}

代码示例来源：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-broker

/**
 * Browses the current destination with the given selector returning a list
 * of messages
 */
@Override
public List<Object> browseMessages(String selector) throws InvalidSelectorException {
  Message[] messages = destination.browse();
  ArrayList<Object> answer = new ArrayList<Object>();
  NonCachedMessageEvaluationContext ctx = new NonCachedMessageEvaluationContext();
  ctx.setDestination(destination.getActiveMQDestination());
  BooleanExpression selectorExpression = selector == null ? null : SelectorParser.parse(selector);
  for (int i = 0; i < messages.length; i++) {
    try {
      Message message = messages[i];
      message.setReadOnlyBody(true);
      if (selectorExpression == null) {
        answer.add(message);
      } else {
        ctx.setMessageReference(message);
        if (selectorExpression.matches(ctx)) {
          answer.add(message);
        }
      }
    } catch (Throwable e) {
      LOG.warn("exception browsing destination", e);
    }
  }
  return answer;
}

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

/**
 * Browses the current destination with the given selector returning a list
 * of messages
 */
@Override
public List<Object> browseMessages(String selector) throws InvalidSelectorException {
  Message[] messages = destination.browse();
  ArrayList<Object> answer = new ArrayList<Object>();
  NonCachedMessageEvaluationContext ctx = new NonCachedMessageEvaluationContext();
  ctx.setDestination(destination.getActiveMQDestination());
  BooleanExpression selectorExpression = selector == null ? null : SelectorParser.parse(selector);
  for (int i = 0; i < messages.length; i++) {
    try {
      Message message = messages[i];
      message.setReadOnlyBody(true);
      if (selectorExpression == null) {
        answer.add(message);
      } else {
        ctx.setMessageReference(message);
        if (selectorExpression.matches(ctx)) {
          answer.add(message);
        }
      }
    } catch (Throwable e) {
      LOG.warn("exception browsing destination", e);
    }
  }
  return answer;
}

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

/**
 * Browses the current destination with the given selector returning a list
 * of messages
 */
@Override
public List<Object> browseMessages(String selector) throws InvalidSelectorException {
  Message[] messages = destination.browse();
  ArrayList<Object> answer = new ArrayList<Object>();
  NonCachedMessageEvaluationContext ctx = new NonCachedMessageEvaluationContext();
  ctx.setDestination(destination.getActiveMQDestination());
  BooleanExpression selectorExpression = selector == null ? null : SelectorParser.parse(selector);
  for (int i = 0; i < messages.length; i++) {
    try {
      Message message = messages[i];
      message.setReadOnlyBody(true);
      if (selectorExpression == null) {
        answer.add(message);
      } else {
        ctx.setMessageReference(message);
        if (selectorExpression.matches(ctx)) {
          answer.add(message);
        }
      }
    } catch (Throwable e) {
      LOG.warn("exception browsing destination", e);
    }
  }
  return answer;
}

代码示例来源：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: 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: 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;
}