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

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

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

Message.isPersistent介绍

暂无

代码示例

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

  1. @Override
  2. public boolean isSendToDeadLetterQueue(Message message) {
  3.   boolean result = false;
  4.   if (message != null) {
  5.     result = true;
  6.     if (enableAudit && messageAudit.isDuplicate(message)) {
  7.       result = false;
  8.       LOG.debug("Not adding duplicate to DLQ: {}, dest: {}", message.getMessageId(), message.getDestination());
  9.     }
  10.     if (!message.isPersistent() && !processNonPersistent) {
  11.       result = false;
  12.     }
  13.     if (message.isExpired() && !processExpired) {
  14.       result = false;
  15.     }
  16.   }
  17.   return result;
  18. }

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

  1. private LocalTransactionId beginLocalTransaction(int numDestinations, ConnectionContext connectionContext, Message message) throws Exception {
  2.   LocalTransactionId result = null;
  3.   if (transactedSend && numDestinations > 1 && message.isPersistent() && message.getTransactionId() == null) {
  4.     result = new LocalTransactionId(new ConnectionId(message.getMessageId().getProducerId().toString()), message.getMessageId().getProducerSequenceId());
  5.     connectionContext.getBroker().beginTransaction(connectionContext, result);
  6.     connectionContext.setTransaction(connectionContext.getTransactions().get(result));
  7.     message.setTransactionId(result);
  8.   }
  9.   return result;
  10. }

