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

QueueSession.createBrowser介绍

[英]Creates a QueueBrowser object to peek at the messages on the specified queue.
[中]创建QueueBrowser对象以查看指定队列上的消息。

代码示例

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

@Override
public QueueBrowser createBrowser(Queue queue) throws JMSException {
  return next.createBrowser(queue);
}

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

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

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

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

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

@Override
public QueueBrowser createBrowser(Queue queue) throws JMSException {
  return next.createBrowser(queue);
}

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

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

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

@Override
public QueueBrowser createBrowser(Queue queue) throws JMSException {
  return next.createBrowser(queue);
}

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

/**
 * @param queue
 * @param messageSelector
 * @return
 * @throws JMSException
 */
public QueueBrowser createBrowser(Queue queue, String messageSelector) throws JMSException {
  return next.createBrowser(queue, messageSelector);
}

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

/**
 * @param queue
 * @return
 * @throws JMSException
 */
public QueueBrowser createBrowser(Queue queue) throws JMSException {
  return next.createBrowser(queue);
}

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

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

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

@Override
public QueueBrowser createBrowser(Queue queue) throws JMSException {
  return next.createBrowser(queue);
}

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

public void setUp()
{
 try
 {
   super.setUp();
   receiverBrowser = receiverSession.createBrowser(receiverQueue);
   senderBrowser = senderSession.createBrowser(senderQueue);
 }
 catch (JMSException e)
 {
   throw new NestedRuntimeException(e);
 }
}

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

protected QueueBrowser createBrowser(Session session, Queue queue, String messageSelector) throws JMSException {
  if (isPubSubDomain()) {
    throw new javax.jms.IllegalStateException("Cannot create QueueBrowser for a TopicSession");
  } else {
    return ((QueueSession) session).createBrowser(queue, messageSelector);
  }
}

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

protected QueueBrowser createBrowser(Session session, Queue queue, String messageSelector)
    throws JMSException {
  if (isPubSubDomain()) {
    throw new javax.jms.IllegalStateException("Cannot create QueueBrowser for a TopicSession");
  }
  else {
    return ((QueueSession) session).createBrowser(queue, messageSelector);
  }
}

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

/**
 *
 */
public QueueBrowser createBrowser(Queue queue) throws JMSException {
TraceJms.logger.log(BasicLevel.DEBUG, "");
return getMOMQueueSession().createBrowser(queue);
}

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

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

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

// Create the connection
InitialContext context = new InitialContext(properties);
QueueConnectionFactory queueConnFactory = (QueueConnectionFactory) context.lookup("ConnectionFactory");
QueueConnection conn = queueConnFactory.createQueueConnection();
Queue queue = (Queue) context.lookup("/queue/Test");
QueueSession session = conn.createQueueSession(false, QueueSession.AUTO_ACKNOWLEDGE);

// Start the connection
conn.start()

// Create a QueueBrowser using the session
QueueBrowser queueBrowser = session.createBrowser(queue);
Enumeration e = queueBrowser.getEnumeration();

// Iterate through the queue
while(e.hasMoreElements()) {
  Message msg = (Message) e.nextElement();
  TextMessage txtMsg = (TextMessage) msg;

  System.out.println(txtMsg.getText());
}

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

/**
* Test that a call to the <code>createBrowser()</code> method with an invalid
* <code>Queue</code> throws a <code>javax.jms.InvalidDestinationException</code>.
*/
public void testCreateBrowser_1()
{
 try
 {
   senderSession.createBrowser((Queue) null);
   fail("Should throw a javax.jms.InvalidDestinationException.\n");
 }
 catch (InvalidDestinationException e)
 {
 }
 catch (JMSException e)
 {
   fail("Should throw a javax.jms.InvalidDestinationException, not a " + e);
 }
}

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

@Override
@Before
public void setUp() throws Exception {
 try {
   super.setUp();
   receiverBrowser = receiverSession.createBrowser(receiverQueue);
   senderBrowser = senderSession.createBrowser(senderQueue);
 } catch (JMSException e) {
   throw new RuntimeException(e);
 }
}

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

/**
* Test that a call to the <code>createBrowser()</code> method with an invalid
* <code>Queue</code> throws a <code>javax.jms.InvalidDestinationException</code>.
*/
@Test
public void testCreateBrowser_1() {
 try {
   senderSession.createBrowser((Queue) null);
   Assert.fail("Should throw a javax.jms.InvalidDestinationException.\n");
 } catch (InvalidDestinationException e) {
 } catch (JMSException e) {
   Assert.fail("Should throw a javax.jms.InvalidDestinationException, not a " + e);
 }
}

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

/**
* Test that a call to the <code>createBrowser()</code> method with an invalid
* messaeg session throws a <code>javax.jms.InvalidSelectorException</code>.
*/
@Test
public void testCreateBrowser_2() {
 try {
   senderSession.createBrowser(senderQueue, "definitely not a message selector!");
   Assert.fail("Should throw a javax.jms.InvalidSelectorException.\n");
 } catch (InvalidSelectorException e) {
 } catch (JMSException e) {
   Assert.fail("Should throw a javax.jms.InvalidSelectorException, not a " + e);
 }
}