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

Message.putIntProperty介绍

暂无

代码示例

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

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

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

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

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

public static Message createPubRelMessage(MQTTSession session, SimpleString address, int messageId) {
 Message message = createServerMessage(session, address, false, 1);
 message.putIntProperty(MQTTUtil.MQTT_MESSAGE_ID_KEY, messageId);
 message.putIntProperty(MQTTUtil.MQTT_MESSAGE_TYPE_KEY, MqttMessageType.PUBREL.value());
 return message;
}

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

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

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

public static Message createPubRelMessage(MQTTSession session, SimpleString address, int messageId) {
 Message message = createServerMessage(session, address, false, 1);
 message.putIntProperty(MQTTUtil.MQTT_MESSAGE_ID_KEY, messageId);
 message.putIntProperty(MQTTUtil.MQTT_MESSAGE_TYPE_KEY, MqttMessageType.PUBREL.value());
 return message;
}

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

break;
case XmlDataConstants.PROPERTY_TYPE_INTEGER:
 message.putIntProperty(key, Integer.parseInt(value));
 break;
case XmlDataConstants.PROPERTY_TYPE_LONG:

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

@Override
public boolean intercept(final Packet packet, final RemotingConnection connection) throws ActiveMQException {
  if (packet.getType() == PacketImpl.SESS_SEND) {
   SessionSendMessage p = (SessionSendMessage) packet;
   Message sm = p.getMessage();
   sm.putIntProperty(key, num);
   wasCalled = true;
   return !reject;
  }
  return true;
}

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

break;
case XmlDataConstants.PROPERTY_TYPE_INTEGER:
 message.putIntProperty(key, Integer.parseInt(value));
 break;
case XmlDataConstants.PROPERTY_TYPE_LONG:

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

@Override
public boolean intercept(final Packet packet, final RemotingConnection connection) throws ActiveMQException {
  if (isForceDeliveryResponse(packet)) {
   return true;
  }
  if (packet.getType() == PacketImpl.SESS_RECEIVE_MSG) {
   SessionReceiveMessage p = (SessionReceiveMessage) packet;
   Message sm = p.getMessage();
   sm.putIntProperty(key, num);
   wasCalled = true;
   return !reject;
  }
  return true;
}

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

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

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

msg.putIntProperty(prop6, val6);
msg.putIntProperty(prop9, val11);
Assert.assertEquals(val11, msg.getObjectProperty(prop9));

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

Message clientFile = createLargeClientMessageStreaming(session, messageSize, true);
clientFile.putIntProperty("value", i);

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

clientFile.putIntProperty("txid", 1);
producer.send(clientFile);
clientFile.putIntProperty("txid", 2);
clientFile.putIntProperty("i", i);
producer.send(clientFile);