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

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

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

Message.getBrokerPath介绍

[英]The route of brokers the command has moved through.
[中]指挥部经过的中间人路线。

代码示例

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

  1. @Override
  2. public void send(ProducerBrokerExchange producerExchange, Message message) throws Exception {
  3.   if (message.getTimestamp() > 0 && !isDestinationDLQ(message) &&
  4.     (processNetworkMessages || (message.getBrokerPath() == null || message.getBrokerPath().length == 0))) {
  5.     // timestamp not been disabled and has not passed through a network or processNetworkMessages=true
  6.     long oldExpiration = message.getExpiration();
  7.     long newTimeStamp = System.currentTimeMillis();
  8.     long timeToLive = zeroExpirationOverride;
  9.     long oldTimestamp = message.getTimestamp();
  10.     if (oldExpiration > 0) {
  11.       timeToLive = oldExpiration - oldTimestamp;
  12.     }
  13.     if (timeToLive > 0 && ttlCeiling > 0 && timeToLive > ttlCeiling) {
  14.       timeToLive = ttlCeiling;
  15.     }
  16.     long expiration = timeToLive + newTimeStamp;
  17.     // In the scenario that the Broker is behind the clients we never want to set the
  18.     // Timestamp and Expiration in the past
  19.     if(!futureOnly || (expiration > oldExpiration)) {
  20.       if (timeToLive > 0 && expiration > 0) {
  21.         message.setExpiration(expiration);
  22.       }
  23.       message.setTimestamp(newTimeStamp);
  24.       LOG.debug("Set message {} timestamp from {} to {}", new Object[]{ message.getMessageId(), oldTimestamp, newTimeStamp });
  25.     }
  26.   }
  27.   super.send(producerExchange, message);
  28. }

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

  1. @Override
  2. protected boolean matchesForwardingFilter(Message message, final MessageEvaluationContext mec) {
  3.   boolean match = true;
  4.   if (mec.getDestination().isQueue() && contains(message.getBrokerPath(), networkBrokerId)) {
  5.     // potential replay back to origin
  6.     match = allowReplayWhenNoConsumers && hasNoLocalConsumers(message, mec) && hasNotJustArrived(message);
  7.     if (match) {
  8.       LOG.trace("Replaying [{}] for [{}] back to origin in the absence of a local consumer", message.getMessageId(), message.getDestination());
  9.     } else {
  10.       LOG.trace("Suppressing replay of [{}] for [{}] back to origin {}", new Object[]{ message.getMessageId(), message.getDestination(), Arrays.asList(message.getBrokerPath())} );
  11.     }
  12.   } else {
  13.     // use existing filter logic for topics and non replays
  14.     match = super.matchesForwardingFilter(message, mec);
  15.   }
  16.   if (match && rateLimitExceeded()) {
  17.     LOG.trace("Throttled network consumer rejecting [{}] for [{}] {}>{}/{}", new Object[]{
  18.         message.getMessageId(), message.getDestination(), matchCount, rateLimit, rateDuration
  19.     });
  20.     match = false;
  21.   }
  22.   return match;
  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: 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. configuration.getBrokerName(), remoteBrokerName, Arrays.toString(md.getMessage().getBrokerPath()), md.getMessage()
  2.   });
  3.     configuration.getBrokerName(), remoteBrokerName, md.getConsumerId(), message.getDestination(), Arrays.toString(message.getBrokerPath()), (LOG.isTraceEnabled() ? message : message.getMessageId())
  4. });
  5. if (isDuplex() && NetworkBridgeFilter.isAdvisoryInterpretedByNetworkBridge(message)) {

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

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

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

Message

相关文章

    查看更多

    热门标签

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

    最新文章

    更多

    Message类方法

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