org.apache.activemq.command.Message.isResponseRequired()方法的使用及代码示例

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

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

Message.isResponseRequired介绍

暂无

代码示例

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

message.incrementReferenceCount();
final RecordLocation location = peristenceAdapter.writeCommand(message, message.isResponseRequired());
if (!context.isInTransaction()) {
  if (debug) {

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

if (!message.isResponseRequired()) {

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

if (result != null && message.isResponseRequired() && !result.isCancelled()) {
  try {
    result.get();

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

final boolean sendProducerAck = !message.isResponseRequired() && producerInfo.getWindowSize() > 0
    && !context.isInRecoveryMode();
    if (producerInfo.getWindowSize() > 0 || message.isResponseRequired()) {
      synchronized (messagesWaitingForSpace) {
        messagesWaitingForSpace.add(new Runnable() {

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

@Override
public void addMessage(final ConnectionContext context, final Message message) throws IOException {
  final KahaAddMessageCommand command = new KahaAddMessageCommand();
  command.setDestination(dest);
  command.setMessageId(message.getMessageId().toProducerKey());
  command.setTransactionInfo(TransactionIdConversion.convert(transactionIdTransformer.transform(message.getTransactionId())));
  command.setPriority(message.getPriority());
  command.setPrioritySupported(isPrioritizedMessages());
  org.apache.activemq.util.ByteSequence packet = wireFormat.marshal(message);
  command.setMessage(new Buffer(packet.getData(), packet.getOffset(), packet.getLength()));
  store(command, isEnableJournalDiskSyncs() && message.isResponseRequired(), new IndexAware() {
    // sync add? (for async, future present from getFutureOrSequenceLong)
    Object possibleFuture = message.getMessageId().getFutureOrSequenceLong();
    @Override
    public void sequenceAssignedWithIndexLocked(final long sequence) {
      message.getMessageId().setFutureOrSequenceLong(sequence);
      if (indexListener != null) {
        if (possibleFuture == null) {
          trackPendingAdd(dest, sequence);
          indexListener.onAdd(new IndexListener.MessageContext(context, message, new Runnable() {
            @Override
            public void run() {
              trackPendingAddComplete(dest, sequence);
            }
          }));
        }
      }
    }
  }, null);
}

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

final boolean sendProducerAck = !message.isResponseRequired() && producerInfo.getWindowSize() > 0
    && !context.isInRecoveryMode();
if (message.isExpired()) {
    if (producerInfo.getWindowSize() > 0 || message.isResponseRequired()) {

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

protected void sendToSlave(Message message) {
  if (message.isResponseRequired()) {
    sendSyncToSlave(message);
  } else {
    sendAsyncToSlave(message);
  }
}

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

message.incrementReferenceCount();
final RecordLocation location = peristenceAdapter.writeCommand(message, message.isResponseRequired());
if (!context.isInTransaction()) {
  if (debug) {

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

message.incrementReferenceCount();
final RecordLocation location = peristenceAdapter.writeCommand(message, message.isResponseRequired());
if (!context.isInTransaction()) {
  if (debug) {

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

message.incrementReferenceCount();
final RecordLocation location = peristenceAdapter.writeCommand(message, message.isResponseRequired());
if (!context.isInTransaction()) {
  if (debug) {

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

final Location location = peristenceAdapter.writeCommand(message, message.isResponseRequired());
if (!context.isInTransaction()) {
  if (debug) {

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

message.incrementReferenceCount();
final RecordLocation location = peristenceAdapter.writeCommand(message, message.isResponseRequired());
if (!context.isInTransaction()) {
  if (debug) {

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

@Override
public Response processMessage(Message messageSend) throws Exception {
  ProducerId producerId = messageSend.getProducerId();
  AMQProducerBrokerExchange producerExchange = getProducerBrokerExchange(producerId);
  final AMQConnectionContext pcontext = producerExchange.getConnectionContext();
  final ProducerInfo producerInfo = producerExchange.getProducerState().getInfo();
  boolean sendProducerAck = !messageSend.isResponseRequired() && producerInfo.getWindowSize() > 0 && !pcontext.isInRecoveryMode();
  AMQSession session = getSession(producerId.getParentId());
  Transaction tx = lookupTX(messageSend.getTransactionId(), session);
  session.getCoreSession().resetTX(tx);
  try {
   session.send(producerInfo, messageSend, sendProducerAck);
  } catch (Exception e) {
   if (tx != null) {
     tx.markAsRollbackOnly(new ActiveMQException(e.getMessage()));
   }
   throw e;
  } finally {
   session.getCoreSession().resetTX(null);
  }
  return null;
}

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

if (result != null && message.isResponseRequired() && !result.isCancelled()) {
  try {
    result.get();

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

if (result != null && message.isResponseRequired() && !result.isCancelled()) {
  try {
    result.get();

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

if (result != null && message.isResponseRequired() && !result.isCancelled()) {
  try {
    result.get();

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

public void addMessage(ConnectionContext context, Message message) throws IOException {
  KahaAddMessageCommand command = new KahaAddMessageCommand();
  command.setDestination(dest);
  command.setMessageId(message.getMessageId().toString());
  command.setTransactionInfo(createTransactionInfo(message.getTransactionId()));
  command.setPriority(message.getPriority());
  command.setPrioritySupported(isPrioritizedMessages());
  org.apache.activemq.util.ByteSequence packet = wireFormat.marshal(message);
  command.setMessage(new Buffer(packet.getData(), packet.getOffset(), packet.getLength()));
  store(command, isEnableJournalDiskSyncs() && message.isResponseRequired(), null, null);
  
}

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

@Override
public void addMessage(final ConnectionContext context, final Message message) throws IOException {
  final KahaAddMessageCommand command = new KahaAddMessageCommand();
  command.setDestination(dest);
  command.setMessageId(message.getMessageId().toProducerKey());
  command.setTransactionInfo(TransactionIdConversion.convert(transactionIdTransformer.transform(message.getTransactionId())));
  command.setPriority(message.getPriority());
  command.setPrioritySupported(isPrioritizedMessages());
  org.apache.activemq.util.ByteSequence packet = wireFormat.marshal(message);
  command.setMessage(new Buffer(packet.getData(), packet.getOffset(), packet.getLength()));
  store(command, isEnableJournalDiskSyncs() && message.isResponseRequired(), new IndexAware() {
    // sync add? (for async, future present from getFutureOrSequenceLong)
    Object possibleFuture = message.getMessageId().getFutureOrSequenceLong();
    @Override
    public void sequenceAssignedWithIndexLocked(final long sequence) {
      message.getMessageId().setFutureOrSequenceLong(sequence);
      if (indexListener != null) {
        if (possibleFuture == null) {
          trackPendingAdd(dest, sequence);
          indexListener.onAdd(new IndexListener.MessageContext(context, message, new Runnable() {
            @Override
            public void run() {
              trackPendingAddComplete(dest, sequence);
            }
          }));
        }
      }
    }
  }, null);
}

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

@Override
public void addMessage(final ConnectionContext context, final Message message) throws IOException {
  final KahaAddMessageCommand command = new KahaAddMessageCommand();
  command.setDestination(dest);
  command.setMessageId(message.getMessageId().toProducerKey());
  command.setTransactionInfo(TransactionIdConversion.convert(transactionIdTransformer.transform(message.getTransactionId())));
  command.setPriority(message.getPriority());
  command.setPrioritySupported(isPrioritizedMessages());
  org.apache.activemq.util.ByteSequence packet = wireFormat.marshal(message);
  command.setMessage(new Buffer(packet.getData(), packet.getOffset(), packet.getLength()));
  store(command, isEnableJournalDiskSyncs() && message.isResponseRequired(), new IndexAware() {
    // sync add? (for async, future present from getFutureOrSequenceLong)
    Object possibleFuture = message.getMessageId().getFutureOrSequenceLong();
    @Override
    public void sequenceAssignedWithIndexLocked(final long sequence) {
      message.getMessageId().setFutureOrSequenceLong(sequence);
      if (indexListener != null) {
        if (possibleFuture == null) {
          trackPendingAdd(dest, sequence);
          indexListener.onAdd(new IndexListener.MessageContext(context, message, new Runnable() {
            @Override
            public void run() {
              trackPendingAddComplete(dest, sequence);
            }
          }));
        }
      }
    }
  }, null);
}

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

@Override
public void addMessage(final ConnectionContext context, final Message message) throws IOException {
  final KahaAddMessageCommand command = new KahaAddMessageCommand();
  command.setDestination(dest);
  command.setMessageId(message.getMessageId().toProducerKey());
  command.setTransactionInfo(TransactionIdConversion.convert(transactionIdTransformer.transform(message.getTransactionId())));
  command.setPriority(message.getPriority());
  command.setPrioritySupported(isPrioritizedMessages());
  org.apache.activemq.util.ByteSequence packet = wireFormat.marshal(message);
  command.setMessage(new Buffer(packet.getData(), packet.getOffset(), packet.getLength()));
  store(command, isEnableJournalDiskSyncs() && message.isResponseRequired(), new IndexAware() {
    // sync add? (for async, future present from getFutureOrSequenceLong)
    Object possibleFuture = message.getMessageId().getFutureOrSequenceLong();
    @Override
    public void sequenceAssignedWithIndexLocked(final long sequence) {
      message.getMessageId().setFutureOrSequenceLong(sequence);
      if (indexListener != null) {
        if (possibleFuture == null) {
          trackPendingAdd(dest, sequence);
          indexListener.onAdd(new IndexListener.MessageContext(context, message, new Runnable() {
            @Override
            public void run() {
              trackPendingAddComplete(dest, sequence);
            }
          }));
        }
      }
    }
  }, null);
}

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

Message

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

    更多

    Message类方法

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