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

Message.putBytesProperty介绍

暂无

代码示例

代码示例来源：origin: wildfly/wildfly

default org.apache.activemq.artemis.api.core.Message putExtraBytesProperty(SimpleString key, byte[] value) {
 return putBytesProperty(key, value);
}

代码示例来源：origin: wildfly/wildfly

public static final void setJMSCorrelationIDAsBytes(Message message,
                          final byte[] correlationID) throws ActiveMQException {
 if (correlationID == null || correlationID.length == 0) {
   throw new ActiveMQException("Please specify a non-zero length byte[]");
 }
 message.putBytesProperty(CORRELATIONID_HEADER_NAME, correlationID);
}

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

default org.apache.activemq.artemis.api.core.Message putExtraBytesProperty(SimpleString key, byte[] value) {
 return putBytesProperty(key, value);
}

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

default org.apache.activemq.artemis.api.core.Message putExtraBytesProperty(SimpleString key, byte[] value) {
 return putBytesProperty(key, value);
}

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

default org.apache.activemq.artemis.api.core.Message putExtraBytesProperty(SimpleString key, byte[] value) {
 return putBytesProperty(key, value);
}

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

default org.apache.activemq.artemis.api.core.Message putExtraBytesProperty(SimpleString key, byte[] value) {
 return putBytesProperty(key, value);
}

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

default org.apache.activemq.artemis.api.core.Message putExtraBytesProperty(SimpleString key, byte[] value) {
 return putBytesProperty(key, value);
}

代码示例来源：origin: org.jboss.eap/wildfly-client-all

default org.apache.activemq.artemis.api.core.Message putExtraBytesProperty(SimpleString key, byte[] value) {
 return putBytesProperty(key, value);
}

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

public static final void setJMSCorrelationIDAsBytes(Message message,
                          final byte[] correlationID) throws ActiveMQException {
 if (correlationID == null || correlationID.length == 0) {
   throw new ActiveMQException("Please specify a non-zero length byte[]");
 }
 message.putBytesProperty(CORRELATIONID_HEADER_NAME, correlationID);
}

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

public static final void setJMSCorrelationIDAsBytes(Message message,
                          final byte[] correlationID) throws ActiveMQException {
 if (correlationID == null || correlationID.length == 0) {
   throw new ActiveMQException("Please specify a non-zero length byte[]");
 }
 message.putBytesProperty(CORRELATIONID_HEADER_NAME, correlationID);
}

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

public static final void setJMSCorrelationIDAsBytes(Message message,
                          final byte[] correlationID) throws ActiveMQException {
 if (correlationID == null || correlationID.length == 0) {
   throw new ActiveMQException("Please specify a non-zero length byte[]");
 }
 message.putBytesProperty(CORRELATIONID_HEADER_NAME, correlationID);
}

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

public static final void setJMSCorrelationIDAsBytes(Message message,
                          final byte[] correlationID) throws ActiveMQException {
 if (correlationID == null || correlationID.length == 0) {
   throw new ActiveMQException("Please specify a non-zero length byte[]");
 }
 message.putBytesProperty(CORRELATIONID_HEADER_NAME, correlationID);
}

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

public static final void setJMSCorrelationIDAsBytes(Message message,
                          final byte[] correlationID) throws ActiveMQException {
 if (correlationID == null || correlationID.length == 0) {
   throw new ActiveMQException("Please specify a non-zero length byte[]");
 }
 message.putBytesProperty(CORRELATIONID_HEADER_NAME, correlationID);
}

代码示例来源：origin: org.jboss.eap/wildfly-client-all

public static final void setJMSCorrelationIDAsBytes(Message message,
                          final byte[] correlationID) throws ActiveMQException {
 if (correlationID == null || correlationID.length == 0) {
   throw new ActiveMQException("Please specify a non-zero length byte[]");
 }
 message.putBytesProperty(CORRELATIONID_HEADER_NAME, correlationID);
}

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

message.putBytesProperty(Message.HDR_ROUTE_TO_IDS, buffer.array());
try (ClientProducer producer = session.createProducer(destination)) {
  producer.send(message);

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

message.putBytesProperty(Message.HDR_ROUTE_TO_IDS, buffer.array());
try (ClientProducer producer = session.createProducer(destination)) {
  producer.send(message);

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

private void move(final SimpleString toAddress,
         final Transaction tx,
         final MessageReference ref,
         final boolean expiry,
         final boolean rejectDuplicate,
         final long... queueIDs) throws Exception {
 Message copyMessage = makeCopy(ref, expiry);
 copyMessage.setAddress(toAddress);
 if (queueIDs != null && queueIDs.length > 0) {
   ByteBuffer buffer = ByteBuffer.allocate(8 * queueIDs.length);
   for (long id : queueIDs) {
    buffer.putLong(id);
   }
   copyMessage.putBytesProperty(Message.HDR_ROUTE_TO_IDS.toString(), buffer.array());
 }
 postOffice.route(copyMessage, tx, false, rejectDuplicate);
 if (expiry) {
   acknowledge(tx, ref, AckReason.EXPIRED, null);
 } else {
   acknowledge(tx, ref);
 }
}

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

break;
case XmlDataConstants.PROPERTY_TYPE_BYTES:
 message.putBytesProperty(key, value == null ? null : decode(value));
 break;
case XmlDataConstants.PROPERTY_TYPE_DOUBLE:

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

message.putBytesProperty(Message.HDR_ROUTE_TO_IDS.toString(), oldRouteToIDs);
} else {
 message.putBytesProperty(Message.HDR_SCALEDOWN_TO_IDS.toString(), oldRouteToIDs);

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

clientFile.putBytesProperty(Message.HDR_BRIDGE_DUPLICATE_ID, someDuplicateInfo.getBytes());
} else {
  clientFile.putBytesProperty(Message.HDR_DUPLICATE_DETECTION_ID, someDuplicateInfo.getBytes());