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

Message.putLongProperty介绍

暂无

代码示例

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

public static void setLongProperty(final Message message, final String name, final long value) {
 if (MessageUtil.JMSXGROUPSEQ.equals(name)) {
   message.setGroupSequence((int) value);
 } else {
   message.putLongProperty(name, value);
 }
}

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

public static void setLongProperty(final Message message, final String name, final long value) {
 if (MessageUtil.JMSXGROUPSEQ.equals(name)) {
   message.setGroupSequence((int) value);
 } else {
   message.putLongProperty(name, value);
 }
}

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

public static void setLongProperty(final Message message, final String name, final long value) {
 if (MessageUtil.JMSXGROUPSEQ.equals(name)) {
   message.setGroupSequence((int) value);
 } else {
   message.putLongProperty(name, value);
 }
}

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

long delay = Long.parseLong(scheduledDelay);
if (delay > 0) {
 msg.putLongProperty(HDR_SCHEDULED_DELIVERY_TIME, System.currentTimeMillis() + delay);
long deliveryTime = Long.parseLong(scheduledTime);
if (deliveryTime > 0) {
 msg.putLongProperty(HDR_SCHEDULED_DELIVERY_TIME, deliveryTime);

代码示例来源：origin: org.apache.activemq/artemis-stomp-protocol

long delay = Long.parseLong(scheduledDelay);
if (delay > 0) {
 msg.putLongProperty(HDR_SCHEDULED_DELIVERY_TIME, System.currentTimeMillis() + delay);
long deliveryTime = Long.parseLong(scheduledTime);
if (deliveryTime > 0) {
 msg.putLongProperty(HDR_SCHEDULED_DELIVERY_TIME, deliveryTime);

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

break;
case XmlDataConstants.PROPERTY_TYPE_LONG:
 message.putLongProperty(key, Long.parseLong(value));
 break;
case XmlDataConstants.PROPERTY_TYPE_SIMPLE_STRING:

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

break;
case XmlDataConstants.PROPERTY_TYPE_LONG:
 message.putLongProperty(key, Long.parseLong(value));
 break;
case XmlDataConstants.PROPERTY_TYPE_SIMPLE_STRING:

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

private Message createQueueInfoMessage(final NotificationType type, final SimpleString queueName) {
 Message message = new CoreMessage().initBuffer(50).setMessageID(storageManager.generateID());
 message.setAddress(queueName);
 String uid = UUIDGenerator.getInstance().generateStringUUID();
 message.putStringProperty(ManagementHelper.HDR_NOTIFICATION_TYPE, new SimpleString(type.toString()));
 message.putLongProperty(ManagementHelper.HDR_NOTIFICATION_TIMESTAMP, System.currentTimeMillis());
 message.putStringProperty(new SimpleString("foobar"), new SimpleString(uid));
 return message;
}

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

/**
* Prompt delivery and send a "forced delivery" message to the consumer.
* <p>
* When the consumer receives such a "forced delivery" message, it discards it and knows that
* there are no other messages to be delivered.
*/
@Override
public void forceDelivery(final long sequence)  {
 forceDelivery(sequence, () -> {
   Message forcedDeliveryMessage = new CoreMessage(storageManager.generateID(), 50);
   MessageReference reference = MessageReference.Factory.createReference(forcedDeliveryMessage, messageQueue);
   reference.setDeliveryCount(0);
   forcedDeliveryMessage.putLongProperty(ClientConsumerImpl.FORCED_DELIVERY_MESSAGE, sequence);
   forcedDeliveryMessage.setAddress(messageQueue.getName());
   applyPrefixForLegacyConsumer(forcedDeliveryMessage);
   callback.sendMessage(reference, forcedDeliveryMessage, ServerConsumerImpl.this, 0);
 });
}

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

notificationMessage.putLongProperty(ManagementHelper.HDR_NOTIFICATION_TIMESTAMP, System.currentTimeMillis());

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

message.putStringProperty(ManagementHelper.HDR_CLUSTER_NAME, info.getClusterName());
message.putStringProperty(ManagementHelper.HDR_ROUTING_NAME, info.getRoutingName());
message.putLongProperty(ManagementHelper.HDR_BINDING_ID, info.getID());
message.putStringProperty(ManagementHelper.HDR_FILTERSTRING, info.getFilterString());
message.putIntProperty(ManagementHelper.HDR_DISTANCE, info.getDistance());

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

msg.putLongProperty(prop7, val7);