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

QueueSession.createReceiver介绍

[英]Creates a QueueReceiver object to receive messages from the specified queue.
[中]

代码示例

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

@Override
public QueueReceiver createReceiver(Queue queue) throws JMSException {
  return next.createReceiver(queue);
}

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

@Override
public QueueReceiver createReceiver(Queue queue, String messageSelector) throws JMSException {
  return next.createReceiver(queue, messageSelector);
}

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

protected MessageConsumer createConsumer() throws JMSException {
  // set up the consumer
  if (consumerConnection == null) return null;
  consumerSession = consumerConnection.createQueueSession(false, Session.CLIENT_ACKNOWLEDGE);
  MessageConsumer consumer = null;
  if (selector != null && selector.length() > 0) {
    consumer = consumerSession.createReceiver(consumerQueue, selector);
  } else {
    consumer = consumerSession.createReceiver(consumerQueue);
  }
  consumer.setMessageListener(this);
  return consumer;
}

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

@Override public QueueReceiver createReceiver(Queue queue) throws JMSException {
 checkQueueSession();
 QueueSession qs = (QueueSession) delegate;
 return TracingMessageConsumer.create(qs.createReceiver(queue), jmsTracing);
}

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

@Override public QueueReceiver createReceiver(Queue queue, String messageSelector)
  throws JMSException {
 checkQueueSession();
 QueueSession qs = (QueueSession) delegate;
 return TracingMessageConsumer.create(qs.createReceiver(queue, messageSelector), 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: 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: axis/axis

private QueueReceiver createReceiver(QueueSession session,
                   Queue queue,
                   String messageSelector)
  throws JMSException
{
  return session.createReceiver(queue, messageSelector);
}

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

private QueueReceiver createReceiver(QueueSession session,
                   Queue queue,
                   String messageSelector)
  throws JMSException
{
  return session.createReceiver(queue, messageSelector);
}

代码示例来源：origin: com.axway.ats.framework/ats-actionlibrary

@Override
public QueueReceiver createReceiver(
                   Queue queue ) throws JMSException {
  return addConsumer( ((QueueSession) session).createReceiver(queue));
}

代码示例来源：origin: com.axway.ats.framework/ats-actionlibrary

@Override
public QueueReceiver createReceiver(
                   Queue queue,
                   String messageSelector ) throws JMSException {
  return addConsumer(queueSession.createReceiver(queue, messageSelector));
}

代码示例来源：origin: org.objectweb.jonas/jonas-jms-manager

/**
 *
 */
public QueueReceiver createReceiver(Queue queue, String messageSelector) throws JMSException {
TraceJms.logger.log(BasicLevel.DEBUG, "");
return getMOMQueueSession().createReceiver(queue, messageSelector);
}

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

/**
* Test syntax of "<em>arithmetic-expr1</em> [NOT] BETWEEN <em>arithmetic-expr2</em> and <em>arithmetic-expr3</em>"
*/
@Test
public void testBetween() {
 try {
   receiver = receiverSession.createReceiver(receiverQueue, "age BETWEEN 15 and 19");
   receiver = receiverSession.createReceiver(receiverQueue, "age NOT BETWEEN 15 and 19");
 } catch (JMSException e) {
   fail(e);
 }
}

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

/**
* Test that identifiers can't be <code>TRUE</code>.
*/
@Test
public void testIdentifierTRUE() {
 try {
   receiver = receiverSession.createReceiver(receiverQueue, "TRUE > 0");
   Assert.fail("TRUE is not a valid identifier");
 } catch (JMSException e) {
 }
}

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

/**
* Test that identifiers can't be <code>BETWEEN</code>.
*/
@Test
public void testIdentifierBETWEEN() {
 try {
   receiver = receiverSession.createReceiver(receiverQueue, "BETWEEN > 0");
   Assert.fail("BETWEEN is not a valid identifier");
 } catch (JMSException e) {
 }
}

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

/**
* Test that identifiers can't be <code>LIKE</code>.
*/
@Test
public void testIdentifierLIKE() {
 try {
   receiver = receiverSession.createReceiver(receiverQueue, "LIKE > 0");
   Assert.fail("LIKE is not a valid identifier");
 } catch (JMSException e) {
 }
}

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

/**
* Test that identifiers can't be <code>FALSE</code>.
*/
@Test
public void testIdentifierFALSE() {
 try {
   receiver = receiverSession.createReceiver(receiverQueue, "FALSE > 0");
   Assert.fail("FALSE is not a valid identifier");
 } catch (JMSException e) {
 }
}

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

/**
* Test that identifiers can't be <code>ESCAPE</code>.
*/
@Test
public void testIdentifierESCAPE() {
 try {
   receiver = receiverSession.createReceiver(receiverQueue, "ESCAPE > 0");
   Assert.fail("ESCAPE is not a valid identifier");
 } catch (JMSException e) {
 }
}

代码示例来源：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()));
}

代码示例来源：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()));
}