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

QueueSession.createTextMessage介绍

暂无

代码示例

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

@Override
public TextMessage createTextMessage(String text) throws JMSException {
  return next.createTextMessage(text);
}

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

@Override
public TextMessage createTextMessage() throws JMSException {
  return next.createTextMessage();
}

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

given(session.createTextMessage(RESPONSE_TEXT)).willReturn(responseTextMessage);
given(session.createProducer(destination)).willReturn(messageProducer);

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

@Test
public void testWithResponsiveMessageDelegateNoDefaultDestinationAndNoReplyToDestination_SendsReturnTextMessageWhenSessionSupplied() throws Exception {
  final TextMessage sentTextMessage = mock(TextMessage.class);
  // correlation ID is queried when response is being created...
  given(sentTextMessage.getJMSCorrelationID()).willReturn(CORRELATION_ID);
  // Reply-To is queried when response is being created...
  given(sentTextMessage.getJMSReplyTo()).willReturn(null);
  TextMessage responseTextMessage = mock(TextMessage.class);
  final QueueSession session = mock(QueueSession.class);
  given(session.createTextMessage(RESPONSE_TEXT)).willReturn(responseTextMessage);
  ResponsiveMessageDelegate delegate = mock(ResponsiveMessageDelegate.class);
  given(delegate.handleMessage(sentTextMessage)).willReturn(RESPONSE_TEXT);
  final MessageListenerAdapter adapter = new MessageListenerAdapter(delegate) {
    @Override
    protected Object extractMessage(Message message) {
      return message;
    }
  };
  try {
    adapter.onMessage(sentTextMessage, session);
    fail("expected CouldNotSendReplyException with InvalidDestinationException");
  }
  catch (ReplyFailureException ex) {
    assertEquals(InvalidDestinationException.class, ex.getCause().getClass());
  }
  verify(responseTextMessage).setJMSCorrelationID(CORRELATION_ID);
  verify(delegate).handleMessage(sentTextMessage);
}

代码示例来源：origin: ca.uhn.hapi/hapi-base

/**
 * @see ca.uhn.hl7v2.protocol.JMSDestination#createMessage()
 */
public TextMessage createMessage() throws JMSException {
  return mySendingSession.createTextMessage();
}

代码示例来源：origin: ca.uhn.hapi/hapi-base

/**
 * @see ca.uhn.hl7v2.protocol.impl.AbstractJMSTransport#getMessage()
 */
protected Message getMessage() throws JMSException {        
  return mySendingSession.createTextMessage();
}

代码示例来源：origin: ca.uhn.hapi/hapi-osgi-base

/**
 * @see ca.uhn.hl7v2.protocol.impl.AbstractJMSTransport#getMessage()
 */
protected Message getMessage() throws JMSException {        
  return mySendingSession.createTextMessage();
}

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

@Override
public TextMessage createTextMessage(String text) throws JMSException {
  return next.createTextMessage(text);
}

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

@Override
public TextMessage createTextMessage() throws JMSException {
  return next.createTextMessage();
}

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

/**
 * @param text
 * @return
 * @throws JMSException
 */
public TextMessage createTextMessage(String text) throws JMSException {
  return next.createTextMessage(text);
}

代码示例来源：origin: ca.uhn.hapi/hapi-osgi-base

/**
 * @see ca.uhn.hl7v2.protocol.JMSDestination#createMessage()
 */
public TextMessage createMessage() throws JMSException {
  return mySendingSession.createTextMessage();
}

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

@Override
public TextMessage createTextMessage() throws JMSException {
  return next.createTextMessage();
}

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

@Override
public TextMessage createTextMessage() throws JMSException {
  return next.createTextMessage();
}

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

/**
 * @return
 * @throws JMSException
 */
public TextMessage createTextMessage() throws JMSException {
  return next.createTextMessage();
}

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

private void sendTextMessage(String payload) throws Exception {
  TextMessage tm = session.createTextMessage(payload);
  sender.send(tm);
}

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

private void sendTextMessage(String payload) throws Exception {
  TextMessage tm = session.createTextMessage(payload);
  sender.send(tm);
}

代码示例来源：origin: org.jboss.as/jboss-as-demos-legacy

public void sendMessage(String txt) throws Exception {
  QueueSender send = null;
  try {
    // Send a text msg
    send = session.createSender(queue);
    TextMessage tm = session.createTextMessage(txt);
    send.send(tm);
    log.info("-----> sent text=" + tm.getText());
  } finally {
    send.close();
  }
}

代码示例来源：origin: org.apache.jmeter/ApacheJMeter_jms

private TextMessage createMessage() throws JMSException {
  if (session == null) {
    throw new IllegalStateException("Session may not be null while creating message");
  }
  TextMessage msg = session.createTextMessage();
  msg.setText(getContent());
  addJMSProperties(msg);
  return msg;
}

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

@Override
  public JmsRecord processRecord(final StringRecord record) throws Exception {
    TextMessage message;
    message = queueSession.createTextMessage();
    message.setText(record.getPayload());
    return new JmsRecord(record.getHeader(), message);
  }
}

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

@Override
 public void onMessage(final Message m) {
   try {
    Destination queue = m.getJMSReplyTo();
    Message m2 = sess.createTextMessage("This is the response");
    sender.send(queue, m2);
   } catch (JMSException e) {
    log.error(e);
   }
 }
}