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

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

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

Message.setByteProperty介绍

[英]Sets a byte property value with the specified name into the message.
[中]在消息中设置具有指定名称的字节属性值。

代码示例

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

  1. message.setLongProperty(jmsPropName, Long.parseLong(value));
  2. } else if (type.equalsIgnoreCase(PROP_TYPE_BYTE)) {
  3. message.setByteProperty(jmsPropName, Byte.parseByte(value));
  4. } else if (type.equalsIgnoreCase(PROP_TYPE_DOUBLE)) {
  5. message.setDoubleProperty(jmsPropName, Double.parseDouble(value));

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

  1. public void setByteProperty(String name, byte value) throws JMSException
  2. {
  3. message.setByteProperty(name, value);
  4. }

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

  1. @Override
  2. public void setByteProperty(final String name, final byte value) throws JMSException {
  3. message.setByteProperty(name, value);
  4. }

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

  1. public void setByteProperty(String name, byte value) throws JMSException {
  2. message.setByteProperty(name, value);
  3. }

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

  1. /**
  2. * Set property
  3. * @param name The name
  4. * @param value The value
  5. * @exception JMSException Thrown if an error occurs
  6. */
  7. public void setByteProperty(final String name, final byte value) throws JMSException
  8. {
  9. if (_log.isTraceEnabled())
  10. {
  11. _log.trace("setByteProperty(" + name + ", " + value + ")");
  12. }
  13. _message.setByteProperty(name, value);
  14. }

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

  1. /**
  2. * Set property
  3. *
  4. * @param name The name
  5. * @param value The value
  6. * @throws JMSException Thrown if an error occurs
  7. */
  8. @Override
  9. public void setByteProperty(final String name, final byte value) throws JMSException {
  10. if (ActiveMQRALogger.LOGGER.isTraceEnabled()) {
  11. ActiveMQRALogger.LOGGER.trace("setByteProperty(" + name + ", " + value + ")");
  12. }
  13. message.setByteProperty(name, value);
  14. }

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

  1. /**
  2. * Set property
  3. *
  4. * @param name The name
  5. * @param value The value
  6. * @throws JMSException Thrown if an error occurs
  7. */
  8. @Override
  9. public void setByteProperty(final String name, final byte value) throws JMSException {
  10. if (ActiveMQRALogger.LOGGER.isTraceEnabled()) {
  11. ActiveMQRALogger.LOGGER.trace("setByteProperty(" + name + ", " + value + ")");
  12. }
  13. message.setByteProperty(name, value);
  14. }

代码示例来源:origin: objectweb-joramtests/joramtests

  1. /**
  2. * if a property is set as a <code>byte</code>,
  3. * it can also be read as an <code>int</code>.
  4. */
  5. public void testByte2Int()
  6. {
  7. try
  8. {
  9. Message message = senderSession.createMessage();
  10. message.setByteProperty("prop", (byte) 127);
  11. assertEquals(127, message.getIntProperty("prop"));
  12. }
  13. catch (JMSException e)
  14. {
  15. fail(e);
  16. }
  17. }

代码示例来源:origin: objectweb-joramtests/joramtests

  1. /**
  2. * if a property is set as a <code>byte</code>,
  3. * it can also be read as a <code>long</code>.
  4. */
  5. public void testByte2Long()
  6. {
  7. try
  8. {
  9. Message message = senderSession.createMessage();
  10. message.setByteProperty("prop", (byte) 127);
  11. assertEquals(127L, message.getLongProperty("prop"));
  12. }
  13. catch (JMSException e)
  14. {
  15. fail(e);
  16. }
  17. }

代码示例来源:origin: objectweb-joramtests/joramtests

  1. /**
  2. * if a property is set as a <code>byte</code>,
  3. * it can also be read as a <code>byte</code>.
  4. */
  5. public void testByte2Byte()
  6. {
  7. try
  8. {
  9. Message message = senderSession.createMessage();
  10. message.setByteProperty("prop", (byte) 127);
  11. assertEquals((byte) 127, message.getByteProperty("prop"));
  12. }
  13. catch (JMSException e)
  14. {
  15. fail(e);
  16. }
  17. }

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

  1. /**
  2. * if a property is set as a <code>byte</code>,
  3. * it can also be read as a <code>String</code>.
  4. */
  5. @Test
  6. public void testByte2String() {
  7. try {
  8. Message message = senderSession.createMessage();
  9. message.setByteProperty("prop", (byte) 127);
  10. Assert.assertEquals("127", message.getStringProperty("prop"));
  11. } catch (JMSException e) {
  12. fail(e);
  13. }
  14. }

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

  1. /**
  2. * if a property is set as a <code>byte</code>,
  3. * it can also be read as a <code>short</code>.
  4. */
  5. @Test
  6. public void testByte2Short() {
  7. try {
  8. Message message = senderSession.createMessage();
  9. message.setByteProperty("prop", (byte) 127);
  10. Assert.assertEquals((short) 127, message.getShortProperty("prop"));
  11. } catch (JMSException e) {
  12. fail(e);
  13. }
  14. }

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

  1. /**
  2. * if a property is set as a <code>byte</code>,
  3. * it can also be read as a <code>byte</code>.
  4. */
  5. @Test
  6. public void testByte2Byte() {
  7. try {
  8. Message message = senderSession.createMessage();
  9. message.setByteProperty("prop", (byte) 127);
  10. Assert.assertEquals((byte) 127, message.getByteProperty("prop"));
  11. } catch (JMSException e) {
  12. fail(e);
  13. }
  14. }

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

  1. private void sendMessageUsingOpenWire(String queueName) throws Exception {
  2. Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
  3. ActiveMQDestination destination = createDestination(session, ActiveMQDestination.QUEUE_TYPE);
  4. System.out.println("destination: " + destination);
  5. final ActiveMQMessageProducer producer = (ActiveMQMessageProducer) session.createProducer(destination);
  6. javax.jms.Message message = session.createMessage();
  7. message.setBooleanProperty("booleanProperty", false);
  8. message.setLongProperty("longProperty", 99999L);
  9. message.setByteProperty("byteProperty", (byte) 5);
  10. message.setIntProperty("intProperty", 979);
  11. message.setShortProperty("shortProperty", (short) 1099);
  12. message.setStringProperty("stringProperty", "HelloMessage");
  13. producer.send(message);
  14. }

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

  1. /**
  2. * if a property is set as a <code>byte</code>,
  3. * it can also be read as a <code>long</code>.
  4. */
  5. @Test
  6. public void testByte2Long() {
  7. try {
  8. Message message = senderSession.createMessage();
  9. message.setByteProperty("prop", (byte) 127);
  10. Assert.assertEquals(127L, message.getLongProperty("prop"));
  11. } catch (JMSException e) {
  12. fail(e);
  13. }
  14. }

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

  1. /**
  2. * if a property is set as a <code>byte</code>,
  3. * it can also be read as an <code>int</code>.
  4. */
  5. @Test
  6. public void testByte2Int() {
  7. try {
  8. Message message = senderSession.createMessage();
  9. message.setByteProperty("prop", (byte) 127);
  10. Assert.assertEquals(127, message.getIntProperty("prop"));
  11. } catch (JMSException e) {
  12. fail(e);
  13. }
  14. }

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

  1. /**
  2. * if a property is set as a <code>byte</code>,
  3. * to get is as a <code>float</code> throws a <code>javax.jms.MessageFormatException</code>.
  4. */
  5. @Test
  6. public void testByte2Float() {
  7. try {
  8. Message message = senderSession.createMessage();
  9. message.setByteProperty("prop", (byte) 127);
  10. message.getFloatProperty("prop");
  11. Assert.fail("sec. 3.5.4 The unmarked cases [of Table 0-4] should raise a JMS MessageFormatException.\n");
  12. } catch (MessageFormatException e) {
  13. } catch (JMSException e) {
  14. fail(e);
  15. }
  16. }

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

  1. /**
  2. * if a property is set as a <code>byte</code>,
  3. * to get is as a <code>double</code> throws a <code>javax.jms.MessageFormatException</code>.
  4. */
  5. @Test
  6. public void testByte2Double() {
  7. try {
  8. Message message = senderSession.createMessage();
  9. message.setByteProperty("prop", (byte) 127);
  10. message.getDoubleProperty("prop");
  11. Assert.fail("sec. 3.5.4 The unmarked cases [of Table 0-4] should raise a JMS MessageFormatException.\n");
  12. } catch (MessageFormatException e) {
  13. } catch (JMSException e) {
  14. fail(e);
  15. }
  16. }

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

  1. /**
  2. * if a property is set as a <code>byte</code>,
  3. * to get is as a <code>boolean</code> throws a <code>javax.jms.MessageFormatException</code>.
  4. */
  5. @Test
  6. public void testByte2Boolean() {
  7. try {
  8. Message message = senderSession.createMessage();
  9. // store a value that can't be converted to boolean
  10. message.setByteProperty("prop", (byte) 127);
  11. message.getBooleanProperty("prop");
  12. Assert.fail("sec. 3.5.4 The unmarked cases [of Table 0-4] should raise a JMS MessageFormatException.\n");
  13. } catch (MessageFormatException e) {
  14. } catch (JMSException e) {
  15. fail(e);
  16. }
  17. }

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

  1. protected void prepareMessage(final Message m) throws JMSException {
  2. m.setBooleanProperty("booleanProperty", true);
  3. m.setByteProperty("byteProperty", (byte) 3);
  4. m.setDoubleProperty("doubleProperty", 4.0);
  5. m.setFloatProperty("floatProperty", 5.0f);
  6. m.setIntProperty("intProperty", 6);
  7. m.setLongProperty("longProperty", 7);
  8. m.setShortProperty("shortProperty", (short) 8);
  9. m.setStringProperty("stringProperty", "this is a String property");
  10. m.setJMSCorrelationID("this is the correlation ID");
  11. m.setJMSReplyTo(ActiveMQServerTestCase.topic1);
  12. m.setJMSType("someArbitraryType");
  13. }

相关文章