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

QueueSession.createBytesMessage介绍

暂无

代码示例

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

@Override
public BytesMessage createBytesMessage() throws JMSException {
  return next.createBytesMessage();
}

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

@Override
public BytesMessage createBytesMessage() throws JMSException {
  return next.createBytesMessage();
}

代码示例来源：origin: pierre/meteo

/**
 * @return
 * @throws JMSException
 */
public BytesMessage createBytesMessage() throws JMSException {
  return next.createBytesMessage();
}

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

@Override
public BytesMessage createBytesMessage() throws JMSException {
  return next.createBytesMessage();
}

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

@Override
public BytesMessage createBytesMessage() throws JMSException {
  return next.createBytesMessage();
}

代码示例来源：origin: org.apache.synapse/synapse-samples

private void sendBytesMessage(byte[] payload) throws Exception {
  BytesMessage bm = session.createBytesMessage();
  bm.writeBytes(payload);
  sender.send(bm);
}

代码示例来源：origin: org.wso2.ei/org.wso2.ei.samples

private void sendBytesMessage(byte[] payload) throws Exception {
  BytesMessage bm = session.createBytesMessage();
  bm.writeBytes(payload);
  sender.send(bm);
}

代码示例来源：origin: wso2/wso2-synapse

private void sendBytesMessage(byte[] payload) throws Exception {
  BytesMessage bm = session.createBytesMessage();
  bm.writeBytes(payload);
  sender.send(bm);
}

代码示例来源：origin: be.fedict.eid-dss/eid-dss-model

public Message getMessage(QueueSession queueSession) throws JMSException {
  BytesMessage bytesMessage = queueSession.createBytesMessage();
  bytesMessage.setStringProperty("email", this.email);
  bytesMessage.setStringProperty("language", this.language);
  bytesMessage.setStringProperty("mimetype", this.mimetype);
  bytesMessage.writeBytes(this.document);
  return bytesMessage;
}

代码示例来源：origin: org.apache.synapse/synapse-samples

private void sendBytesMessage(String destName,byte[] buffer) throws Exception {
  InitialContext ic = getInitialContext();
  QueueConnectionFactory confac = (QueueConnectionFactory) ic.lookup("ConnectionFactory");
  QueueConnection connection = confac.createQueueConnection();
  QueueSession session = connection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
  BytesMessage bm = session.createBytesMessage();
  bm.writeBytes(buffer);
  QueueSender sender = session.createSender((Queue)ic.lookup(destName));
  sender.send(bm);
  sender.close();
  session.close();
  connection.close();
}

代码示例来源：origin: wso2/wso2-synapse

private void sendBytesMessage(String destName,byte[] buffer) throws Exception {
  InitialContext ic = getInitialContext();
  QueueConnectionFactory confac = (QueueConnectionFactory) ic.lookup("ConnectionFactory");
  QueueConnection connection = confac.createQueueConnection();
  QueueSession session = connection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
  BytesMessage bm = session.createBytesMessage();
  bm.writeBytes(buffer);
  QueueSender sender = session.createSender((Queue)ic.lookup(destName));
  sender.send(bm);
  sender.close();
  session.close();
  connection.close();
}

代码示例来源：origin: org.wso2.ei/org.wso2.ei.samples

private void sendBytesMessage(String destName,byte[] buffer) throws Exception {
  InitialContext ic = getInitialContext();
  QueueConnectionFactory confac = (QueueConnectionFactory) ic.lookup("ConnectionFactory");
  QueueConnection connection = confac.createQueueConnection();
  QueueSession session = connection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
  BytesMessage bm = session.createBytesMessage();
  bm.writeBytes(buffer);
  QueueSender sender = session.createSender((Queue)ic.lookup(destName));
  sender.send(bm);
  sender.close();
  session.close();
  connection.close();
}

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

/**
* Send a <code>BytesMessage</code> with an empty body.
* <br />
* Receive it and test if the message is effectively an instance of 
* <code>BytesMessage</code>
*/
public void testBytesMessage_1()
{
 try
 {
   BytesMessage message = senderSession.createBytesMessage();
   sender.send(message);
   Message msg = receiver.receive(TestConfig.TIMEOUT);
   assertTrue("The message should be an instance of BytesMessage.\n", msg instanceof BytesMessage);
 }
 catch (JMSException e)
 {
   fail(e);
 }
}

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

/**
* Send a <code>BytesMessage</code> with 2 Java primitives in its body (a <code>
* String</code> and a <code>double</code>).
* <br />
* Receive it and test that the values of the primitives of the body are correct
*/
public void testBytesMessage_2()
{
 try
 {
   byte[] bytes = new String("pi").getBytes();
   BytesMessage message = senderSession.createBytesMessage();
   message.writeBytes(bytes);
   message.writeDouble(3.14159);
   sender.send(message);
   Message m = receiver.receive(TestConfig.TIMEOUT);
   assertTrue("The message should be an instance of BytesMessage.\n", m instanceof BytesMessage);
   BytesMessage msg = (BytesMessage) m;
   byte[] receivedBytes = new byte[bytes.length];
   msg.readBytes(receivedBytes);
   assertEquals(new String(bytes), new String(receivedBytes));
   assertEquals(3.14159, msg.readDouble(), 0);
 }
 catch (JMSException e)
 {
   fail(e);
 }
}

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

/**
* Send a <code>BytesMessage</code> with an empty body.
* <br />
* Receive it and test if the message is effectively an instance of
* <code>BytesMessage</code>
*/
@Test
public void testBytesMessage_1() {
 try {
   BytesMessage message = senderSession.createBytesMessage();
   sender.send(message);
   Message msg = receiver.receive(TestConfig.TIMEOUT);
   Assert.assertTrue("The message should be an instance of BytesMessage.\n", msg instanceof BytesMessage);
 } catch (JMSException e) {
   fail(e);
 }
}

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

/**
* Send a <code>BytesMessage</code> with 2 Java primitives in its body (a <code>
* String</code> and a <code>double</code>).
* <br />
* Receive it and test that the values of the primitives of the body are correct
*/
@Test
public void testBytesMessage_2() {
 try {
   byte[] bytes = new String("pi").getBytes();
   BytesMessage message = senderSession.createBytesMessage();
   message.writeBytes(bytes);
   message.writeDouble(3.14159);
   sender.send(message);
   Message m = receiver.receive(TestConfig.TIMEOUT);
   Assert.assertTrue("The message should be an instance of BytesMessage.\n", m instanceof BytesMessage);
   BytesMessage msg = (BytesMessage) m;
   byte[] receivedBytes = new byte[bytes.length];
   msg.readBytes(receivedBytes);
   Assert.assertEquals(new String(bytes), new String(receivedBytes));
   Assert.assertEquals(3.14159, msg.readDouble(), 0);
 } catch (JMSException e) {
   fail(e);
 }
}

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

BytesMessage bytesMessage = defaultQueueSession.createBytesMessage();
bytesMessage.setStringProperty("testName", "testSendEmptyMessages");
defaultSender.send(bytesMessage);