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

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

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

Message.getTransactionId介绍

暂无

代码示例

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

  1. @Override
  2. public Response processMessage(Message send) throws Exception {
  3.   if (send != null) {
  4.     if (trackTransactions && send.getTransactionId() != null) {
  5.       ProducerId producerId = send.getProducerId();
  6.       ConnectionId connectionId = producerId.getParentId().getParentId();
  7.       if (connectionId != null) {
  8.         ConnectionState cs = connectionStates.get(connectionId);
  9.         if (cs != null) {
  10.           TransactionState transactionState = cs.getTransactionState(send.getTransactionId());
  11.           if (transactionState != null) {
  12.             transactionState.addCommand(send);
  13.             if (trackTransactionProducers) {
  14.               // for jmstemplate, track the producer in case it is closed before commit
  15.               // and needs to be replayed
  16.               SessionState ss = cs.getSessionState(producerId.getParentId());
  17.               ProducerState producerState = ss.getProducerState(producerId);
  18.               producerState.setTransactionState(transactionState);
  19.             }
  20.           }
  21.         }
  22.       }
  23.       return TRACKED_RESPONSE_MARKER;
  24.     }else if (trackMessages) {
  25.       messageCache.put(send.getMessageId(), send);
  26.     }
  27.   }
  28.   return null;
  29. }

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

  1. looseMarshalCachedObject(wireFormat, (DataStructure)info.getProducerId(), dataOut);
  2. looseMarshalCachedObject(wireFormat, (DataStructure)info.getDestination(), dataOut);
  3. looseMarshalCachedObject(wireFormat, (DataStructure)info.getTransactionId(), dataOut);
  4. looseMarshalCachedObject(wireFormat, (DataStructure)info.getOriginalDestination(), dataOut);
  5. looseMarshalNestedObject(wireFormat, (DataStructure)info.getMessageId(), dataOut);
  6. looseMarshalCachedObject(wireFormat, (DataStructure)info.getOriginalTransactionId(), dataOut);
  7. looseMarshalString(info.getGroupID(), dataOut);
  8. dataOut.writeInt(info.getGroupSequence());
  9. looseMarshalString(info.getCorrelationId(), dataOut);
  10. dataOut.writeBoolean(info.isPersistent());
  11. looseMarshalLong(wireFormat, info.getExpiration(), dataOut);
  12. dataOut.writeByte(info.getPriority());
  13. looseMarshalNestedObject(wireFormat, (DataStructure)info.getReplyTo(), dataOut);
  14. looseMarshalLong(wireFormat, info.getTimestamp(), dataOut);
  15. looseMarshalString(info.getType(), dataOut);
  16. looseMarshalByteSequence(wireFormat, info.getContent(), dataOut);
  17. looseMarshalByteSequence(wireFormat, info.getMarshalledProperties(), dataOut);
  18. dataOut.writeBoolean(info.isCompressed());
  19. dataOut.writeInt(info.getRedeliveryCounter());
  20. looseMarshalObjectArray(wireFormat, info.getBrokerPath(), dataOut);
  21. looseMarshalLong(wireFormat, info.getArrival(), dataOut);
  22. looseMarshalString(info.getUserID(), dataOut);

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

  1. protected Message configureMessage(MessageDispatch md) throws IOException {
  2.   Message message = md.getMessage().copy();
  3.   // Update the packet to show where it came from.
  4.   message.setBrokerPath(appendToBrokerPath(message.getBrokerPath(), localBrokerPath));
  5.   message.setProducerId(producerInfo.getProducerId());
  6.   message.setDestination(md.getDestination());
  7.   message.setMemoryUsage(null);
  8.   if (message.getOriginalTransactionId() == null) {
  9.     message.setOriginalTransactionId(message.getTransactionId());
  10.   }
  11.   message.setTransactionId(null);
  12.   if (configuration.isUseCompression()) {
  13.     message.compress();
  14.   }
  15.   return message;
  16. }

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

  1. if (message.getOriginalDestination() != null) {
  2.   message.setOriginalDestination(message.getDestination());
  3. if (message.getOriginalTransactionId() != null) {
  4.   message.setOriginalTransactionId(message.getTransactionId());

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

  1. public static void doResend(final ConnectionContext context, Message originalMessage, ActiveMQDestination deadLetterDestination, boolean copy) throws Exception {
  2.   Message message = copy ? originalMessage.copy() : originalMessage;
  3.   message.setOriginalDestination(message.getDestination());
  4.   message.setOriginalTransactionId(message.getTransactionId());
  5.   message.setDestination(deadLetterDestination);
  6.   message.setTransactionId(null);
  7.   message.setMemoryUsage(null);
  8.   message.setRedeliveryCounter(0);
  9.   message.getMessageId().setDataLocator(null);
  10.   boolean originalFlowControl = context.isProducerFlowControl();
  11.   try {
  12.     context.setProducerFlowControl(false);
  13.     ProducerInfo info = new ProducerInfo();
  14.     ProducerState state = new ProducerState(info);
  15.     ProducerBrokerExchange producerExchange = new ProducerBrokerExchange();
  16.     producerExchange.setProducerState(state);
  17.     producerExchange.setMutable(true);
  18.     producerExchange.setConnectionContext(context);
  19.     context.getBroker().send(producerExchange, message);
  20.   } finally {
  21.     context.setProducerFlowControl(originalFlowControl);
  22.   }
  23. }

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

  1. looseMarshalCachedObject(wireFormat, (DataStructure)info.getProducerId(), dataOut);
  2. looseMarshalCachedObject(wireFormat, (DataStructure)info.getDestination(), dataOut);
  3. looseMarshalCachedObject(wireFormat, (DataStructure)info.getTransactionId(), dataOut);
  4. looseMarshalCachedObject(wireFormat, (DataStructure)info.getOriginalDestination(), dataOut);
  5. looseMarshalNestedObject(wireFormat, (DataStructure)info.getMessageId(), dataOut);
  6. looseMarshalCachedObject(wireFormat, (DataStructure)info.getOriginalTransactionId(), dataOut);
  7. looseMarshalString(info.getGroupID(), dataOut);
  8. dataOut.writeInt(info.getGroupSequence());
  9. looseMarshalString(info.getCorrelationId(), dataOut);
  10. dataOut.writeBoolean(info.isPersistent());
  11. looseMarshalLong(wireFormat, info.getExpiration(), dataOut);
  12. dataOut.writeByte(info.getPriority());
  13. looseMarshalNestedObject(wireFormat, (DataStructure)info.getReplyTo(), dataOut);
  14. looseMarshalLong(wireFormat, info.getTimestamp(), dataOut);
  15. looseMarshalString(info.getType(), dataOut);
  16. looseMarshalByteSequence(wireFormat, info.getContent(), dataOut);
  17. looseMarshalByteSequence(wireFormat, info.getMarshalledProperties(), dataOut);
  18. dataOut.writeBoolean(info.isCompressed());
  19. dataOut.writeInt(info.getRedeliveryCounter());
  20. looseMarshalObjectArray(wireFormat, info.getBrokerPath(), dataOut);
  21. looseMarshalLong(wireFormat, info.getArrival(), dataOut);
  22. looseMarshalString(info.getUserID(), dataOut);

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

  1. protected Message configureMessage(MessageDispatch md) {
  2.   Message message = md.getMessage().copy();
  3.   // Update the packet to show where it came from.
  4.   message.setBrokerPath(appendToBrokerPath(message.getBrokerPath(), localBrokerPath));
  5.   message.setProducerId(producerInfo.getProducerId());
  6.   message.setDestination(md.getDestination());
  7.   if (message.getOriginalTransactionId() == null) {
  8.     message.setOriginalTransactionId(message.getTransactionId());
  9.   }
  10.   message.setTransactionId(null);
  11.   return message;
  12. }

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

  1. looseMarshalCachedObject(wireFormat, (DataStructure)info.getProducerId(), dataOut);
  2. looseMarshalCachedObject(wireFormat, (DataStructure)info.getDestination(), dataOut);
  3. looseMarshalCachedObject(wireFormat, (DataStructure)info.getTransactionId(), dataOut);
  4. looseMarshalCachedObject(wireFormat, (DataStructure)info.getOriginalDestination(), dataOut);
  5. looseMarshalNestedObject(wireFormat, (DataStructure)info.getMessageId(), dataOut);
  6. looseMarshalCachedObject(wireFormat, (DataStructure)info.getOriginalTransactionId(), dataOut);
  7. looseMarshalString(info.getGroupID(), dataOut);
  8. dataOut.writeInt(info.getGroupSequence());
  9. looseMarshalString(info.getCorrelationId(), dataOut);
  10. dataOut.writeBoolean(info.isPersistent());
  11. looseMarshalLong(wireFormat, info.getExpiration(), dataOut);
  12. dataOut.writeByte(info.getPriority());
  13. looseMarshalNestedObject(wireFormat, (DataStructure)info.getReplyTo(), dataOut);
  14. looseMarshalLong(wireFormat, info.getTimestamp(), dataOut);
  15. looseMarshalString(info.getType(), dataOut);
  16. looseMarshalByteSequence(wireFormat, info.getContent(), dataOut);
  17. looseMarshalByteSequence(wireFormat, info.getMarshalledProperties(), dataOut);
  18. dataOut.writeBoolean(info.isCompressed());
  19. dataOut.writeInt(info.getRedeliveryCounter());
  20. looseMarshalObjectArray(wireFormat, info.getBrokerPath(), dataOut);
  21. looseMarshalLong(wireFormat, info.getArrival(), dataOut);
  22. looseMarshalString(info.getUserID(), dataOut);

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

  1. protected Message configureMessage(MessageDispatch md) throws IOException {
  2.   Message message = md.getMessage().copy();
  3.   // Update the packet to show where it came from.
  4.   message.setBrokerPath(appendToBrokerPath(message.getBrokerPath(), localBrokerPath));
  5.   message.setProducerId(producerInfo.getProducerId());
  6.   message.setDestination(md.getDestination());
  7.   message.setMemoryUsage(null);
  8.   if (message.getOriginalTransactionId() == null) {
  9.     message.setOriginalTransactionId(message.getTransactionId());
  10.   }
  11.   message.setTransactionId(null);
  12.   if (configuration.isUseCompression()) {
  13.     message.compress();
  14.   }
  15.   return message;
  16. }

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

  1. looseMarshalCachedObject(wireFormat, (DataStructure)info.getProducerId(), dataOut);
  2. looseMarshalCachedObject(wireFormat, (DataStructure)info.getDestination(), dataOut);
  3. looseMarshalCachedObject(wireFormat, (DataStructure)info.getTransactionId(), dataOut);
  4. looseMarshalCachedObject(wireFormat, (DataStructure)info.getOriginalDestination(), dataOut);
  5. looseMarshalNestedObject(wireFormat, (DataStructure)info.getMessageId(), dataOut);
  6. looseMarshalCachedObject(wireFormat, (DataStructure)info.getOriginalTransactionId(), dataOut);
  7. looseMarshalString(info.getGroupID(), dataOut);
  8. dataOut.writeInt(info.getGroupSequence());
  9. looseMarshalString(info.getCorrelationId(), dataOut);
  10. dataOut.writeBoolean(info.isPersistent());
  11. looseMarshalLong(wireFormat, info.getExpiration(), dataOut);
  12. dataOut.writeByte(info.getPriority());
  13. looseMarshalNestedObject(wireFormat, (DataStructure)info.getReplyTo(), dataOut);
  14. looseMarshalLong(wireFormat, info.getTimestamp(), dataOut);
  15. looseMarshalString(info.getType(), dataOut);
  16. looseMarshalByteSequence(wireFormat, info.getContent(), dataOut);
  17. looseMarshalByteSequence(wireFormat, info.getMarshalledProperties(), dataOut);
  18. dataOut.writeBoolean(info.isCompressed());
  19. dataOut.writeInt(info.getRedeliveryCounter());
  20. looseMarshalObjectArray(wireFormat, info.getBrokerPath(), dataOut);
  21. looseMarshalLong(wireFormat, info.getArrival(), dataOut);
  22. looseMarshalString(info.getUserID(), dataOut);

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

  1. protected Message configureMessage(MessageDispatch md) throws IOException {
  2.   Message message = md.getMessage().copy();
  3.   // Update the packet to show where it came from.
  4.   message.setBrokerPath(appendToBrokerPath(message.getBrokerPath(), localBrokerPath));
  5.   message.setProducerId(producerInfo.getProducerId());
  6.   message.setDestination(md.getDestination());
  7.   message.setMemoryUsage(null);
  8.   if (message.getOriginalTransactionId() == null) {
  9.     message.setOriginalTransactionId(message.getTransactionId());
  10.   }
  11.   message.setTransactionId(null);
  12.   if (configuration.isUseCompression()) {
  13.     message.compress();
  14.   }
  15.   return message;
  16. }

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

  1. looseMarshalCachedObject(wireFormat, (DataStructure)info.getProducerId(), dataOut);
  2. looseMarshalCachedObject(wireFormat, (DataStructure)info.getDestination(), dataOut);
  3. looseMarshalCachedObject(wireFormat, (DataStructure)info.getTransactionId(), dataOut);
  4. looseMarshalCachedObject(wireFormat, (DataStructure)info.getOriginalDestination(), dataOut);
  5. looseMarshalNestedObject(wireFormat, (DataStructure)info.getMessageId(), dataOut);
  6. looseMarshalCachedObject(wireFormat, (DataStructure)info.getOriginalTransactionId(), dataOut);
  7. looseMarshalString(info.getGroupID(), dataOut);
  8. dataOut.writeInt(info.getGroupSequence());
  9. looseMarshalString(info.getCorrelationId(), dataOut);
  10. dataOut.writeBoolean(info.isPersistent());
  11. looseMarshalLong(wireFormat, info.getExpiration(), dataOut);
  12. dataOut.writeByte(info.getPriority());
  13. looseMarshalNestedObject(wireFormat, (DataStructure)info.getReplyTo(), dataOut);
  14. looseMarshalLong(wireFormat, info.getTimestamp(), dataOut);
  15. looseMarshalString(info.getType(), dataOut);
  16. looseMarshalByteSequence(wireFormat, info.getContent(), dataOut);
  17. looseMarshalByteSequence(wireFormat, info.getMarshalledProperties(), dataOut);
  18. dataOut.writeBoolean(info.isCompressed());
  19. dataOut.writeInt(info.getRedeliveryCounter());
  20. looseMarshalObjectArray(wireFormat, info.getBrokerPath(), dataOut);
  21. looseMarshalLong(wireFormat, info.getArrival(), dataOut);
  22. looseMarshalString(info.getUserID(), dataOut);

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

  1. protected Message configureMessage(MessageDispatch md) throws IOException {
  2.   Message message = md.getMessage().copy();
  3.   // Update the packet to show where it came from.
  4.   message.setBrokerPath(appendToBrokerPath(message.getBrokerPath(), localBrokerPath));
  5.   message.setProducerId(producerInfo.getProducerId());
  6.   message.setDestination(md.getDestination());
  7.   message.setMemoryUsage(null);
  8.   if (message.getOriginalTransactionId() == null) {
  9.     message.setOriginalTransactionId(message.getTransactionId());
  10.   }
  11.   message.setTransactionId(null);
  12.   if (configuration.isUseCompression()) {
  13.     message.compress();
  14.   }
  15.   return message;
  16. }

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

  1. looseMarshalCachedObject(wireFormat, (DataStructure)info.getProducerId(), dataOut);
  2. looseMarshalCachedObject(wireFormat, (DataStructure)info.getDestination(), dataOut);
  3. looseMarshalCachedObject(wireFormat, (DataStructure)info.getTransactionId(), dataOut);
  4. looseMarshalCachedObject(wireFormat, (DataStructure)info.getOriginalDestination(), dataOut);
  5. looseMarshalNestedObject(wireFormat, (DataStructure)info.getMessageId(), dataOut);
  6. looseMarshalCachedObject(wireFormat, (DataStructure)info.getOriginalTransactionId(), dataOut);
  7. looseMarshalString(info.getGroupID(), dataOut);
  8. dataOut.writeInt(info.getGroupSequence());
  9. looseMarshalString(info.getCorrelationId(), dataOut);
  10. dataOut.writeBoolean(info.isPersistent());
  11. looseMarshalLong(wireFormat, info.getExpiration(), dataOut);
  12. dataOut.writeByte(info.getPriority());
  13. looseMarshalNestedObject(wireFormat, (DataStructure)info.getReplyTo(), dataOut);
  14. looseMarshalLong(wireFormat, info.getTimestamp(), dataOut);
  15. looseMarshalString(info.getType(), dataOut);
  16. looseMarshalByteSequence(wireFormat, info.getContent(), dataOut);
  17. looseMarshalByteSequence(wireFormat, info.getMarshalledProperties(), dataOut);
  18. dataOut.writeBoolean(info.isCompressed());
  19. dataOut.writeInt(info.getRedeliveryCounter());
  20. looseMarshalObjectArray(wireFormat, info.getBrokerPath(), dataOut);
  21. looseMarshalLong(wireFormat, info.getArrival(), dataOut);
  22. looseMarshalString(info.getUserID(), dataOut);

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

  1. looseMarshalCachedObject(wireFormat, (DataStructure)info.getProducerId(), dataOut);
  2. looseMarshalCachedObject(wireFormat, (DataStructure)info.getDestination(), dataOut);
  3. looseMarshalCachedObject(wireFormat, (DataStructure)info.getTransactionId(), dataOut);
  4. looseMarshalCachedObject(wireFormat, (DataStructure)info.getOriginalDestination(), dataOut);
  5. looseMarshalNestedObject(wireFormat, (DataStructure)info.getMessageId(), dataOut);
  6. looseMarshalCachedObject(wireFormat, (DataStructure)info.getOriginalTransactionId(), dataOut);
  7. looseMarshalString(info.getGroupID(), dataOut);
  8. dataOut.writeInt(info.getGroupSequence());
  9. looseMarshalString(info.getCorrelationId(), dataOut);
  10. dataOut.writeBoolean(info.isPersistent());
  11. looseMarshalLong(wireFormat, info.getExpiration(), dataOut);
  12. dataOut.writeByte(info.getPriority());
  13. looseMarshalNestedObject(wireFormat, (DataStructure)info.getReplyTo(), dataOut);
  14. looseMarshalLong(wireFormat, info.getTimestamp(), dataOut);
  15. looseMarshalString(info.getType(), dataOut);
  16. looseMarshalByteSequence(wireFormat, info.getContent(), dataOut);
  17. looseMarshalByteSequence(wireFormat, info.getMarshalledProperties(), dataOut);
  18. dataOut.writeBoolean(info.isCompressed());
  19. dataOut.writeInt(info.getRedeliveryCounter());
  20. looseMarshalObjectArray(wireFormat, info.getBrokerPath(), dataOut);
  21. looseMarshalLong(wireFormat, info.getArrival(), dataOut);
  22. looseMarshalString(info.getUserID(), dataOut);

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

  1. looseMarshalCachedObject(wireFormat, (DataStructure)info.getProducerId(), dataOut);
  2. looseMarshalCachedObject(wireFormat, (DataStructure)info.getDestination(), dataOut);
  3. looseMarshalCachedObject(wireFormat, (DataStructure)info.getTransactionId(), dataOut);
  4. looseMarshalCachedObject(wireFormat, (DataStructure)info.getOriginalDestination(), dataOut);
  5. looseMarshalNestedObject(wireFormat, (DataStructure)info.getMessageId(), dataOut);
  6. looseMarshalCachedObject(wireFormat, (DataStructure)info.getOriginalTransactionId(), dataOut);
  7. looseMarshalString(info.getGroupID(), dataOut);
  8. dataOut.writeInt(info.getGroupSequence());
  9. looseMarshalString(info.getCorrelationId(), dataOut);
  10. dataOut.writeBoolean(info.isPersistent());
  11. looseMarshalLong(wireFormat, info.getExpiration(), dataOut);
  12. dataOut.writeByte(info.getPriority());
  13. looseMarshalNestedObject(wireFormat, (DataStructure)info.getReplyTo(), dataOut);
  14. looseMarshalLong(wireFormat, info.getTimestamp(), dataOut);
  15. looseMarshalString(info.getType(), dataOut);
  16. looseMarshalByteSequence(wireFormat, info.getContent(), dataOut);
  17. looseMarshalByteSequence(wireFormat, info.getMarshalledProperties(), dataOut);
  18. dataOut.writeBoolean(info.isCompressed());
  19. dataOut.writeInt(info.getRedeliveryCounter());
  20. looseMarshalObjectArray(wireFormat, info.getBrokerPath(), dataOut);
  21. looseMarshalLong(wireFormat, info.getArrival(), dataOut);
  22. looseMarshalString(info.getUserID(), dataOut);

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

  1. looseMarshalCachedObject(wireFormat, (DataStructure)info.getProducerId(), dataOut);
  2. looseMarshalCachedObject(wireFormat, (DataStructure)info.getDestination(), dataOut);
  3. looseMarshalCachedObject(wireFormat, (DataStructure)info.getTransactionId(), dataOut);
  4. looseMarshalCachedObject(wireFormat, (DataStructure)info.getOriginalDestination(), dataOut);
  5. looseMarshalNestedObject(wireFormat, (DataStructure)info.getMessageId(), dataOut);
  6. looseMarshalCachedObject(wireFormat, (DataStructure)info.getOriginalTransactionId(), dataOut);
  7. looseMarshalString(info.getGroupID(), dataOut);
  8. dataOut.writeInt(info.getGroupSequence());
  9. looseMarshalString(info.getCorrelationId(), dataOut);
  10. dataOut.writeBoolean(info.isPersistent());
  11. looseMarshalLong(wireFormat, info.getExpiration(), dataOut);
  12. dataOut.writeByte(info.getPriority());
  13. looseMarshalNestedObject(wireFormat, (DataStructure)info.getReplyTo(), dataOut);
  14. looseMarshalLong(wireFormat, info.getTimestamp(), dataOut);
  15. looseMarshalString(info.getType(), dataOut);
  16. looseMarshalByteSequence(wireFormat, info.getContent(), dataOut);
  17. looseMarshalByteSequence(wireFormat, info.getMarshalledProperties(), dataOut);
  18. dataOut.writeBoolean(info.isCompressed());
  19. dataOut.writeInt(info.getRedeliveryCounter());
  20. looseMarshalObjectArray(wireFormat, info.getBrokerPath(), dataOut);
  21. looseMarshalLong(wireFormat, info.getArrival(), dataOut);
  22. looseMarshalString(info.getUserID(), dataOut);

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

  1. tightMarshalCachedObject2(wireFormat, (DataStructure)info.getProducerId(), dataOut, bs);
  2. tightMarshalCachedObject2(wireFormat, (DataStructure)info.getDestination(), dataOut, bs);
  3. tightMarshalCachedObject2(wireFormat, (DataStructure)info.getTransactionId(), dataOut, bs);
  4. tightMarshalCachedObject2(wireFormat, (DataStructure)info.getOriginalDestination(), dataOut, bs);
  5. tightMarshalNestedObject2(wireFormat, (DataStructure)info.getMessageId(), dataOut, bs);
  6. tightMarshalCachedObject2(wireFormat, (DataStructure)info.getOriginalTransactionId(), dataOut, bs);
  7. tightMarshalString2(info.getGroupID(), dataOut, bs);
  8. dataOut.writeInt(info.getGroupSequence());
  9. tightMarshalString2(info.getCorrelationId(), dataOut, bs);
  10. bs.readBoolean();
  11. tightMarshalLong2(wireFormat, info.getExpiration(), dataOut, bs);
  12. dataOut.writeByte(info.getPriority());
  13. tightMarshalNestedObject2(wireFormat, (DataStructure)info.getReplyTo(), dataOut, bs);
  14. tightMarshalLong2(wireFormat, info.getTimestamp(), dataOut, bs);
  15. tightMarshalString2(info.getType(), dataOut, bs);
  16. tightMarshalByteSequence2(info.getContent(), dataOut, bs);
  17. tightMarshalByteSequence2(info.getMarshalledProperties(), dataOut, bs);
  18. bs.readBoolean();
  19. dataOut.writeInt(info.getRedeliveryCounter());
  20. tightMarshalObjectArray2(wireFormat, info.getBrokerPath(), dataOut, bs);
  21. tightMarshalLong2(wireFormat, info.getArrival(), dataOut, bs);
  22. tightMarshalString2(info.getUserID(), dataOut, bs);

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

  1. tightMarshalCachedObject2(wireFormat, (DataStructure)info.getProducerId(), dataOut, bs);
  2. tightMarshalCachedObject2(wireFormat, (DataStructure)info.getDestination(), dataOut, bs);
  3. tightMarshalCachedObject2(wireFormat, (DataStructure)info.getTransactionId(), dataOut, bs);
  4. tightMarshalCachedObject2(wireFormat, (DataStructure)info.getOriginalDestination(), dataOut, bs);
  5. tightMarshalNestedObject2(wireFormat, (DataStructure)info.getMessageId(), dataOut, bs);
  6. tightMarshalCachedObject2(wireFormat, (DataStructure)info.getOriginalTransactionId(), dataOut, bs);
  7. tightMarshalString2(info.getGroupID(), dataOut, bs);
  8. dataOut.writeInt(info.getGroupSequence());
  9. tightMarshalString2(info.getCorrelationId(), dataOut, bs);
  10. bs.readBoolean();
  11. tightMarshalLong2(wireFormat, info.getExpiration(), dataOut, bs);
  12. dataOut.writeByte(info.getPriority());
  13. tightMarshalNestedObject2(wireFormat, (DataStructure)info.getReplyTo(), dataOut, bs);
  14. tightMarshalLong2(wireFormat, info.getTimestamp(), dataOut, bs);
  15. tightMarshalString2(info.getType(), dataOut, bs);
  16. tightMarshalByteSequence2(info.getContent(), dataOut, bs);
  17. tightMarshalByteSequence2(info.getMarshalledProperties(), dataOut, bs);
  18. bs.readBoolean();
  19. dataOut.writeInt(info.getRedeliveryCounter());
  20. tightMarshalObjectArray2(wireFormat, info.getBrokerPath(), dataOut, bs);
  21. tightMarshalLong2(wireFormat, info.getArrival(), dataOut, bs);
  22. tightMarshalString2(info.getUserID(), dataOut, bs);

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

  1. rc += tightMarshalCachedObject1(wireFormat, (DataStructure)info.getProducerId(), bs);
  2. rc += tightMarshalCachedObject1(wireFormat, (DataStructure)info.getDestination(), bs);
  3. rc += tightMarshalCachedObject1(wireFormat, (DataStructure)info.getTransactionId(), bs);
  4. rc += tightMarshalCachedObject1(wireFormat, (DataStructure)info.getOriginalDestination(), bs);
  5. rc += tightMarshalNestedObject1(wireFormat, (DataStructure)info.getMessageId(), bs);
  6. rc += tightMarshalCachedObject1(wireFormat, (DataStructure)info.getOriginalTransactionId(), bs);
  7. rc += tightMarshalString1(info.getGroupID(), bs);
  8. rc += tightMarshalString1(info.getCorrelationId(), bs);
  9. bs.writeBoolean(info.isPersistent());
  10. rc += tightMarshalLong1(wireFormat, info.getExpiration(), bs);
  11. rc += tightMarshalNestedObject1(wireFormat, (DataStructure)info.getReplyTo(), bs);
  12. rc += tightMarshalLong1(wireFormat, info.getTimestamp(), bs);
  13. rc += tightMarshalString1(info.getType(), bs);
  14. rc += tightMarshalByteSequence1(info.getContent(), bs);
  15. rc += tightMarshalByteSequence1(info.getMarshalledProperties(), bs);
  16. rc += tightMarshalCachedObject1(wireFormat, (DataStructure)info.getTargetConsumerId(), bs);
  17. bs.writeBoolean(info.isCompressed());
  18. rc += tightMarshalObjectArray1(wireFormat, info.getBrokerPath(), bs);
  19. rc += tightMarshalLong1(wireFormat, info.getArrival(), bs);
  20. rc += tightMarshalString1(info.getUserID(), bs);

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

Message

相关文章

    查看更多

    热门标签

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

    最新文章

    更多

    Message类方法

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