代码示例来源：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. if (!msg.isPersistent()) {
  2.   if (isSendAdvisoryIfNoConsumers()) {
  3.       if (message.getOriginalDestination() != null) {
  4.         message.setOriginalDestination(message.getDestination());
  5.       if (message.getOriginalTransactionId() != null) {
  6.         message.setOriginalTransactionId(message.getTransactionId());

代码示例来源：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)) {
  6.   if (message.isPersistent() || configuration.isAlwaysSyncSend()) {

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

  1. final String type = messageSend.getType();
  2. if (type != null) {
  3.   coreMessage.putStringProperty(JMS_TYPE_PROPERTY, new SimpleString(type));
  4. coreMessage.setDurable(messageSend.isPersistent());
  5. coreMessage.setExpiration(messageSend.getExpiration());
  6. coreMessage.setPriority(messageSend.getPriority());
  7. final BrokerId[] brokers = messageSend.getBrokerPath();
  8. if (brokers != null) {
  9.   putMsgBrokerPath(brokers, coreMessage);
  10. final MessageId messageId = messageSend.getMessageId();
  11. coreMessage.putBytesProperty(AMQ_MSG_MESSAGE_ID, midBytes.data);
  12. final ProducerId producerId = messageSend.getProducerId();
  13. if (producerId != null) {
  14.   final ByteSequence producerIdBytes = marshaller.marshal(producerId);
  15. final ActiveMQDestination origDest = messageSend.getOriginalDestination();
  16. if (origDest != null) {
  17.   putMsgOriginalDestination(origDest, marshaller, coreMessage);

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

  1. throws IOException, Exception {
  2. final ConnectionContext context = producerExchange.getConnectionContext();
  3. message.getMessageId().setBrokerSequenceId(getDestinationSequenceId());
  4. Future<Object> result = null;
  5. if (topicStore != null && message.isPersistent() && !canOptimizeOutPersistence()) {
  6.   if (systemUsage.getStoreUsage().isFull(getStoreUsageHighWaterMark())) {
  7.     final String logMessage = "Persistent store is Full, " + getStoreUsageHighWaterMark() + "% of "
  8.         + systemUsage.getStoreUsage().getLimit() + ". Stopping producer (" + message.getProducerId()
  9.         + ") to prevent flooding " + getActiveMQDestination().getQualifiedName() + "."
  10.         + " See http://activemq.apache.org/producer-flow-control.html for more info";

代码示例来源：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. if (!msg.isPersistent()) {
  2.   if (isSendAdvisoryIfNoConsumers()) {
  3.       if (message.getOriginalDestination() != null) {
  4.         message.setOriginalDestination(message.getDestination());
  5.       if (message.getOriginalTransactionId() != null) {
  6.         message.setOriginalTransactionId(message.getTransactionId());

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

  1. ActiveMQDestination deadLetterDestination = deadLetterStrategy.getDeadLetterQueueFor(message, subscription);
  2.   if (deadLetterDestination.equals(message.getDestination())) {
  3.     LOG.debug("Not re-adding to DLQ: {}, dest: {}", message.getMessageId(), message.getDestination());
  4.     return false;
  5.   if (!message.isPersistent()) {
  6.     message.setPersistent(true);
  7.     message.setProperty("originalDeliveryMode", "NON_PERSISTENT");
  8. LOG.debug("Dead Letter message with no DLQ strategy in place, message id: {}, destination: {}", message.getMessageId(), message.getDestination());

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

  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)) {
  6.   if (message.isPersistent() || configuration.isAlwaysSyncSend()) {

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

  1. throws IOException, Exception {
  2. final ConnectionContext context = producerExchange.getConnectionContext();
  3. message.getMessageId().setBrokerSequenceId(getDestinationSequenceId());
  4. Future<Object> result = null;
  5. if (topicStore != null && message.isPersistent() && !canOptimizeOutPersistence()) {
  6.   if (systemUsage.getStoreUsage().isFull(getStoreUsageHighWaterMark())) {
  7.     final String logMessage = "Persistent store is Full, " + getStoreUsageHighWaterMark() + "% of "
  8.         + systemUsage.getStoreUsage().getLimit() + ". Stopping producer (" + message.getProducerId()
  9.         + ") to prevent flooding " + getActiveMQDestination().getQualifiedName() + "."
  10.         + " See http://activemq.apache.org/producer-flow-control.html for more info";

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

  1. private LocalTransactionId beginLocalTransaction(int numDestinations, ConnectionContext connectionContext, Message message) throws Exception {
  2.   LocalTransactionId result = null;
  3.   if (transactedSend && numDestinations > 1 && message.isPersistent() && message.getTransactionId() == null) {
  4.     result = new LocalTransactionId(new ConnectionId(message.getMessageId().getProducerId().toString()), message.getMessageId().getProducerSequenceId());
  5.     connectionContext.getBroker().beginTransaction(connectionContext, result);
  6.     connectionContext.setTransaction(connectionContext.getTransactions().get(result));
  7.     message.setTransactionId(result);
  8.   }
  9.   return result;
  10. }

代码示例来源：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. if (!msg.isPersistent()) {
  2.   if (isSendAdvisoryIfNoConsumers()) {
  3.       if (message.getOriginalDestination() != null) {
  4.         message.setOriginalDestination(message.getDestination());
  5.       if (message.getOriginalTransactionId() != null) {
  6.         message.setOriginalTransactionId(message.getTransactionId());

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

  1. message.incrementRedeliveryCounter();
  2. try {
  3.   if (message.isPersistent()) {
  4.     ((BaseDestination) message.getRegionDestination()).getMessageStore().updateMessage(message);
  5.   RuntimeException runtimeException = new RuntimeException("Failed to persist JMSRedeliveryFlag on " + message.getMessageId() + " in " + message.getDestination(), error);
  6.   LOG.warn(runtimeException.getLocalizedMessage(), runtimeException);
  7.   throw runtimeException;

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

  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)) {
  6.   if (message.isPersistent() || configuration.isAlwaysSyncSend()) {

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

  1. throws IOException, Exception {
  2. final ConnectionContext context = producerExchange.getConnectionContext();
  3. message.getMessageId().setBrokerSequenceId(getDestinationSequenceId());
  4. Future<Object> result = null;
  5. if (topicStore != null && message.isPersistent() && !canOptimizeOutPersistence()) {
  6.   if (systemUsage.getStoreUsage().isFull(getStoreUsageHighWaterMark())) {
  7.     final String logMessage = "Persistent store is Full, " + getStoreUsageHighWaterMark() + "% of "
  8.         + systemUsage.getStoreUsage().getLimit() + ". Stopping producer (" + message.getProducerId()
  9.         + ") to prevent flooding " + getActiveMQDestination().getQualifiedName() + "."
  10.         + " See http://activemq.apache.org/producer-flow-control.html for more info";

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

  1. private LocalTransactionId beginLocalTransaction(int numDestinations, ConnectionContext connectionContext, Message message) throws Exception {
  2.   LocalTransactionId result = null;
  3.   if (transactedSend && numDestinations > 1 && message.isPersistent() && message.getTransactionId() == null) {
  4.     result = new LocalTransactionId(new ConnectionId(message.getMessageId().getProducerId().toString()), message.getMessageId().getProducerSequenceId());
  5.     connectionContext.getBroker().beginTransaction(connectionContext, result);
  6.     connectionContext.setTransaction(connectionContext.getTransactions().get(result));
  7.     message.setTransactionId(result);
  8.   }
  9.   return result;
  10. }

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

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

Message

相关文章

    查看更多

    热门标签

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

    最新文章

    更多

    Message类方法

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