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

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

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

Message.getJMSType介绍

[英]Gets the message type identifier supplied by the client when the message was sent.
[中]获取发送消息时客户端提供的消息类型标识符。

代码示例

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

  1. public void onMessage(javax.jms.Message message) {
  2.  LoggingEvent event;
  3.  Logger remoteLogger;
  4.  try {
  5.   if(message instanceof  ObjectMessage) {
  6.  ObjectMessage objectMessage = (ObjectMessage) message;
  7.  event = (LoggingEvent) objectMessage.getObject();
  8.  remoteLogger = Logger.getLogger(event.getLoggerName());
  9.  remoteLogger.callAppenders(event);
  10.   } else {
  11.  logger.warn("Received message is of type "+message.getJMSType()
  12.      +", was expecting ObjectMessage.");
  13.   }      
  14.  } catch(JMSException jmse) {
  15.   logger.error("Exception thrown while processing incoming message.", 
  16.      jmse);
  17.  }
  18. }

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

  1. sbuf.append(m.getJMSType());

代码示例来源：origin: spring-projects/spring-framework

  1. String type = jmsMessage.getJMSType();
  2. if (type != null) {
  3.   headers.put(JmsHeaders.TYPE, type);

代码示例来源：origin: apache/rocketmq-externals

  1. public static byte[] getContentFromJms(javax.jms.Message jmsMessage) throws Exception {
  2.   byte[] content;
  3.   if (jmsMessage instanceof TextMessage) {
  4.     if (StringUtils.isEmpty(((TextMessage) jmsMessage).getText())) {
  5.       throw new IllegalArgumentException("Message body length is zero");
  6.     }
  7.     content = MsgConvertUtil.string2Bytes(((TextMessage) jmsMessage).getText(),
  8.       Charsets.UTF_8.toString());
  9.   }
  10.   else if (jmsMessage instanceof ObjectMessage) {
  11.     if (((ObjectMessage) jmsMessage).getObject() == null) {
  12.       throw new IllegalArgumentException("Message body length is zero");
  13.     }
  14.     content = MsgConvertUtil.objectSerialize(((ObjectMessage) jmsMessage).getObject());
  15.   }
  16.   else if (jmsMessage instanceof BytesMessage) {
  17.     JmsBytesMessage bytesMessage = (JmsBytesMessage) jmsMessage;
  18.     if (bytesMessage.getBodyLength() == 0) {
  19.       throw new IllegalArgumentException("Message body length is zero");
  20.     }
  21.     content = bytesMessage.getData();
  22.   }
  23.   else {
  24.     throw new IllegalArgumentException("Unknown message type " + jmsMessage.getJMSType());
  25.   }
  26.   return content;
  27. }

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

  1. private Map<String, String> extractMessageHeaders(final Message message) throws JMSException {
  2.   final Map<String, String> messageHeaders = new HashMap<>();
  3.   messageHeaders.put(JmsHeaders.DELIVERY_MODE, String.valueOf(message.getJMSDeliveryMode()));
  4.   messageHeaders.put(JmsHeaders.EXPIRATION, String.valueOf(message.getJMSExpiration()));
  5.   messageHeaders.put(JmsHeaders.PRIORITY, String.valueOf(message.getJMSPriority()));
  6.   messageHeaders.put(JmsHeaders.REDELIVERED, String.valueOf(message.getJMSRedelivered()));
  7.   messageHeaders.put(JmsHeaders.TIMESTAMP, String.valueOf(message.getJMSTimestamp()));
  8.   messageHeaders.put(JmsHeaders.CORRELATION_ID, message.getJMSCorrelationID());
  9.   messageHeaders.put(JmsHeaders.MESSAGE_ID, message.getJMSMessageID());
  10.   messageHeaders.put(JmsHeaders.TYPE, message.getJMSType());
  11.   String replyToDestinationName = this.retrieveDestinationName(message.getJMSReplyTo(), JmsHeaders.REPLY_TO);
  12.   if (replyToDestinationName != null) {
  13.     messageHeaders.put(JmsHeaders.REPLY_TO, replyToDestinationName);
  14.   }
  15.   String destinationName = this.retrieveDestinationName(message.getJMSDestination(), JmsHeaders.DESTINATION);
  16.   if (destinationName != null) {
  17.     messageHeaders.put(JmsHeaders.DESTINATION, destinationName);
  18.   }
  19.   return messageHeaders;
  20. }

代码示例来源：origin: spring-projects/spring-framework

  1. @Test
  2. public void jmsTypeMappedFromHeader() throws JMSException {
  3.   String jmsType = "testing";
  4.   Message<String> message = initBuilder()
  5.       .setHeader(JmsHeaders.TYPE, jmsType).build();
  6.   javax.jms.Message jmsMessage = new StubTextMessage();
  7.   mapper.fromHeaders(message.getHeaders(), jmsMessage);
  8.   assertNotNull(jmsMessage.getJMSType());
  9.   assertEquals(jmsType, jmsMessage.getJMSType());
  10. }

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

  1. attributes.put(ATTRIBUTE_PREFIX + JMS_REPLY_TO, message.getJMSReplyTo().toString());
  2. if (message.getJMSType() != null) {
  3.   attributes.put(ATTRIBUTE_PREFIX + JMS_TYPE, message.getJMSType());

代码示例来源：origin: spring-projects/spring-framework

  1. @Test
  2. public void jmsTypeIgnoredIfIncorrectType() throws JMSException {
  3.   Message<String> message = initBuilder()
  4.       .setHeader(JmsHeaders.TYPE, 123).build();
  5.   javax.jms.Message jmsMessage = new StubTextMessage();
  6.   mapper.fromHeaders(message.getHeaders(), jmsMessage);
  7.   assertNull(jmsMessage.getJMSType());
  8. }

代码示例来源：origin: spring-projects/spring-framework

  1. @Test
  2. public void attemptToWriteDisallowedTypePropertyIsNotFatal() throws JMSException {
  3.   Message<String> message = initBuilder()
  4.       .setHeader(JmsHeaders.TYPE, "someType")
  5.       .setHeader("foo", "bar")
  6.       .build();
  7.   javax.jms.Message jmsMessage = new StubTextMessage() {
  8.     @Override
  9.     public void setJMSType(String type) throws JMSException {
  10.       throw new JMSException("illegal property");
  11.     }
  12.   };
  13.   mapper.fromHeaders(message.getHeaders(), jmsMessage);
  14.   assertNull(jmsMessage.getJMSType());
  15.   assertNotNull(jmsMessage.getStringProperty("foo"));
  16.   assertEquals("bar", jmsMessage.getStringProperty("foo"));
  17. }

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

  1. setJMSExpiration(foreign.getJMSExpiration());
  2. setJMSPriority(foreign.getJMSPriority());
  3. setJMSType(foreign.getJMSType());

代码示例来源：origin: spring-projects/spring-framework

  1. @Test
  2. public void buildMessageWithStandardMessage() throws JMSException {
  3.   Destination replyTo = new Destination() {};
  4.   Message<String> result = MessageBuilder.withPayload("Response")
  5.       .setHeader("foo", "bar")
  6.       .setHeader(JmsHeaders.TYPE, "msg_type")
  7.       .setHeader(JmsHeaders.REPLY_TO, replyTo)
  8.       .build();
  9.   Session session = mock(Session.class);
  10.   given(session.createTextMessage("Response")).willReturn(new StubTextMessage("Response"));
  11.   MessagingMessageListenerAdapter listener = getSimpleInstance("echo", Message.class);
  12.   javax.jms.Message replyMessage = listener.buildMessage(session, result);
  13.   verify(session).createTextMessage("Response");
  14.   assertNotNull("reply should never be null", replyMessage);
  15.   assertEquals("Response", ((TextMessage) replyMessage).getText());
  16.   assertEquals("custom header not copied", "bar", replyMessage.getStringProperty("foo"));
  17.   assertEquals("type header not copied", "msg_type", replyMessage.getJMSType());
  18.   assertEquals("replyTo header not copied", replyTo, replyMessage.getJMSReplyTo());
  19. }

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

  1. /**
  2.    * Copies the standard JMS and user defined properties from the givem
  3.    * message to the specified message
  4.    *
  5.    * @param fromMessage the message to take the properties from
  6.    * @param toMessage the message to add the properties to
  7.    * @throws JMSException
  8.    */
  9.   public static void copyProperties(Message fromMessage, Message toMessage) throws JMSException {
  10.     toMessage.setJMSMessageID(fromMessage.getJMSMessageID());
  11.     toMessage.setJMSCorrelationID(fromMessage.getJMSCorrelationID());
  12.     toMessage.setJMSReplyTo(transformDestination(fromMessage.getJMSReplyTo()));
  13.     toMessage.setJMSDestination(transformDestination(fromMessage.getJMSDestination()));
  14.     toMessage.setJMSDeliveryMode(fromMessage.getJMSDeliveryMode());
  15.     toMessage.setJMSRedelivered(fromMessage.getJMSRedelivered());
  16.     toMessage.setJMSType(fromMessage.getJMSType());
  17.     toMessage.setJMSExpiration(fromMessage.getJMSExpiration());
  18.     toMessage.setJMSPriority(fromMessage.getJMSPriority());
  19.     toMessage.setJMSTimestamp(fromMessage.getJMSTimestamp());
  21.     Enumeration propertyNames = fromMessage.getPropertyNames();
  23.     while (propertyNames.hasMoreElements()) {
  24.       String name = propertyNames.nextElement().toString();
  25.       Object obj = fromMessage.getObjectProperty(name);
  26.       toMessage.setObjectProperty(name, obj);
  27.     }
  28.   }
  29. }

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

  1. public void onMessage(javax.jms.Message message) {
  2.  LoggingEvent event;
  3.  Logger remoteLogger;
  4.  try {
  5.   if(message instanceof  ObjectMessage) {
  6.  ObjectMessage objectMessage = (ObjectMessage) message;
  7.  event = (LoggingEvent) objectMessage.getObject();
  8.  remoteLogger = Logger.getLogger(event.getLoggerName());
  9.  remoteLogger.callAppenders(event);
  10.   } else {
  11.  logger.warn("Received message is of type "+message.getJMSType()
  12.      +", was expecting ObjectMessage.");
  13.   }      
  14.  } catch(JMSException jmse) {
  15.   logger.error("Exception thrown while processing incoming message.", 
  16.      jmse);
  17.  }
  18. }

代码示例来源：origin: camunda/camunda-bpm-platform

  1. public void onMessage(javax.jms.Message message) {
  2.  ILoggingEvent event;
  3.  try {
  4.   if (message instanceof ObjectMessage) {
  5.    ObjectMessage objectMessage = (ObjectMessage) message;
  6.    event = (ILoggingEvent) objectMessage.getObject();
  7.    Logger log = (Logger) LoggerFactory.getLogger(event.getLoggerName());
  8.    log.callAppenders(event);
  9.   } else {
  10.    logger.warn("Received message is of type " + message.getJMSType()
  11.      + ", was expecting ObjectMessage.");
  12.   }
  13.  } catch (JMSException jmse) {
  14.   logger.error("Exception thrown while processing incoming message.", jmse);
  15.  }
  16. }

代码示例来源：origin: camunda/camunda-bpm-platform

  1. public void onMessage(javax.jms.Message message) {
  2.  ILoggingEvent event;
  3.  try {
  4.   if (message instanceof ObjectMessage) {
  5.    ObjectMessage objectMessage = (ObjectMessage) message;
  6.    event = (ILoggingEvent) objectMessage.getObject();
  7.    Logger log = (Logger) LoggerFactory.getLogger(event.getLoggerName());
  8.    log.callAppenders(event);
  9.   } else {
  10.    logger.warn("Received message is of type " + message.getJMSType()
  11.      + ", was expecting ObjectMessage.");
  12.   }
  13.  } catch (JMSException jmse) {
  14.   logger.error("Exception thrown while processing incoming message.", jmse);
  15.  }
  16. }

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

  1. sbuf.append(m.getJMSType());

代码示例来源：origin: spring-projects/spring-integration

  1. String type = jmsMessage.getJMSType();
  2. if (type != null) {
  3.   headers.put(JmsHeaders.TYPE, type);

代码示例来源：origin: spring-projects/spring-integration

  1. @Test
  2. public void testJmsTypeMappedFromHeader() throws JMSException {
  3.   String jmsType = "testing";
  4.   Message<String> message = MessageBuilder.withPayload("test")
  5.       .setHeader(JmsHeaders.TYPE, jmsType).build();
  6.   DefaultJmsHeaderMapper mapper = new DefaultJmsHeaderMapper();
  7.   javax.jms.Message jmsMessage = new StubTextMessage();
  8.   mapper.fromHeaders(message.getHeaders(), jmsMessage);
  9.   assertNotNull(jmsMessage.getJMSType());
  10.   assertEquals(jmsType, jmsMessage.getJMSType());
  11. }

代码示例来源：origin: spring-projects/spring-integration

  1. @Test
  2. public void testJmsTypeIgnoredIfIncorrectType() throws JMSException {
  3.   Message<String> message = MessageBuilder.withPayload("test")
  4.       .setHeader(JmsHeaders.TYPE, new Integer(123)).build();
  5.   DefaultJmsHeaderMapper mapper = new DefaultJmsHeaderMapper();
  6.   javax.jms.Message jmsMessage = new StubTextMessage();
  7.   mapper.fromHeaders(message.getHeaders(), jmsMessage);
  8.   assertNull(jmsMessage.getJMSType());
  9. }

代码示例来源：origin: spring-projects/spring-integration

  1. @Test
  2. public void attemptToWriteDisallowedTypePropertyIsNotFatal() throws JMSException {
  3.   Message<String> message = MessageBuilder.withPayload("test")
  4.       .setHeader(JmsHeaders.TYPE, "someType")
  5.       .setHeader("foo", "bar")
  6.       .build();
  7.   DefaultJmsHeaderMapper mapper = new DefaultJmsHeaderMapper();
  8.   javax.jms.Message jmsMessage = new StubTextMessage() {
  9.     @Override
  10.     public void setJMSType(String type) throws JMSException {
  11.       throw new JMSException("illegal property");
  12.     }
  13.   };
  14.   mapper.fromHeaders(message.getHeaders(), jmsMessage);
  15.   assertNull(jmsMessage.getJMSType());
  16.   assertNotNull(jmsMessage.getStringProperty("foo"));
  17.   assertEquals("bar", jmsMessage.getStringProperty("foo"));
  18. }

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

Message

相关文章

    查看更多

    热门标签

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

    最新文章

    更多

    Message类方法

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