Package javax.jms

Examples of javax.jms.ServerSessionPool

154
155
156
157
158
159
160
161
162
163
164
   * @throws JMSException if creation of the ServerSessionPool failed
   * @see #setServerSessionFactory
   * @see ServerSessionFactory#getServerSession(ListenerSessionManager)
   */
  protected ServerSessionPool createServerSessionPool() throws JMSException {
    return new ServerSessionPool() {
      public ServerSession getServerSession() throws JMSException {
        logger.debug("JMS ConnectionConsumer requests ServerSession");
        return getServerSessionFactory().getServerSession(ServerSessionMessageListenerContainer.this);
      }
    };
View Full Code Here
701
702
703
704
705
706
707
708
709
710
711
      QueueSender sender = session.createSender(testQueue);
      sender.send(session.createTextMessage("Hi"));
      sender.send(session.createTextMessage("There"));
      sender.send(session.createTextMessage("Guys"));
      queueConnection.createConnectionConsumer(testQueue, null, new ServerSessionPool()
      {
         public ServerSession getServerSession()
         {
            Logger.getLogger(getClass().getName()).debug("Getting server session.");
            return new ServerSession()
View Full Code Here
135
136
137
138
139
140
141
142
      }
      finally {
        JmsUtils.closeSession(session);
      }
    }
    ServerSessionPool pool = createServerSessionPool();
    this.consumer = createConsumer(con, destination, pool);
  }
View Full Code Here
150
151
152
153
154
155
156
157
158
159
160
   * @throws JMSException if creation of the ServerSessionPool failed
   * @see #setServerSessionFactory
   * @see ServerSessionFactory#getServerSession(ListenerSessionManager)
   */
  protected ServerSessionPool createServerSessionPool() throws JMSException {
    return new ServerSessionPool() {
      public ServerSession getServerSession() throws JMSException {
        logger.debug("JMS ConnectionConsumer requests ServerSession");
        return getServerSessionFactory().getServerSession(ServerSessionMessageListenerContainer.this);
      }
    };
View Full Code Here
137
138
139
140
141
142
143
144
      }
      finally {
        JmsUtils.closeSession(session);
      }
    }
    ServerSessionPool pool = createServerSessionPool();
    this.consumer = createConsumer(con, destination, pool);
  }
View Full Code Here
152
153
154
155
156
157
158
159
160
161
162
   * @throws JMSException if creation of the ServerSessionPool failed
   * @see #setServerSessionFactory
   * @see ServerSessionFactory#getServerSession(ListenerSessionManager)
   */
  protected ServerSessionPool createServerSessionPool() throws JMSException {
    return new ServerSessionPool() {
      public ServerSession getServerSession() throws JMSException {
        logger.debug("JMS ConnectionConsumer requests ServerSession");
        return getServerSessionFactory().getServerSession(ServerSessionMessageListenerContainer.this);
      }
    };
View Full Code Here
667
668
669
670
671
672
673
674
675
676
677
        Session session = connection.createSession(true, Session.AUTO_ACKNOWLEDGE);
        Queue destination = session.createQueue(QUEUE_NAME);

        final CountDownLatch connectionConsumerGotOne = new CountDownLatch(1);
        final Session poolSession = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
        connection.createConnectionConsumer(destination, null, new ServerSessionPool() {
            public ServerSession getServerSession() throws JMSException {
                return new ServerSession() {
                    public Session getSession() throws JMSException {
                        return poolSession;
                    }
View Full Code Here
650
651
652
653
654
655
656
657
658
659
660
        Session session = connection.createSession(true, Session.AUTO_ACKNOWLEDGE);
        Queue destination = session.createQueue(QUEUE_NAME);

        final CountDownLatch connectionConsumerGotOne = new CountDownLatch(1);
        final Session poolSession = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
        connection.createConnectionConsumer(destination, null, new ServerSessionPool() {
            public ServerSession getServerSession() throws JMSException {
                return new ServerSession() {
                    public Session getSession() throws JMSException {
                        return poolSession;
                    }
View Full Code Here
735
736
737
738
739
740
741
742
743
744
745
      MethodInvocation mi = (MethodInvocation)invocation;
     
      JBossDestination dest = (JBossDestination)mi.getArguments()[0];
      String subscriptionName = (String)mi.getArguments()[1];
      String messageSelector = (String)mi.getArguments()[2];
      ServerSessionPool sessionPool = (ServerSessionPool)mi.getArguments()[3];
      int maxMessages = ((Integer)mi.getArguments()[4]).intValue();
     
      return new JBossConnectionConsumer((ConnectionDelegate)mi.getTargetObject(), dest,
                                         subscriptionName, messageSelector, sessionPool,
                                         maxMessages);
View Full Code Here
623
624
625
626
627
628
629
630
631
632
633
         xaconn.start();
         XASession xasession = xaconn.createXASession();
         DummyListener listener = new DummyListener();
         xasession.setMessageListener(listener);

         ServerSessionPool pool = new MockServerSessionPool(xasession);

         xaconn.createConnectionConsumer(queue1, null, pool, 1);

         Thread.sleep(1000);
         assertEquals(1, listener.messages.size());
View Full Code Here
TOP

Related Classes of javax.jms.ServerSessionPool

  • org.apache.activemq.RedeliveryPolicyTest
  • org.apache.activemq.transport.failover.FailoverTransactionTest
  • org.jboss.jms.client.container.SessionAspect
  • org.jboss.test.jbossmessaging.test.JBossJMSUnitTest
  • org.jboss.test.jbossmessaging.test.Jms11UnitTest
  • org.jboss.test.messaging.jms.ConnectionConsumerTest
  • org.jboss.test.messaging.jms.OrderingGroupConnectionConsumerTest
  • org.jboss.test.messaging.jms.XATest
  • org.springframework.jms.listener.serversession.ServerSessionMessageListenerContainer
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.