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

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

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

Message.getPriority介绍

暂无

代码示例

代码示例来源：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. looseMarshalCachedObject(wireFormat, (DataStructure)info.getTargetConsumerId(), dataOut);
  17. dataOut.writeBoolean(info.isCompressed());
  18. dataOut.writeInt(info.getRedeliveryCounter());
  19. looseMarshalObjectArray(wireFormat, info.getBrokerPath(), dataOut);
  20. looseMarshalLong(wireFormat, info.getArrival(), dataOut);
  21. looseMarshalString(info.getUserID(), dataOut);
  22. dataOut.writeBoolean(info.isRecievedByDFBridge());

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

  1. @Override
  2. public void updateMessage(Message message) throws IOException {
  3.   if (LOG.isTraceEnabled()) {
  4.     LOG.trace("updating: " + message.getMessageId() + " with deliveryCount: " + message.getRedeliveryCounter());
  5.   }
  6.   KahaUpdateMessageCommand updateMessageCommand = new KahaUpdateMessageCommand();
  7.   KahaAddMessageCommand command = new KahaAddMessageCommand();
  8.   command.setDestination(dest);
  9.   command.setMessageId(message.getMessageId().toProducerKey());
  10.   command.setPriority(message.getPriority());
  11.   command.setPrioritySupported(prioritizedMessages);
  12.   org.apache.activemq.util.ByteSequence packet = wireFormat.marshal(message);
  13.   command.setMessage(new Buffer(packet.getData(), packet.getOffset(), packet.getLength()));
  14.   updateMessageCommand.setMessage(command);
  15.   store(updateMessageCommand, isEnableJournalDiskSyncs(), null, null);
  16. }

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

  1. @Override
  2. public void addMessage(final ConnectionContext context, final Message message) throws IOException {
  3.   MessageId messageId = message.getMessageId();
  4.   if (audit != null && audit.isDuplicate(message)) {
  5.     if (LOG.isDebugEnabled()) {
  6.     sequenceId = persistenceAdapter.getNextSequenceId();
  7.     final long sequence = sequenceId;
  8.     message.getMessageId().setEntryLocator(sequence);
  9.     adapter.doAddMessage(c, sequenceId, messageId, destination, data, message.getExpiration(),
  10.         this.isPrioritizedMessages() ? message.getPriority() : 0, xaXid);
  11.   } catch (SQLException e) {
  12.     JDBCPersistenceAdapter.log("JDBC Failure: ", e);
  13.     onAdd(message, sequenceId, message.getPriority());

代码示例来源：origin: io.fabric8.ipaas.apps/fabric8mq

  1. protected void populateInitialHeaders(Map<String, Object> map) {
  2.     Message message = null;
  3.     if (command.isMessage()) {
  4.       message = (Message) this.command;
  5.     }
  6.     if (command.isMessageDispatch()) {
  7.       message = ((MessageDispatch) command).getMessage();
  8.     }
  10.     if (message != null) {
  11.       map.put("JMSCorrelationID", message.getCorrelationId());
  12.       map.put("JMSDestination", message.getDestination());
  13.       map.put("JMSExpiration", message.getExpiration());
  14.       map.put("JMSMessageID", message.getMessageId().toString());
  15.       map.put("JMSPriority", message.getPriority());
  16.       map.put("JMSRedelivered", message.isRedelivered());
  17.       map.put("JMSTimestamp", message.getTimestamp());
  18.       map.put("JMSReplyTo", message.getReplyTo());
  19.       map.put("JMSType", message.getType());
  20.       map.put("JMSXGroupID", message.getGroupID());
  21.       map.put("JMSXGroupSeq", message.getGroupSequence());
  22.       map.put("JMSXUserID", message.getUserID());
  23.     }
  24.   }
  25. }

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

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

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

  1. 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. looseMarshalCachedObject(wireFormat, (DataStructure)info.getTargetConsumerId(), dataOut);
  17. dataOut.writeBoolean(info.isCompressed());
  18. dataOut.writeInt(info.getRedeliveryCounter());
  19. looseMarshalObjectArray(wireFormat, info.getBrokerPath(), dataOut);
  20. looseMarshalLong(wireFormat, info.getArrival(), dataOut);
  21. looseMarshalString(info.getUserID(), dataOut);
  22. dataOut.writeBoolean(info.isRecievedByDFBridge());

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

  1. public void addMessage(ConnectionContext context, Message message) throws IOException {
  2.   MessageId messageId = message.getMessageId();
  3.   if (audit != null && audit.isDuplicate(message)) {
  4.     if (LOG.isDebugEnabled()) {
  5.     adapter.doAddMessage(c,sequenceId, messageId, destination, data, message.getExpiration(), message.getPriority());
  6.   } catch (SQLException e) {
  7.     JDBCPersistenceAdapter.log("JDBC Failure: ", e);
  8.     c.close();
  9.   onAdd(sequenceId, message.getPriority());

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

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

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

  1. @Override
  2. public void updateMessage(Message message) throws IOException {
  3.   if (LOG.isTraceEnabled()) {
  4.     LOG.trace("updating: " + message.getMessageId() + " with deliveryCount: " + message.getRedeliveryCounter());
  5.   }
  6.   KahaUpdateMessageCommand updateMessageCommand = new KahaUpdateMessageCommand();
  7.   KahaAddMessageCommand command = new KahaAddMessageCommand();
  8.   command.setDestination(dest);
  9.   command.setMessageId(message.getMessageId().toProducerKey());
  10.   command.setPriority(message.getPriority());
  11.   command.setPrioritySupported(prioritizedMessages);
  12.   org.apache.activemq.util.ByteSequence packet = wireFormat.marshal(message);
  13.   command.setMessage(new Buffer(packet.getData(), packet.getOffset(), packet.getLength()));
  14.   updateMessageCommand.setMessage(command);
  15.   store(updateMessageCommand, isEnableJournalDiskSyncs(), null, null);
  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. looseMarshalCachedObject(wireFormat, (DataStructure)info.getTargetConsumerId(), dataOut);
  17. dataOut.writeBoolean(info.isCompressed());
  18. dataOut.writeInt(info.getRedeliveryCounter());
  19. looseMarshalObjectArray(wireFormat, info.getBrokerPath(), dataOut);
  20. looseMarshalLong(wireFormat, info.getArrival(), dataOut);
  21. looseMarshalString(info.getUserID(), dataOut);
  22. dataOut.writeBoolean(info.isRecievedByDFBridge());

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

  1. @Override
  2. public void addMessage(final ConnectionContext context, final Message message) throws IOException {
  3.   MessageId messageId = message.getMessageId();
  4.   if (audit != null && audit.isDuplicate(message)) {
  5.     if (LOG.isDebugEnabled()) {
  6.     sequenceId = persistenceAdapter.getNextSequenceId();
  7.     final long sequence = sequenceId;
  8.     message.getMessageId().setEntryLocator(sequence);
  9.     adapter.doAddMessage(c, sequenceId, messageId, destination, data, message.getExpiration(),
  10.         this.isPrioritizedMessages() ? message.getPriority() : 0, xaXid);
  11.   } catch (SQLException e) {
  12.     JDBCPersistenceAdapter.log("JDBC Failure: ", e);
  13.     onAdd(message, sequenceId, message.getPriority());

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

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

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

  1. @Override
  2. public void updateMessage(Message message) throws IOException {
  3.   if (LOG.isTraceEnabled()) {
  4.     LOG.trace("updating: " + message.getMessageId() + " with deliveryCount: " + message.getRedeliveryCounter());
  5.   }
  6.   KahaUpdateMessageCommand updateMessageCommand = new KahaUpdateMessageCommand();
  7.   KahaAddMessageCommand command = new KahaAddMessageCommand();
  8.   command.setDestination(dest);
  9.   command.setMessageId(message.getMessageId().toProducerKey());
  10.   command.setPriority(message.getPriority());
  11.   command.setPrioritySupported(prioritizedMessages);
  12.   org.apache.activemq.util.ByteSequence packet = wireFormat.marshal(message);
  13.   command.setMessage(new Buffer(packet.getData(), packet.getOffset(), packet.getLength()));
  14.   updateMessageCommand.setMessage(command);
  15.   store(updateMessageCommand, isEnableJournalDiskSyncs(), null, null);
  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. looseMarshalCachedObject(wireFormat, (DataStructure)info.getTargetConsumerId(), dataOut);
  17. dataOut.writeBoolean(info.isCompressed());
  18. dataOut.writeInt(info.getRedeliveryCounter());
  19. looseMarshalObjectArray(wireFormat, info.getBrokerPath(), dataOut);
  20. looseMarshalLong(wireFormat, info.getArrival(), dataOut);
  21. looseMarshalString(info.getUserID(), dataOut);
  22. dataOut.writeBoolean(info.isRecievedByDFBridge());

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

  1. @Override
  2. public void addMessage(final ConnectionContext context, final Message message) throws IOException {
  3.   MessageId messageId = message.getMessageId();
  4.   if (audit != null && audit.isDuplicate(message)) {
  5.     if (LOG.isDebugEnabled()) {
  6.     sequenceId = persistenceAdapter.getNextSequenceId();
  7.     final long sequence = sequenceId;
  8.     message.getMessageId().setEntryLocator(sequence);
  9.     adapter.doAddMessage(c, sequenceId, messageId, destination, data, message.getExpiration(),
  10.         this.isPrioritizedMessages() ? message.getPriority() : 0, xaXid);
  11.   } catch (SQLException e) {
  12.     JDBCPersistenceAdapter.log("JDBC Failure: ", e);
  13.     onAdd(message, sequenceId, message.getPriority());

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

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

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

  1. @Override
  2. public void updateMessage(Message message) throws IOException {
  3.   if (LOG.isTraceEnabled()) {
  4.     LOG.trace("updating: " + message.getMessageId() + " with deliveryCount: " + message.getRedeliveryCounter());
  5.   }
  6.   KahaUpdateMessageCommand updateMessageCommand = new KahaUpdateMessageCommand();
  7.   KahaAddMessageCommand command = new KahaAddMessageCommand();
  8.   command.setDestination(dest);
  9.   command.setMessageId(message.getMessageId().toProducerKey());
  10.   command.setPriority(message.getPriority());
  11.   command.setPrioritySupported(prioritizedMessages);
  12.   org.apache.activemq.util.ByteSequence packet = wireFormat.marshal(message);
  13.   command.setMessage(new Buffer(packet.getData(), packet.getOffset(), packet.getLength()));
  14.   updateMessageCommand.setMessage(command);
  15.   store(updateMessageCommand, isEnableJournalDiskSyncs(), null, null);
  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. looseMarshalCachedObject(wireFormat, (DataStructure)info.getTargetConsumerId(), dataOut);
  17. dataOut.writeBoolean(info.isCompressed());
  18. dataOut.writeInt(info.getRedeliveryCounter());
  19. looseMarshalObjectArray(wireFormat, info.getBrokerPath(), dataOut);
  20. looseMarshalLong(wireFormat, info.getArrival(), dataOut);
  21. looseMarshalString(info.getUserID(), dataOut);
  22. dataOut.writeBoolean(info.isRecievedByDFBridge());

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

  1. @Override
  2. public void addMessage(final ConnectionContext context, final Message message) throws IOException {
  3.   MessageId messageId = message.getMessageId();
  4.   if (audit != null && audit.isDuplicate(message)) {
  5.     if (LOG.isDebugEnabled()) {
  6.     sequenceId = persistenceAdapter.getNextSequenceId();
  7.     final long sequence = sequenceId;
  8.     message.getMessageId().setEntryLocator(sequence);
  9.     adapter.doAddMessage(c, sequenceId, messageId, destination, data, message.getExpiration(),
  10.         this.isPrioritizedMessages() ? message.getPriority() : 0, xaXid);
  11.   } catch (SQLException e) {
  12.     JDBCPersistenceAdapter.log("JDBC Failure: ", e);
  13.     onAdd(message, sequenceId, message.getPriority());

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

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

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

Message

相关文章

    查看更多

    热门标签

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

    最新文章

    更多

    Message类方法

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