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

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

本文整理了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

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

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

  1. if (!message.isResponseRequired()) {

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

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

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

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

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

  1. @Override
  2. public void addMessage(final ConnectionContext context, final Message message) throws IOException {
  3.   final KahaAddMessageCommand command = new KahaAddMessageCommand();
  4.   command.setDestination(dest);
  5.   command.setMessageId(message.getMessageId().toProducerKey());
  6.   command.setTransactionInfo(TransactionIdConversion.convert(transactionIdTransformer.transform(message.getTransactionId())));
  7.   command.setPriority(message.getPriority());
  8.   command.setPrioritySupported(isPrioritizedMessages());
  9.   org.apache.activemq.util.ByteSequence packet = wireFormat.marshal(message);
  10.   command.setMessage(new Buffer(packet.getData(), packet.getOffset(), packet.getLength()));
  11.   store(command, isEnableJournalDiskSyncs() && message.isResponseRequired(), new IndexAware() {
  12.     // sync add? (for async, future present from getFutureOrSequenceLong)
  13.     Object possibleFuture = message.getMessageId().getFutureOrSequenceLong();
  14.     @Override
  15.     public void sequenceAssignedWithIndexLocked(final long sequence) {
  16.       message.getMessageId().setFutureOrSequenceLong(sequence);
  17.       if (indexListener != null) {
  18.         if (possibleFuture == null) {
  19.           trackPendingAdd(dest, sequence);
  20.           indexListener.onAdd(new IndexListener.MessageContext(context, message, new Runnable() {
  21.             @Override
  22.             public void run() {
  23.               trackPendingAddComplete(dest, sequence);
  24.             }
  25.           }));
  26.         }
  27.       }
  28.     }
  29.   }, null);
  30. }

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

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

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

  1. protected void sendToSlave(Message message) {
  2.   if (message.isResponseRequired()) {
  3.     sendSyncToSlave(message);
  4.   } else {
  5.     sendAsyncToSlave(message);
  6.   }
  7. }

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

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

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

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

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

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

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

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

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

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

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

  1. @Override
  2. public Response processMessage(Message messageSend) throws Exception {
  3.   ProducerId producerId = messageSend.getProducerId();
  4.   AMQProducerBrokerExchange producerExchange = getProducerBrokerExchange(producerId);
  5.   final AMQConnectionContext pcontext = producerExchange.getConnectionContext();
  6.   final ProducerInfo producerInfo = producerExchange.getProducerState().getInfo();
  7.   boolean sendProducerAck = !messageSend.isResponseRequired() && producerInfo.getWindowSize() > 0 && !pcontext.isInRecoveryMode();
  8.   AMQSession session = getSession(producerId.getParentId());
  9.   Transaction tx = lookupTX(messageSend.getTransactionId(), session);
  10.   session.getCoreSession().resetTX(tx);
  11.   try {
  12.    session.send(producerInfo, messageSend, sendProducerAck);
  13.   } catch (Exception e) {
  14.    if (tx != null) {
  15.      tx.markAsRollbackOnly(new ActiveMQException(e.getMessage()));
  16.    }
  17.    throw e;
  18.   } finally {
  19.    session.getCoreSession().resetTX(null);
  20.   }
  21.   return null;
  22. }

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

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

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

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

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

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

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

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

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

  1. @Override
  2. public void addMessage(final ConnectionContext context, final Message message) throws IOException {
  3.   final KahaAddMessageCommand command = new KahaAddMessageCommand();
  4.   command.setDestination(dest);
  5.   command.setMessageId(message.getMessageId().toProducerKey());
  6.   command.setTransactionInfo(TransactionIdConversion.convert(transactionIdTransformer.transform(message.getTransactionId())));
  7.   command.setPriority(message.getPriority());
  8.   command.setPrioritySupported(isPrioritizedMessages());
  9.   org.apache.activemq.util.ByteSequence packet = wireFormat.marshal(message);
  10.   command.setMessage(new Buffer(packet.getData(), packet.getOffset(), packet.getLength()));
  11.   store(command, isEnableJournalDiskSyncs() && message.isResponseRequired(), new IndexAware() {
  12.     // sync add? (for async, future present from getFutureOrSequenceLong)
  13.     Object possibleFuture = message.getMessageId().getFutureOrSequenceLong();
  14.     @Override
  15.     public void sequenceAssignedWithIndexLocked(final long sequence) {
  16.       message.getMessageId().setFutureOrSequenceLong(sequence);
  17.       if (indexListener != null) {
  18.         if (possibleFuture == null) {
  19.           trackPendingAdd(dest, sequence);
  20.           indexListener.onAdd(new IndexListener.MessageContext(context, message, new Runnable() {
  21.             @Override
  22.             public void run() {
  23.               trackPendingAddComplete(dest, sequence);
  24.             }
  25.           }));
  26.         }
  27.       }
  28.     }
  29.   }, null);
  30. }

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

  1. @Override
  2. public void addMessage(final ConnectionContext context, final Message message) throws IOException {
  3.   final KahaAddMessageCommand command = new KahaAddMessageCommand();
  4.   command.setDestination(dest);
  5.   command.setMessageId(message.getMessageId().toProducerKey());
  6.   command.setTransactionInfo(TransactionIdConversion.convert(transactionIdTransformer.transform(message.getTransactionId())));
  7.   command.setPriority(message.getPriority());
  8.   command.setPrioritySupported(isPrioritizedMessages());
  9.   org.apache.activemq.util.ByteSequence packet = wireFormat.marshal(message);
  10.   command.setMessage(new Buffer(packet.getData(), packet.getOffset(), packet.getLength()));
  11.   store(command, isEnableJournalDiskSyncs() && message.isResponseRequired(), new IndexAware() {
  12.     // sync add? (for async, future present from getFutureOrSequenceLong)
  13.     Object possibleFuture = message.getMessageId().getFutureOrSequenceLong();
  14.     @Override
  15.     public void sequenceAssignedWithIndexLocked(final long sequence) {
  16.       message.getMessageId().setFutureOrSequenceLong(sequence);
  17.       if (indexListener != null) {
  18.         if (possibleFuture == null) {
  19.           trackPendingAdd(dest, sequence);
  20.           indexListener.onAdd(new IndexListener.MessageContext(context, message, new Runnable() {
  21.             @Override
  22.             public void run() {
  23.               trackPendingAddComplete(dest, sequence);
  24.             }
  25.           }));
  26.         }
  27.       }
  28.     }
  29.   }, null);
  30. }

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

  1. @Override
  2. public void addMessage(final ConnectionContext context, final Message message) throws IOException {
  3.   final KahaAddMessageCommand command = new KahaAddMessageCommand();
  4.   command.setDestination(dest);
  5.   command.setMessageId(message.getMessageId().toProducerKey());
  6.   command.setTransactionInfo(TransactionIdConversion.convert(transactionIdTransformer.transform(message.getTransactionId())));
  7.   command.setPriority(message.getPriority());
  8.   command.setPrioritySupported(isPrioritizedMessages());
  9.   org.apache.activemq.util.ByteSequence packet = wireFormat.marshal(message);
  10.   command.setMessage(new Buffer(packet.getData(), packet.getOffset(), packet.getLength()));
  11.   store(command, isEnableJournalDiskSyncs() && message.isResponseRequired(), new IndexAware() {
  12.     // sync add? (for async, future present from getFutureOrSequenceLong)
  13.     Object possibleFuture = message.getMessageId().getFutureOrSequenceLong();
  14.     @Override
  15.     public void sequenceAssignedWithIndexLocked(final long sequence) {
  16.       message.getMessageId().setFutureOrSequenceLong(sequence);
  17.       if (indexListener != null) {
  18.         if (possibleFuture == null) {
  19.           trackPendingAdd(dest, sequence);
  20.           indexListener.onAdd(new IndexListener.MessageContext(context, message, new Runnable() {
  21.             @Override
  22.             public void run() {
  23.               trackPendingAddComplete(dest, sequence);
  24.             }
  25.           }));
  26.         }
  27.       }
  28.     }
  29.   }, null);
  30. }

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

Message

相关文章

    查看更多

    热门标签

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

    最新文章

    更多

    Message类方法

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