Package org.jboss.jms.destination

Examples of org.jboss.jms.destination.JBossQueue

287
288
289
290
291
292
293
294
295
296
297
         if (dest == null)
         {
            throw new JMSException("There is no administratively defined queue with name:" + name);
         }       
  
         return new JBossQueue(dest.getName());
      }
      catch (Throwable t)
      {
         throw ExceptionUtil.handleJMSInvocation(t, this + " createQueue");
      }
View Full Code Here
1772
1773
1774
1775
1776
1777
1778
1779
1780
1781
1782
     
      String consumerID = GUIDGenerator.generateGUID();
           
      int prefetchSize = connectionEndpoint.getPrefetchSize();
     
      JBossDestination dest = new JBossQueue(queueName);
     
      //We don't care about redelivery delays and number of attempts for a direct consumer
     
      ServerConsumerEndpoint ep =
         new ServerConsumerEndpoint(consumerID, binding.queue,
View Full Code Here
90
91
92
93
94
95
96
97
98
99
100
  protected MessageSucker(Queue localQueue, Session sourceSession, Session localSession,
                boolean preserveOrdering, long sourceChannelID)
   { 
      if (trace) { log.trace("Creating message sucker, localQueue:" + localQueue + " preserveOrdering:" + preserveOrdering); }
     
      this.jbq = new JBossQueue(localQueue.getName(), true);
     
      this.localQueue = localQueue;
     
      this.sourceSession = sourceSession;
     
View Full Code Here
297
298
299
300
301
302
303
304
305
306
307
         if (dest == null)
         {
            throw new JMSException("There is no administratively defined queue with name:" + name);
         }

         return new JBossQueue(dest.getName());
      }
      catch (Throwable t)
      {
         throw ExceptionUtil.handleJMSInvocation(t, this + " createQueue");
      }
View Full Code Here
1825
1826
1827
1828
1829
1830
1831
1832
1833
1834
1835
      String consumerID = GUIDGenerator.generateGUID();

      int prefetchSize = connectionEndpoint.getPrefetchSize();

      JBossDestination dest = new JBossQueue(queueName);

      //We don't care about redelivery delays for a direct consumer
      //We do care about number of attempts, see JBMESSAGING-1774
      ServerConsumerEndpoint ep =
         new ServerConsumerEndpoint(consumerID, binding.queue,
View Full Code Here
443
444
445
446
447
448
449
450
451
         Iterator iter = suckers.values().iterator();
        
         while (iter.hasNext())
         {
            FakeMessageSucker sucker = (FakeMessageSucker)iter.next();
            sucker.updateQueue(new JBossQueue(queue.getQueueName()));
         }

      }
View Full Code Here
464
465
466
467
468
469
470
471
472
         Iterator iter = suckers.values().iterator();
        
         while (iter.hasNext())
         {
            FakeMessageSucker sucker = (FakeMessageSucker)iter.next();
            sucker.updateQueue(new JBossQueue(queue.getQueueName()));
         }

      }
View Full Code Here
606
607
608
609
610
611
612
613
614
615
616
      JBossDestination jbd2;
     
      if (isQueue())
      {
         jbd2 = new JBossQueue("PageableAttributes");
      }
      else
      {
         jbd2 = new JBossTopic("PageableAttributes");
      }
View Full Code Here
459
460
461
462
463
464
465
466
467
         Iterator iter = suckers.values().iterator();
        
         while (iter.hasNext())
         {
            FakeMessageSucker sucker = (FakeMessageSucker)iter.next();
            sucker.updateQueue(new JBossQueue(queue.getQueueName()));
         }

      }
View Full Code Here
577
578
579
580
581
582
583
584
585
      // Session
     
      public void testSessionCreateConsumerDelegateRequest() throws Exception
      {
         RequestSupport req =
            new SessionCreateConsumerDelegateRequest("23", (byte)77, new JBossQueue("wibble"), null, false, null, false, true);
                
         testPacket(req, PacketSupport.REQ_SESSION_CREATECONSUMERDELEGATE);                          
      }
View Full Code Here
TOP

Related Classes of org.jboss.jms.destination.JBossQueue

  • org.jboss.jms.server.DestinationJNDIMapper
  • org.jboss.jms.server.endpoint.ServerSessionEndpoint
  • org.jboss.messaging.core.impl.clusterconnection.MessageSucker
  • org.jboss.test.messaging.jms.BrowserTest
  • org.jboss.test.messaging.jms.clustering.FakeClusterConnectionManager$FakeConnectionInfo
  • org.jboss.test.messaging.jms.DLQTest
  • org.jboss.test.messaging.jms.ExpiryQueueTest
  • org.jboss.test.messaging.jms.message.MessageHeaderTestBase
  • org.jboss.test.messaging.jms.message.MessageTest
  • org.jboss.test.messaging.jms.MessageProxyTest
    • 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.