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

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

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

Message.beforeMarshall介绍

暂无

代码示例

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

  1. messageSend.removeProperty(ScheduledMessage.AMQ_SCHEDULED_CRON);
  2. if (messageSend.getTimestamp() > 0 && messageSend.getExpiration() > 0) {
  3.   long oldExpiration = messageSend.getExpiration();
  4.   long newTimeStamp = System.currentTimeMillis();
  5.   long timeToLive = 0;
  6.   long oldTimestamp = messageSend.getTimestamp();
  7.     LOG.debug("Set message {} timestamp from {} to {}", new Object[]{ messageSend.getMessageId(), oldTimestamp, newTimeStamp });
  8. messageSend.beforeMarshall(wireFormat);

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

  1. @Override
  2. public ListenableFuture<Object> asyncAddQueueMessage(final ConnectionContext context, final Message message)
  3.     throws IOException {
  4.   if (isConcurrentStoreAndDispatchQueues()) {
  5.     message.beforeMarshall(wireFormat);
  6.     StoreQueueTask result = new StoreQueueTask(this, context, message);
  7.     ListenableFuture<Object> future = result.getFuture();
  8.     message.getMessageId().setFutureOrSequenceLong(future);
  9.     message.setRecievedByDFBridge(true); // flag message as concurrentStoreAndDispatch
  10.     result.aquireLocks();
  11.     synchronized (asyncTaskMap) {
  12.       addQueueTask(this, result);
  13.       if (indexListener != null) {
  14.         indexListener.onAdd(new IndexListener.MessageContext(context, message, null));
  15.       }
  16.     }
  17.     return future;
  18.   } else {
  19.     return super.asyncAddQueueMessage(context, message);
  20.   }
  21. }

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

  1. info.beforeMarshall(wireFormat);
  2. looseMarshalCachedObject(wireFormat, (DataStructure)info.getTransactionId(), dataOut);
  3. looseMarshalCachedObject(wireFormat, (DataStructure)info.getOriginalDestination(), dataOut);
  4. looseMarshalNestedObject(wireFormat, (DataStructure)info.getMessageId(), dataOut);
  5. looseMarshalCachedObject(wireFormat, (DataStructure)info.getOriginalTransactionId(), dataOut);
  6. looseMarshalString(info.getGroupID(), dataOut);
  7. looseMarshalString(info.getCorrelationId(), dataOut);
  8. dataOut.writeBoolean(info.isPersistent());
  9. looseMarshalLong(wireFormat, info.getExpiration(), dataOut);
  10. dataOut.writeByte(info.getPriority());
  11. looseMarshalNestedObject(wireFormat, (DataStructure)info.getReplyTo(), dataOut);
  12. looseMarshalLong(wireFormat, info.getTimestamp(), dataOut);
  13. looseMarshalString(info.getType(), dataOut);
  14. looseMarshalByteSequence(wireFormat, info.getContent(), dataOut);

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

  1. @Override
  2. public ListenableFuture<Object> asyncAddQueueMessage(final ConnectionContext context, final Message message)
  3.     throws IOException {
  4.   if (isConcurrentStoreAndDispatchQueues()) {
  5.     message.beforeMarshall(wireFormat);
  6.     StoreQueueTask result = new StoreQueueTask(this, context, message);
  7.     ListenableFuture<Object> future = result.getFuture();
  8.     message.getMessageId().setFutureOrSequenceLong(future);
  9.     message.setRecievedByDFBridge(true); // flag message as concurrentStoreAndDispatch
  10.     result.aquireLocks();
  11.     synchronized (asyncTaskMap) {
  12.       addQueueTask(this, result);
  13.       if (indexListener != null) {
  14.         indexListener.onAdd(new IndexListener.MessageContext(context, message, null));
  15.       }
  16.     }
  17.     return future;
  18.   } else {
  19.     return super.asyncAddQueueMessage(context, message);
  20.   }
  21. }

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

  1. info.beforeMarshall(wireFormat);
  2. looseMarshalCachedObject(wireFormat, (DataStructure)info.getTransactionId(), dataOut);
  3. looseMarshalCachedObject(wireFormat, (DataStructure)info.getOriginalDestination(), dataOut);
  4. looseMarshalNestedObject(wireFormat, (DataStructure)info.getMessageId(), dataOut);
  5. looseMarshalCachedObject(wireFormat, (DataStructure)info.getOriginalTransactionId(), dataOut);
  6. looseMarshalString(info.getGroupID(), dataOut);
  7. looseMarshalString(info.getCorrelationId(), dataOut);
  8. dataOut.writeBoolean(info.isPersistent());
  9. looseMarshalLong(wireFormat, info.getExpiration(), dataOut);
  10. dataOut.writeByte(info.getPriority());
  11. looseMarshalNestedObject(wireFormat, (DataStructure)info.getReplyTo(), dataOut);
  12. looseMarshalLong(wireFormat, info.getTimestamp(), dataOut);
  13. looseMarshalString(info.getType(), dataOut);
  14. looseMarshalByteSequence(wireFormat, info.getContent(), dataOut);

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

  1. @Override
  2. public ListenableFuture<Object> asyncAddQueueMessage(final ConnectionContext context, final Message message)
  3.     throws IOException {
  4.   if (isConcurrentStoreAndDispatchQueues()) {
  5.     message.beforeMarshall(wireFormat);
  6.     StoreQueueTask result = new StoreQueueTask(this, context, message);
  7.     ListenableFuture<Object> future = result.getFuture();
  8.     message.getMessageId().setFutureOrSequenceLong(future);
  9.     message.setRecievedByDFBridge(true); // flag message as concurrentStoreAndDispatch
  10.     result.aquireLocks();
  11.     synchronized (asyncTaskMap) {
  12.       addQueueTask(this, result);
  13.       if (indexListener != null) {
  14.         indexListener.onAdd(new IndexListener.MessageContext(context, message, null));
  15.       }
  16.     }
  17.     return future;
  18.   } else {
  19.     return super.asyncAddQueueMessage(context, message);
  20.   }
  21. }

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

  1. info.beforeMarshall(wireFormat);
  2. looseMarshalCachedObject(wireFormat, (DataStructure)info.getTransactionId(), dataOut);
  3. looseMarshalCachedObject(wireFormat, (DataStructure)info.getOriginalDestination(), dataOut);
  4. looseMarshalNestedObject(wireFormat, (DataStructure)info.getMessageId(), dataOut);
  5. looseMarshalCachedObject(wireFormat, (DataStructure)info.getOriginalTransactionId(), dataOut);
  6. looseMarshalString(info.getGroupID(), dataOut);
  7. looseMarshalString(info.getCorrelationId(), dataOut);
  8. dataOut.writeBoolean(info.isPersistent());
  9. looseMarshalLong(wireFormat, info.getExpiration(), dataOut);
  10. dataOut.writeByte(info.getPriority());
  11. looseMarshalNestedObject(wireFormat, (DataStructure)info.getReplyTo(), dataOut);
  12. looseMarshalLong(wireFormat, info.getTimestamp(), dataOut);
  13. looseMarshalString(info.getType(), dataOut);
  14. looseMarshalByteSequence(wireFormat, info.getContent(), dataOut);

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

  1. @Override
  2. public ListenableFuture<Object> asyncAddQueueMessage(final ConnectionContext context, final Message message)
  3.     throws IOException {
  4.   if (isConcurrentStoreAndDispatchQueues()) {
  5.     message.beforeMarshall(wireFormat);
  6.     StoreQueueTask result = new StoreQueueTask(this, context, message);
  7.     ListenableFuture<Object> future = result.getFuture();
  8.     message.getMessageId().setFutureOrSequenceLong(future);
  9.     message.setRecievedByDFBridge(true); // flag message as concurrentStoreAndDispatch
  10.     result.aquireLocks();
  11.     synchronized (asyncTaskMap) {
  12.       addQueueTask(this, result);
  13.       if (indexListener != null) {
  14.         indexListener.onAdd(new IndexListener.MessageContext(context, message, null));
  15.       }
  16.     }
  17.     return future;
  18.   } else {
  19.     return super.asyncAddQueueMessage(context, message);
  20.   }
  21. }

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

  1. info.beforeMarshall(wireFormat);
  2. looseMarshalCachedObject(wireFormat, (DataStructure)info.getTransactionId(), dataOut);
  3. looseMarshalCachedObject(wireFormat, (DataStructure)info.getOriginalDestination(), dataOut);
  4. looseMarshalNestedObject(wireFormat, (DataStructure)info.getMessageId(), dataOut);
  5. looseMarshalCachedObject(wireFormat, (DataStructure)info.getOriginalTransactionId(), dataOut);
  6. looseMarshalString(info.getGroupID(), dataOut);
  7. looseMarshalString(info.getCorrelationId(), dataOut);
  8. dataOut.writeBoolean(info.isPersistent());
  9. looseMarshalLong(wireFormat, info.getExpiration(), dataOut);
  10. dataOut.writeByte(info.getPriority());
  11. looseMarshalNestedObject(wireFormat, (DataStructure)info.getReplyTo(), dataOut);
  12. looseMarshalLong(wireFormat, info.getTimestamp(), dataOut);
  13. looseMarshalString(info.getType(), dataOut);
  14. looseMarshalByteSequence(wireFormat, info.getContent(), dataOut);

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

  1. info.beforeMarshall(wireFormat);
  2. looseMarshalCachedObject(wireFormat, (DataStructure)info.getTransactionId(), dataOut);
  3. looseMarshalCachedObject(wireFormat, (DataStructure)info.getOriginalDestination(), dataOut);
  4. looseMarshalNestedObject(wireFormat, (DataStructure)info.getMessageId(), dataOut);
  5. looseMarshalCachedObject(wireFormat, (DataStructure)info.getOriginalTransactionId(), dataOut);
  6. looseMarshalString(info.getGroupID(), dataOut);
  7. looseMarshalString(info.getCorrelationId(), dataOut);
  8. dataOut.writeBoolean(info.isPersistent());
  9. looseMarshalLong(wireFormat, info.getExpiration(), dataOut);
  10. dataOut.writeByte(info.getPriority());
  11. looseMarshalNestedObject(wireFormat, (DataStructure)info.getReplyTo(), dataOut);
  12. looseMarshalLong(wireFormat, info.getTimestamp(), dataOut);
  13. looseMarshalString(info.getType(), dataOut);
  14. looseMarshalByteSequence(wireFormat, info.getContent(), dataOut);

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

  1. info.beforeMarshall(wireFormat);
  2. looseMarshalCachedObject(wireFormat, (DataStructure)info.getTransactionId(), dataOut);
  3. looseMarshalCachedObject(wireFormat, (DataStructure)info.getOriginalDestination(), dataOut);
  4. looseMarshalNestedObject(wireFormat, (DataStructure)info.getMessageId(), dataOut);
  5. looseMarshalCachedObject(wireFormat, (DataStructure)info.getOriginalTransactionId(), dataOut);
  6. looseMarshalString(info.getGroupID(), dataOut);
  7. looseMarshalString(info.getCorrelationId(), dataOut);
  8. dataOut.writeBoolean(info.isPersistent());
  9. looseMarshalLong(wireFormat, info.getExpiration(), dataOut);
  10. dataOut.writeByte(info.getPriority());
  11. looseMarshalNestedObject(wireFormat, (DataStructure)info.getReplyTo(), dataOut);
  12. looseMarshalLong(wireFormat, info.getTimestamp(), dataOut);
  13. looseMarshalString(info.getType(), dataOut);
  14. looseMarshalByteSequence(wireFormat, info.getContent(), dataOut);

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

  1. info.beforeMarshall(wireFormat);
  2. looseMarshalCachedObject(wireFormat, (DataStructure)info.getTransactionId(), dataOut);
  3. looseMarshalCachedObject(wireFormat, (DataStructure)info.getOriginalDestination(), dataOut);
  4. looseMarshalNestedObject(wireFormat, (DataStructure)info.getMessageId(), dataOut);
  5. looseMarshalCachedObject(wireFormat, (DataStructure)info.getOriginalTransactionId(), dataOut);
  6. looseMarshalString(info.getGroupID(), dataOut);
  7. looseMarshalString(info.getCorrelationId(), dataOut);
  8. dataOut.writeBoolean(info.isPersistent());
  9. looseMarshalLong(wireFormat, info.getExpiration(), dataOut);
  10. dataOut.writeByte(info.getPriority());
  11. looseMarshalNestedObject(wireFormat, (DataStructure)info.getReplyTo(), dataOut);
  12. looseMarshalLong(wireFormat, info.getTimestamp(), dataOut);
  13. looseMarshalString(info.getType(), dataOut);
  14. looseMarshalByteSequence(wireFormat, info.getContent(), dataOut);

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

  1. info.beforeMarshall(wireFormat);
  2. looseMarshalCachedObject(wireFormat, (DataStructure)info.getTransactionId(), dataOut);
  3. looseMarshalCachedObject(wireFormat, (DataStructure)info.getOriginalDestination(), dataOut);
  4. looseMarshalNestedObject(wireFormat, (DataStructure)info.getMessageId(), dataOut);
  5. looseMarshalCachedObject(wireFormat, (DataStructure)info.getOriginalTransactionId(), dataOut);
  6. looseMarshalString(info.getGroupID(), dataOut);
  7. looseMarshalString(info.getCorrelationId(), dataOut);
  8. dataOut.writeBoolean(info.isPersistent());
  9. looseMarshalLong(wireFormat, info.getExpiration(), dataOut);
  10. dataOut.writeByte(info.getPriority());
  11. looseMarshalNestedObject(wireFormat, (DataStructure)info.getReplyTo(), dataOut);
  12. looseMarshalLong(wireFormat, info.getTimestamp(), dataOut);
  13. looseMarshalString(info.getType(), dataOut);
  14. looseMarshalByteSequence(wireFormat, info.getContent(), dataOut);

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

  1. info.beforeMarshall(wireFormat);
  2. looseMarshalCachedObject(wireFormat, (DataStructure)info.getTransactionId(), dataOut);
  3. looseMarshalCachedObject(wireFormat, (DataStructure)info.getOriginalDestination(), dataOut);
  4. looseMarshalNestedObject(wireFormat, (DataStructure)info.getMessageId(), dataOut);
  5. looseMarshalCachedObject(wireFormat, (DataStructure)info.getOriginalTransactionId(), dataOut);
  6. looseMarshalString(info.getGroupID(), dataOut);
  7. looseMarshalString(info.getCorrelationId(), dataOut);
  8. dataOut.writeBoolean(info.isPersistent());
  9. looseMarshalLong(wireFormat, info.getExpiration(), dataOut);
  10. dataOut.writeByte(info.getPriority());
  11. looseMarshalNestedObject(wireFormat, (DataStructure)info.getReplyTo(), dataOut);
  12. looseMarshalLong(wireFormat, info.getTimestamp(), dataOut);
  13. looseMarshalString(info.getType(), dataOut);
  14. looseMarshalByteSequence(wireFormat, info.getContent(), dataOut);

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

  1. info.beforeMarshall(wireFormat);
  2. rc += tightMarshalCachedObject1(wireFormat, (DataStructure)info.getTransactionId(), bs);
  3. rc += tightMarshalCachedObject1(wireFormat, (DataStructure)info.getOriginalDestination(), bs);
  4. rc += tightMarshalNestedObject1(wireFormat, (DataStructure)info.getMessageId(), bs);
  5. rc += tightMarshalCachedObject1(wireFormat, (DataStructure)info.getOriginalTransactionId(), bs);
  6. rc += tightMarshalString1(info.getGroupID(), bs);
  7. rc += tightMarshalString1(info.getCorrelationId(), bs);
  8. bs.writeBoolean(info.isPersistent());
  9. rc += tightMarshalLong1(wireFormat, info.getExpiration(), bs);
  10. rc += tightMarshalNestedObject1(wireFormat, (DataStructure)info.getReplyTo(), bs);
  11. rc += tightMarshalLong1(wireFormat, info.getTimestamp(), bs);
  12. rc += tightMarshalString1(info.getType(), bs);
  13. rc += tightMarshalByteSequence1(info.getContent(), bs);

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

  1. info.beforeMarshall(wireFormat);
  2. rc += tightMarshalCachedObject1(wireFormat, (DataStructure)info.getTransactionId(), bs);
  3. rc += tightMarshalCachedObject1(wireFormat, (DataStructure)info.getOriginalDestination(), bs);
  4. rc += tightMarshalNestedObject1(wireFormat, (DataStructure)info.getMessageId(), bs);
  5. rc += tightMarshalCachedObject1(wireFormat, (DataStructure)info.getOriginalTransactionId(), bs);
  6. rc += tightMarshalString1(info.getGroupID(), bs);
  7. rc += tightMarshalString1(info.getCorrelationId(), bs);
  8. bs.writeBoolean(info.isPersistent());
  9. rc += tightMarshalLong1(wireFormat, info.getExpiration(), bs);
  10. rc += tightMarshalNestedObject1(wireFormat, (DataStructure)info.getReplyTo(), bs);
  11. rc += tightMarshalLong1(wireFormat, info.getTimestamp(), bs);
  12. rc += tightMarshalString1(info.getType(), bs);
  13. rc += tightMarshalByteSequence1(info.getContent(), bs);

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

  1. info.beforeMarshall(wireFormat);
  2. rc += tightMarshalCachedObject1(wireFormat, (DataStructure)info.getTransactionId(), bs);
  3. rc += tightMarshalCachedObject1(wireFormat, (DataStructure)info.getOriginalDestination(), bs);
  4. rc += tightMarshalNestedObject1(wireFormat, (DataStructure)info.getMessageId(), bs);
  5. rc += tightMarshalCachedObject1(wireFormat, (DataStructure)info.getOriginalTransactionId(), bs);
  6. rc += tightMarshalString1(info.getGroupID(), bs);
  7. rc += tightMarshalString1(info.getCorrelationId(), bs);
  8. bs.writeBoolean(info.isPersistent());
  9. rc+=tightMarshalLong1(wireFormat, info.getExpiration(), bs);
  10. rc += tightMarshalNestedObject1(wireFormat, (DataStructure)info.getReplyTo(), bs);
  11. rc+=tightMarshalLong1(wireFormat, info.getTimestamp(), bs);
  12. rc += tightMarshalString1(info.getType(), bs);
  13. rc += tightMarshalByteSequence1(info.getContent(), bs);

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

  1. info.beforeMarshall(wireFormat);
  2. rc += tightMarshalCachedObject1(wireFormat, (DataStructure)info.getTransactionId(), bs);
  3. rc += tightMarshalCachedObject1(wireFormat, (DataStructure)info.getOriginalDestination(), bs);
  4. rc += tightMarshalNestedObject1(wireFormat, (DataStructure)info.getMessageId(), bs);
  5. rc += tightMarshalCachedObject1(wireFormat, (DataStructure)info.getOriginalTransactionId(), bs);
  6. rc += tightMarshalString1(info.getGroupID(), bs);
  7. rc += tightMarshalString1(info.getCorrelationId(), bs);
  8. bs.writeBoolean(info.isPersistent());
  9. rc+=tightMarshalLong1(wireFormat, info.getExpiration(), bs);
  10. rc += tightMarshalNestedObject1(wireFormat, (DataStructure)info.getReplyTo(), bs);
  11. rc+=tightMarshalLong1(wireFormat, info.getTimestamp(), bs);
  12. rc += tightMarshalString1(info.getType(), bs);
  13. rc += tightMarshalByteSequence1(info.getContent(), bs);

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

  1. info.beforeMarshall(wireFormat);
  2. rc += tightMarshalCachedObject1(wireFormat, (DataStructure)info.getTransactionId(), bs);
  3. rc += tightMarshalCachedObject1(wireFormat, (DataStructure)info.getOriginalDestination(), bs);
  4. rc += tightMarshalNestedObject1(wireFormat, (DataStructure)info.getMessageId(), bs);
  5. rc += tightMarshalCachedObject1(wireFormat, (DataStructure)info.getOriginalTransactionId(), bs);
  6. rc += tightMarshalString1(info.getGroupID(), bs);
  7. rc += tightMarshalString1(info.getCorrelationId(), bs);
  8. bs.writeBoolean(info.isPersistent());
  9. rc+=tightMarshalLong1(wireFormat, info.getExpiration(), bs);
  10. rc += tightMarshalNestedObject1(wireFormat, (DataStructure)info.getReplyTo(), bs);
  11. rc+=tightMarshalLong1(wireFormat, info.getTimestamp(), bs);
  12. rc += tightMarshalString1(info.getType(), bs);
  13. rc += tightMarshalByteSequence1(info.getContent(), bs);

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

  1. info.beforeMarshall(wireFormat);
  2. rc += tightMarshalCachedObject1(wireFormat, (DataStructure)info.getTransactionId(), bs);
  3. rc += tightMarshalCachedObject1(wireFormat, (DataStructure)info.getOriginalDestination(), bs);
  4. rc += tightMarshalNestedObject1(wireFormat, (DataStructure)info.getMessageId(), bs);
  5. rc += tightMarshalCachedObject1(wireFormat, (DataStructure)info.getOriginalTransactionId(), bs);
  6. rc += tightMarshalString1(info.getGroupID(), bs);
  7. rc += tightMarshalString1(info.getCorrelationId(), bs);
  8. bs.writeBoolean(info.isPersistent());
  9. rc += tightMarshalLong1(wireFormat, info.getExpiration(), bs);
  10. rc += tightMarshalNestedObject1(wireFormat, (DataStructure)info.getReplyTo(), bs);
  11. rc += tightMarshalLong1(wireFormat, info.getTimestamp(), bs);
  12. rc += tightMarshalString1(info.getType(), bs);
  13. rc += tightMarshalByteSequence1(info.getContent(), bs);

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

Message

相关文章

    查看更多

    热门标签

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

    最新文章

    更多

    Message类方法

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