javax.jms.Message.getJMSCorrelationIDAsBytes()方法的使用及代码示例

x33g5p2x  于2022-01-24 转载在 其他  
字(7.3k)|赞(0)|评价(0)|浏览(242)

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

Message.getJMSCorrelationIDAsBytes介绍

[英]Gets the correlation ID as an array of bytes for the message.

The use of a byte[] value for JMSCorrelationID is non-portable.
[中]获取相关ID作为消息的字节数组。
JMSCorrelationID使用byte[]值是不可移植的。

代码示例

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

  1. byte[] corrIDBytes = foreign.getJMSCorrelationIDAsBytes();
  2.  setJMSCorrelationIDAsBytes(corrIDBytes);
  3. } catch (JMSException e) {

代码示例来源：origin: org.apache.tomee/openejb-core

  1. @Override
  2. public byte[] getJMSCorrelationIDAsBytes() throws JMSException {
  3.   return message.getJMSCorrelationIDAsBytes();
  4. }

代码示例来源：origin: org.jboss.jbossas/jboss-as-connector

  1. public byte[] getJMSCorrelationIDAsBytes() throws JMSException
  2. {
  3.  return message.getJMSCorrelationIDAsBytes();
  4. }

代码示例来源：origin: org.jboss.genericjms/generic-jms-ra-jar

  1. public byte[] getJMSCorrelationIDAsBytes() throws JMSException {
  2.   return message.getJMSCorrelationIDAsBytes();
  3. }

代码示例来源：origin: org.apache.qpid/qpid-jca

  1. /**
  2. * Get correlation id
  3. * @return The value
  4. * @exception JMSException Thrown if an error occurs
  5. */
  6. public byte[] getJMSCorrelationIDAsBytes() throws JMSException
  7. {
  8.  if (_log.isTraceEnabled())
  9.  {
  10.    _log.trace("getJMSCorrelationIDAsBytes()");
  11.  }
  12.  return _message.getJMSCorrelationIDAsBytes();
  13. }

代码示例来源：origin: org.apache.camel/camel-jms

  1. /**
  2.    * Gets the JMSCorrelationIDAsBytes from the message.
  3.    *
  4.    * @param message the message
  5.    * @return the JMSCorrelationIDAsBytes, or <tt>null</tt> if not able to get
  6.    */
  7.   public static String getJMSCorrelationIDAsBytes(Message message) {
  8.     try {
  9.       byte[] bytes = message.getJMSCorrelationIDAsBytes();
  10.       boolean isNull = true;
  11.       for (byte b : bytes) {
  12.         if (b != 0) {
  13.           isNull = false;
  14.         }
  15.       }
  16.       return isNull ? null : new String(bytes);
  17.     } catch (Exception e) {
  18.       // ignore if JMS broker do not support this
  19.     }
  20.     return null;
  21.   }
  22. }

代码示例来源：origin: org.seasar.jms/s2jms-core

  1. /**
  2.  * JMSメッセージの{@link javax.jms.Message#getJMSCorrelationIDAsBytes correlationID}
  3.  * ヘッダの値をバイト列で返します。
  4.  * 
  5.  * @return JMSメッセージの{@link javax.jms.Message#getJMSCorrelationIDAsBytes correlationID}ヘッダの値のバイト列
  6.  * @throws SJMSRuntimeException
  7.  *             JMS実装で例外が発生した場合にスローされます
  8.  */
  9. public byte[] getCorrelationIDAsBytes() {
  10.   try {
  11.     return message.getJMSCorrelationIDAsBytes();
  12.   } catch (final JMSException e) {
  13.     throw new SJMSRuntimeException("EJMS0001", new Object[] { e }, e);
  14.   }
  15. }

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

  1. /**
  2. * Get correlation id
  3. *
  4. * @return The value
  5. * @throws JMSException Thrown if an error occurs
  6. */
  7. @Override
  8. public byte[] getJMSCorrelationIDAsBytes() throws JMSException {
  9.  if (ActiveMQRALogger.LOGGER.isTraceEnabled()) {
  10.    ActiveMQRALogger.LOGGER.trace("getJMSCorrelationIDAsBytes()");
  11.  }
  12.  return message.getJMSCorrelationIDAsBytes();
  13. }

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

  1. /**
  2. * Get correlation id
  3. *
  4. * @return The value
  5. * @throws JMSException Thrown if an error occurs
  6. */
  7. @Override
  8. public byte[] getJMSCorrelationIDAsBytes() throws JMSException {
  9.  if (ActiveMQRALogger.LOGGER.isTraceEnabled()) {
  10.    ActiveMQRALogger.LOGGER.trace("getJMSCorrelationIDAsBytes()");
  11.  }
  12.  return message.getJMSCorrelationIDAsBytes();
  13. }

