Java 类javax.jms.QueueBrowser 实例源码

项目：pooled-jms 文件：JmsQueueBrowserTest.java

@Test
public void testGetQueue() throws JMSException {
    JmsPoolConnection connection = (JmsPoolConnection) cf.createQueueConnection();
    QueueSession session = connection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
    Queue queue = session.createTemporaryQueue();
    QueueBrowser browser = session.createBrowser(queue);

    assertNotNull(browser.getQueue());

    browser.close();
    browser.close();

    try {
        browser.getQueue();
        fail("Should not be able to use a closed browser");
    } catch (IllegalStateException ise) {
    }
}

项目：pooled-jms 文件：JmsQueueBrowserTest.java

@Test
public void testGetMessageSelector() throws JMSException {
    JmsPoolConnection connection = (JmsPoolConnection) cf.createQueueConnection();
    QueueSession session = connection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
    Queue queue = session.createTemporaryQueue();
    QueueBrowser browser = session.createBrowser(queue, "color = red");

    assertNotNull(browser.getMessageSelector());
    assertEquals("color = red", browser.getMessageSelector());

    browser.close();

    try {
        browser.getMessageSelector();
        fail("Should not be able to use a closed browser");
    } catch (IllegalStateException ise) {
    }
}

项目：pooled-jms 文件：JmsQueueBrowserTest.java

@Test
public void testGetEnumeration() throws JMSException {
    JmsPoolConnection connection = (JmsPoolConnection) cf.createQueueConnection();
    QueueSession session = connection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
    Queue queue = session.createTemporaryQueue();
    QueueBrowser browser = session.createBrowser(queue);

    assertNotNull(browser.getEnumeration());

    browser.close();

    try {
        browser.getEnumeration();
        fail("Should not be able to use a closed browser");
    } catch (IllegalStateException ise) {
    }
}

项目：jaffa-framework 文件：LockingService.java

/** Browses all pending messages in the input queue looking for the locks, as specified in the input filter.
 * Throws an ApplicationException, if any matching message is found, and if the input argument 'deleteLockingMessage' is false.
 * Deletes all matching messages, if the input argument 'deleteLockingMessage' is true.
 * @param queueName the queue name.
 * @param filter the filter for retrieving Lock messages.
 * @param deleteLockingMessage determines if the matching messages are to be deleted.
 * @param session the JMS session.
 * @throws JMSException if any JMS error occurs.
 * @throws FrameworkException Indicates some system error.
 * @throws ApplicationExceptions Indicates application error(s).
 */
private static void checkOrDeleteLockingPendingMessages(String queueName, String filter, boolean deleteLockingMessage, Session session)
throws JMSException, ApplicationExceptions, FrameworkException {
    // Creates a QueueBrowser from the Session, using the filter
    if (log.isDebugEnabled())
        log.debug("Checking for locks in pending messages in " + queueName + " with the filter " + filter);
    QueueBrowser qb = session.createBrowser(JmsClientHelper.obtainQueue(queueName), filter);

    // Throws an ApplicationException if any applicable lock is found
    Enumeration e = qb.getEnumeration();
    while (e.hasMoreElements()) {
        Message message = (Message) e.nextElement();
        if (log.isDebugEnabled())
            log.debug("Found a blocking pending message in " + queueName + " with the contents " + message);
        if (deleteLockingMessage)
            JmsBrowser.consumeMessage(session, message, queueName);
        else
            throw new ApplicationExceptions(new JaffaMessagingApplicationException(JaffaMessagingApplicationException.LOCK_ERROR, new Object[] {queueName, message.getJMSMessageID()}));
    }

    // Close the QueueBrowser
    qb.close();
}

项目：spring4-understanding 文件：JmsTemplate.java

@Override
public <T> T browseSelected(final Queue queue, final String messageSelector, final BrowserCallback<T> action)
        throws JmsException {

    Assert.notNull(action, "Callback object must not be null");
    return execute(new SessionCallback<T>() {
        @Override
        public T doInJms(Session session) throws JMSException {
            QueueBrowser browser = createBrowser(session, queue, messageSelector);
            try {
                return action.doInJms(session, browser);
            }
            finally {
                JmsUtils.closeQueueBrowser(browser);
            }
        }
    }, true);
}

