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

QueueSession.createSender介绍

[英]Creates a QueueSender object to send messages to the specified queue.
[中]创建QueueSender对象以将消息发送到指定队列。

代码示例

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

@Override
public QueueSender createSender(Queue queue) throws JMSException {
  return next.createSender(queue);
}

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

protected synchronized MessageProducer createProducer() throws JMSException {
  if (producerConnection == null) return null;
  producerSession = producerConnection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
  producer = producerSession.createSender(null);
  return producer;
}

代码示例来源：origin: openzipkin/brave

@Override public QueueSender createSender(Queue queue) throws JMSException {
 checkQueueSession();
 QueueSession qs = (QueueSession) delegate;
 return TracingMessageProducer.create(qs.createSender(queue), jmsTracing);
}

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

/** Constructor for the {@code QueueRequestor} class.
 *  
 * <P>This implementation assumes the session parameter to be non-transacted,
 * with a delivery mode of either {@code AUTO_ACKNOWLEDGE} or 
 * {@code DUPS_OK_ACKNOWLEDGE}.
 *
 * @param session the {@code QueueSession} the queue belongs to
 * @param queue the queue to perform the request/reply call on
 *  
 * @exception JMSException if the JMS provider fails to create the
 *                         {@code QueueRequestor} due to some internal
 *                         error.
 * @exception InvalidDestinationException if an invalid queue is specified.
 */ 
public
QueueRequestor(QueueSession session, Queue queue) throws JMSException {
  
  if (queue==null) throw new InvalidDestinationException("queue==null");
  
  this.session = session;
  tempQueue    = session.createTemporaryQueue();
  sender       = session.createSender(queue);
  receiver     = session.createReceiver(tempQueue);
}

代码示例来源：origin: quartz-scheduler/quartz

.getString(JmsHelper.JMS_DESTINATION_JNDI));
sender = sess.createSender(queue);

代码示例来源：origin: org.apache.geronimo.specs/geronimo-jms_1.1_spec

public QueueRequestor(QueueSession session, Queue queue)
  throws JMSException
{
  super();
  if(queue == null) {
    throw new InvalidDestinationException("Invalid queue");
  }
  
  setSession(session);
  setTemporaryQueue(session.createTemporaryQueue());
  setSender(session.createSender(queue));
  setReceiver(session.createReceiver(getTemporaryQueue()));
}

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

this.queueSender = queueSession.createSender(queue);

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

protected synchronized MessageProducer createProducer() throws JMSException {
  if (producerConnection == null) return null;
  producerSession = producerConnection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
  producer = producerSession.createSender(null);
  return producer;
}

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

protected SendSession createSendSession(javax.jms.Connection connection)
  throws JMSException
{
  QueueSession session = createQueueSession((QueueConnection)connection,
                JMSConstants.DEFAULT_ACKNOWLEDGE_MODE);
  QueueSender sender = session.createSender(null);
  return new QueueSendSession(session, sender);
}

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

protected SendSession createSendSession(javax.jms.Connection connection)
  throws JMSException
{
  QueueSession session = createQueueSession((QueueConnection)connection,
                JMSConstants.DEFAULT_ACKNOWLEDGE_MODE);
  QueueSender sender = session.createSender(null);
  return new QueueSendSession(session, sender);
}

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

protected synchronized MessageProducer createProducer() throws JMSException {
  if (producerConnection == null) return null;
  producerSession = producerConnection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
  producer = producerSession.createSender(null);
  return producer;
}

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

protected synchronized MessageProducer createProducer() throws JMSException {
  if (producerConnection == null) return null;
  producerSession = producerConnection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
  producer = producerSession.createSender(null);
  return producer;
}

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

protected synchronized MessageProducer createProducer() throws JMSException {
  producerSession = producerConnection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
  producer = producerSession.createSender(null);
  return producer;
}

代码示例来源：origin: org.jboss.javaee/jboss-jms-api

public QueueRequestor(QueueSession session, Queue queue) throws JMSException
{
 queueSession = session;
 requestSender = queueSession.createSender(queue);
 replyQueue = queueSession.createTemporaryQueue();
 replyReceiver = queueSession.createReceiver(replyQueue);
}

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

@Override
public void open() throws Exception {
  queueConnection = queueConnectionFactory.createQueueConnection();
  queueSession = queueConnection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
  queueSender = queueSession.createSender(queue);
}

代码示例来源：origin: org.jboss.seam/jboss-seam

@Create
public void create() throws JMSException, NamingException
{
 queueSender = org.jboss.seam.jms.QueueSession.instance().createSender( getQueue() );
}

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

public QueueSender getQueueSender(Queue destination) throws JMSException {
  QueueSender result = null;
  if (useAnonymousProducers) {
    result = safeGetSessionHolder().getOrCreateSender();
  } else {
    result = ((QueueSession) getInternalSession()).createSender(destination);
  }
  return result;
}

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

public QueueRequestor(QueueSession session, Queue queue)
  throws JMSException
{
  super();
  if(queue == null) {
    throw new InvalidDestinationException("Invalid queue");
  }
  
  setSession(session);
  setTemporaryQueue(session.createTemporaryQueue());
  setSender(session.createSender(queue));
  setReceiver(session.createReceiver(getTemporaryQueue()));
}

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

public QueueRequestor(QueueSession session, Queue queue)
  throws JMSException
{
  super();
  if(queue == null) {
    throw new InvalidDestinationException("Invalid queue");
  }
  
  setSession(session);
  setTemporaryQueue(session.createTemporaryQueue());
  setSender(session.createSender(queue));
  setReceiver(session.createReceiver(getTemporaryQueue()));
}

代码示例来源：origin: org.apache.openejb/javaee-api

public QueueRequestor(QueueSession session, Queue queue)
  throws JMSException
{
  super();
  if(queue == null) {
    throw new InvalidDestinationException("Invalid queue");
  }
  
  setSession(session);
  setTemporaryQueue(session.createTemporaryQueue());
  setSender(session.createSender(queue));
  setReceiver(session.createReceiver(getTemporaryQueue()));
}