javax.jms.QueueSession.createObjectMessage()方法的使用及代码示例

x33g5p2x  于2022-01-28 转载在 其他  
字(7.5k)|赞(0)|评价(0)|浏览(136)

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

QueueSession.createObjectMessage介绍

暂无

代码示例

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

@Override
public ObjectMessage createObjectMessage() throws JMSException {
  return next.createObjectMessage();
}

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

@Override
public ObjectMessage createObjectMessage(Serializable object) throws JMSException {
  return next.createObjectMessage(object);
}

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

/**
 * This method called by {@link AppenderBase#doAppend} method to do most
 * of the real appending work.
 */
public void append(ILoggingEvent event) {
 if (!isStarted()) {
  return;
 }
 try {
  ObjectMessage msg = queueSession.createObjectMessage();
  Serializable so = pst.transform(event);
  msg.setObject(so);
  queueSender.send(msg);
  successiveFailureCount = 0;
 } catch (Exception e) {
  successiveFailureCount++;
  if (successiveFailureCount > SUCCESSIVE_FAILURE_LIMIT) {
   stop();
  }
  addError("Could not send message in JMSQueueAppender [" + name + "].", e);
 }
}

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

/**
 * @param object
 * @return
 * @throws JMSException
 */
public ObjectMessage createObjectMessage(Serializable object) throws JMSException {
  return next.createObjectMessage(object);
}

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

@Override
public ObjectMessage createObjectMessage(Serializable object) throws JMSException {
  return next.createObjectMessage(object);
}

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

/**
 * @return
 * @throws JMSException
 */
public ObjectMessage createObjectMessage() throws JMSException {
  return next.createObjectMessage();
}

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

@Override
public ObjectMessage createObjectMessage() throws JMSException {
  return next.createObjectMessage();
}

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

@Override
public ObjectMessage createObjectMessage(Serializable object) throws JMSException {
  return next.createObjectMessage(object);
}

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

@Override
public ObjectMessage createObjectMessage(Serializable object) throws JMSException {
  return next.createObjectMessage(object);
}

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

@Override
public ObjectMessage createObjectMessage() throws JMSException {
  return next.createObjectMessage();
}

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

@Override
public ObjectMessage createObjectMessage() throws JMSException {
  return next.createObjectMessage();
}

代码示例来源：origin: espertechinc/esper

public void sendEvent(BaseTerminalEvent baseDeskEvent) {
  try {
    ObjectMessage textMessage = session.createObjectMessage(baseDeskEvent);
    sender.send(textMessage);
  } catch (JMSException ex) {
    System.out.println("Error sending event:" + ex.toString());
  }
}

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

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

代码示例来源：origin: stackoverflow.com

Queue q = (Queue) ServiceLocator.getInstance().getDestination("QUEUE");
 QueueConnectionFactory factory = (QueueConnectionFactory) ServiceLocator.getInstance().getConnectionFactory(
     "java:/ConnectionFactory");
 QueueConnection connection = factory.createQueueConnection();
 QueueSession session = null;
 QueueSender sender = null;
 session = connection.createQueueSession(false, javax.jms.Session.AUTO_ACKNOWLEDGE);
 sender = session.createSender(q);
 ObjectMessage msg = session.createObjectMessage();
 if (redelivedCount > 0) {
  msg.setIntProperty("redelivedCount", redelivedCount);
  // schedule to run in 10 secs
  msg.setLongProperty("_AMQ_SCHED_DELIVERY", System.currentTimeMillis() + 10000);
 }
 msg.setStringProperty("action", action);
 msg.setObject(params);
 sender.send(msg);

代码示例来源：origin: at.bestsolution.efxclipse.eclipse/ch.qos.logback.classic

/**
 * This method called by {@link AppenderBase#doAppend} method to do most
 * of the real appending work.
 */
public void append(ILoggingEvent event) {
 if (!isStarted()) {
  return;
 }
 try {
  ObjectMessage msg = queueSession.createObjectMessage();
  Serializable so = pst.transform(event);
  msg.setObject(so);
  queueSender.send(msg);
  successiveFailureCount = 0;
 } catch (Exception e) {
  successiveFailureCount++;
  if (successiveFailureCount > SUCCESSIVE_FAILURE_LIMIT) {
   stop();
  }
  addError("Could not send message in JMSQueueAppender [" + name + "].", e);
 }
}

代码示例来源：origin: com.alibaba.citrus.tool/antx-autoexpand

/**
 * This method called by {@link AppenderBase#doAppend} method to do most
 * of the real appending work.
 */
public void append(ILoggingEvent event) {
 if (!isStarted()) {
  return;
 }
 try {
  ObjectMessage msg = queueSession.createObjectMessage();
  Serializable so = pst.transform(event);
  msg.setObject(so);
  queueSender.send(msg);
  successiveFailureCount = 0;
 } catch (Exception e) {
  successiveFailureCount++;
  if (successiveFailureCount > SUCCESSIVE_FAILURE_LIMIT) {
   stop();
  }
  addError("Could not send message in JMSQueueAppender [" + name + "].", e);
 }
}

代码示例来源：origin: Nextdoor/bender

/**
 * This method called by {@link AppenderBase#doAppend} method to do most
 * of the real appending work.
 */
public void append(ILoggingEvent event) {
  if (!isStarted()) {
    return;
  }
  try {
    ObjectMessage msg = queueSession.createObjectMessage();
    Serializable so = pst.transform(event);
    msg.setObject(so);
    queueSender.send(msg);
    successiveFailureCount = 0;
  } catch (Exception e) {
    successiveFailureCount++;
    if (successiveFailureCount > SUCCESSIVE_FAILURE_LIMIT) {
      stop();
    }
    addError("Could not send message in JMSQueueAppender [" + name + "].", e);
  }
}

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

/**
* Send an <code>ObjectMessage</code> with a <code>Vector</code> (composed of a <code>
* String</code> and a <code>double</code>) in its body.
* <br />
* Receive it and test that the values of the primitives of the body are correct
*/
@Test
public void testObjectMessage_2() {
 try {
   Vector<Object> vector = new Vector<>();
   vector.add("pi");
   vector.add(new Double(3.14159));
   ObjectMessage message = senderSession.createObjectMessage();
   message.setObject(vector);
   sender.send(message);
   Message m = receiver.receive(TestConfig.TIMEOUT);
   Assert.assertTrue("The message should be an instance of ObjectMessage.\n", m instanceof ObjectMessage);
   ObjectMessage msg = (ObjectMessage) m;
   Assert.assertEquals(vector, msg.getObject());
 } catch (JMSException e) {
   fail(e);
 }
}

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

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

代码示例来源：origin: hibernate/hibernate-search

private void sendMessage(List<LuceneWork> queue) throws Exception {
  ObjectMessage message = getQueueSession().createObjectMessage();
  final String indexName = getIndexName();
  message.setStringProperty(
      Environment.INDEX_NAME_JMS_PROPERTY,
      indexName );
  byte[] data = getExtendedSearchIntegrator().getWorkSerializer().toSerializedModel( queue );
  message.setObject( data );
  QueueSender sender = getQueueSession().createSender( getMessageQueue() );
  sender.send( message );
}

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

QueueSession

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

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