代码示例来源：origin: ibm-messaging/kafka-connect-mq-source

  1. case CORRELATION_ID_AS_BYTES:
  2.   keySchema = Schema.OPTIONAL_BYTES_SCHEMA;
  3.   key = message.getJMSCorrelationIDAsBytes();
  4.   break;
  5. default:

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

  1. @Test
  2. public void testForeignMessageCorrelationIDBytesDisabled() throws Exception {
  3.  System.setProperty(ActiveMQJMSConstants.JMS_ACTIVEMQ_ENABLE_BYTE_ARRAY_JMS_CORRELATION_ID_PROPERTY_NAME, "false");
  4.  SimpleJMSMessage msg = new SimpleJMSMessage();
  5.  msg.setJMSCorrelationID("mycorrelationid");
  6.  byte[] bytes = new byte[]{1, 4, 3, 6, 8};
  7.  msg.setJMSCorrelationIDAsBytes(bytes);
  8.  queueProd.send(msg);
  9.  Message rec = queueCons.receive();
  10.  ProxyAssertSupport.assertNotNull(rec);
  11.  Assert.assertNull(rec.getJMSCorrelationIDAsBytes());
  12.  Assert.assertEquals("mycorrelationid", msg.getJMSCorrelationID());
  13. }

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

  1. @Test
  2. public void testForeignMessageCorrelationID() throws Exception {
  3.  System.setProperty(ActiveMQJMSConstants.JMS_ACTIVEMQ_ENABLE_BYTE_ARRAY_JMS_CORRELATION_ID_PROPERTY_NAME, "true");
  4.  SimpleJMSMessage msg = new SimpleJMSMessage();
  5.  msg.setJMSCorrelationID("mycorrelationid");
  6.  byte[] bytes = new byte[]{1, 4, 3, 6, 8};
  7.  msg.setJMSCorrelationIDAsBytes(bytes);
  8.  queueProd.send(msg);
  9.  Message rec = queueCons.receive();
  10.  ProxyAssertSupport.assertNotNull(rec);
  11.  //Bytes correlation id takes precedence
  12.  byte[] bytesrec = rec.getJMSCorrelationIDAsBytes();
  13.  assertByteArraysEqual(bytes, bytesrec);
  14.  Assert.assertNull(rec.getJMSCorrelationID());
  15. }

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

  1. @Test
  2. public void testJMSDestination() throws Exception {
  3.  Message m1 = queueProducerSession.createMessage();
  4.  // Test with correlation id containing a message id
  5.  final String messageID = "ID:812739812378";
  6.  m1.setJMSCorrelationID(messageID);
  7.  queueProducer.send(m1);
  8.  Message m2 = queueConsumer.receive();
  9.  ProxyAssertSupport.assertEquals(messageID, m2.getJMSCorrelationID());
  10.  // Test with correlation id containing an application defined string
  11.  Message m3 = queueProducerSession.createMessage();
  12.  final String appDefinedID = "oiwedjiwjdoiwejdoiwjd";
  13.  m3.setJMSCorrelationID(appDefinedID);
  14.  queueProducer.send(m3);
  15.  Message m4 = queueConsumer.receive();
  16.  ProxyAssertSupport.assertEquals(appDefinedID, m4.getJMSCorrelationID());
  17.  // Test with correlation id containing a byte[]
  18.  Message m5 = queueProducerSession.createMessage();
  19.  final byte[] bytes = new byte[]{-111, 45, 106, 3, -44};
  20.  m5.setJMSCorrelationIDAsBytes(bytes);
  21.  queueProducer.send(m5);
  22.  Message m6 = queueConsumer.receive();
  23.  assertByteArraysEqual(bytes, m6.getJMSCorrelationIDAsBytes());
  24. }

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

  1. byte[] corrIDBytes = foreign.getJMSCorrelationIDAsBytes();
  2.  setJMSCorrelationIDAsBytes(corrIDBytes);
  3. } catch (JMSException e) {

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

  1. byte[] corrIDBytes = foreign.getJMSCorrelationIDAsBytes();
  2.  setJMSCorrelationIDAsBytes(corrIDBytes);
  3. } catch (JMSException e) {

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

  1. byte[] corrIDBytes = foreign.getJMSCorrelationIDAsBytes();
  2.  setJMSCorrelationIDAsBytes(corrIDBytes);
  3. } catch (JMSException e) {

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

  1. byte[] corrIDBytes = foreign.getJMSCorrelationIDAsBytes();
  2.  setJMSCorrelationIDAsBytes(corrIDBytes);
  3. } catch (JMSException e) {

代码示例来源：origin: org.hornetq/hornetq-jms

  1. byte[] corrIDBytes = foreign.getJMSCorrelationIDAsBytes();
  2. setJMSCorrelationIDAsBytes(corrIDBytes);

代码示例来源：origin: se.ugli.jocote/jocote

  1. private static Map<String, Object> headers(final javax.jms.Message message) throws JMSException {
  2.   final Map<String, Object> result = new HashMap<>();
  3.   putHeadedIfPresent(result, CorrelationID, message.getJMSCorrelationID());
  4.   putHeadedIfPresent(result, CorrelationIDAsBytes, message.getJMSCorrelationIDAsBytes());
  5.   putHeadedIfPresent(result, DeliveryMode, message.getJMSDeliveryMode());
  6.   putHeadedIfPresent(result, Destination, message.getJMSDestination());
  7.   putHeadedIfPresent(result, Expiration, message.getJMSExpiration());
  8.   putHeadedIfPresent(result, MessageID, message.getJMSMessageID());
  9.   putHeadedIfPresent(result, Priority, message.getJMSPriority());
  10.   putHeadedIfPresent(result, Redelivered, message.getJMSRedelivered());
  11.   putHeadedIfPresent(result, ReplyTo, message.getJMSReplyTo());
  12.   putHeadedIfPresent(result, Timestamp, message.getJMSTimestamp());
  13.   putHeadedIfPresent(result, Type, message.getJMSType());
  14.   return result;
  15. }

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

  1. corrIDBytes = m1.getJMSCorrelationIDAsBytes();
  2. } catch (JMSException e) {

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

Message

相关文章

    查看更多

    热门标签

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

    最新文章

    更多

    Message类方法

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