项目：spring4-understanding 文件：JmsTemplate.java

@Override
public <T> T browseSelected(final String queueName, final String messageSelector, final BrowserCallback<T> action)
        throws JmsException {

    Assert.notNull(action, "Callback object must not be null");
    return execute(new SessionCallback<T>() {
        @Override
        public T doInJms(Session session) throws JMSException {
            Queue queue = (Queue) getDestinationResolver().resolveDestinationName(session, queueName, false);
            QueueBrowser browser = createBrowser(session, queue, messageSelector);
            try {
                return action.doInJms(session, browser);
            }
            finally {
                JmsUtils.closeQueueBrowser(browser);
            }
        }
    }, true);
}

项目：rabbitmq-jms-samples 文件：BrowseConfig.java

@Profile("browse")
@Bean
public QueueBrowser queueBrowser(Session queueSession, AMQPProperties amqpProperties, JMSProperties jmsProperties) {
    QueueBrowser messageBrowser = null;
    try {
        if(amqpProperties.amqpExchangeName != null && !"".equals(amqpProperties.amqpExchangeName)) {
            log.info("Not a valid option for queue browser");
            messageBrowser = queueSession.createBrowser(queueSession.createQueue(jmsProperties.queueName));
        }
        else {
            log.info("Creating QueueBrowser using JMS Queue obj for queueName="+jmsProperties.queueName);
            messageBrowser = queueSession.createBrowser(queueSession.createQueue(jmsProperties.queueName));
        }
    } catch (JMSException e) {
        e.printStackTrace();
    }
    return messageBrowser;
}

项目：eHMP 文件：JmsSyncErrorDaoTests.java

@Before
public void setUp() throws Exception {
    mockJmsSession = mock(Session.class);
    mockJmsQueueBrowser = mock(QueueBrowser.class);
    mockJmsTemplate = mock(JmsOperations.class);
    mockConversionService = mock(ConversionService.class);
    mockQueueMBean = mock(QueueViewMBean.class);
    mockErrorDao = mock(IVprSyncErrorDao.class);

    syncService = new SyncService();
    syncService.setConversionService(mockConversionService);
    syncService.setErrorDao(mockErrorDao);
    syncService.setJmsTemplate(mockJmsTemplate);
    syncService.setVprDeadLetterQueueMBean(mockQueueMBean);

    when(mockJmsTemplate.browse(eq(MessageDestinations.DEAD_LETTER_QUEUE), any(BrowserCallback.class))).thenAnswer(new ReturnsBrowserCallbackArgument<Object>(mockJmsSession, mockJmsQueueBrowser));
}

项目：activemq-artemis 文件：JMSUsecaseTest.java

@Test
public void testQueueBrowser() throws Exception {
   // Send a message to the broker.
   connection.start();
   Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
   ActiveMQDestination destination = createDestination(session, destinationType);
   MessageProducer producer = session.createProducer(destination);
   producer.setDeliveryMode(this.deliveryMode);
   sendMessages(session, producer, 5);
   producer.close();

   QueueBrowser browser = session.createBrowser((Queue) destination);
   Enumeration<?> enumeration = browser.getEnumeration();
   for (int i = 0; i < 5; i++) {
      Thread.sleep(100);
      assertTrue(enumeration.hasMoreElements());
      Message m = (Message) enumeration.nextElement();
      assertNotNull(m);
      assertEquals("" + i, ((TextMessage) m).getText());
   }
   assertFalse(enumeration.hasMoreElements());
}

项目：activemq-artemis 文件：JMSConnectionWithSecurityTest.java

@Test(timeout = 30000)
public void testBrowserNotAuthorized() throws Exception {
   Connection connection = createConnection(noprivUser, noprivPass);

   try {
      Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
      javax.jms.Queue queue = session.createQueue(getQueueName());
      try {
         QueueBrowser browser = session.createBrowser(queue);
         // Browser is not created until an enumeration is requesteda
         browser.getEnumeration();
         fail("Should not be able to consume here.");
      } catch (JMSSecurityException jmsSE) {
         IntegrationTestLogger.LOGGER.info("Caught expected exception");
      }
   } finally {
      connection.close();
   }
}