Package org.jboss.jms.destination

Examples of org.jboss.jms.destination.JBossQueue

585
586
587
588
589
590
591
592
593
      }
     
      public void testSessionCreateBrowserDelegateRequest() throws Exception
      {
         RequestSupport req =
            new SessionCreateBrowserDelegateRequest("23", (byte)77, new JBossQueue("wibble"), null);
                
         testPacket(req, PacketSupport.REQ_SESSION_CREATEBROWSERDELEGATE);                          
      }
View Full Code Here
844
845
846
847
848
849
850
851
852
      }
     
      public void testSessionCreateQueueResponse() throws Exception
      {
         ResponseSupport resp =
            new SessionCreateQueueResponse(new JBossQueue("ijoij"));
                
         testPacket(resp, PacketSupport.RESP_SESSION_CREATEQUEUE);                          
      }
View Full Code Here
309
310
311
312
313
314
315
316
317
318
319
         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
1989
1990
1991
1992
1993
1994
1995
1996
1997
1998
1999
      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
130
131
132
133
134
135
136
137
138
139
140
        
         JBossDestination jbDest;
        
         if (destination.isQueue())
         {
            jbDest = new JBossQueue(destination.getName());
         }
         else
         {
            jbDest = new JBossTopic(destination.getName());
         }
View Full Code Here
210
211
212
213
214
215
216
217
218
219
220
         {
            destinations.add(new JBossTemporaryQueue(dest.getName()));
         }
         else
         {
            destinations.add(new JBossQueue(dest.getName()));
         }
      }
     
      iter = topicMap.values().iterator();
      while (iter.hasNext())
View Full Code Here
89
90
91
92
93
94
95
96
97
98
99
  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
199
200
201
202
203
204
205
206
207
208
209
         JBossMessage check1 = ((MessageProxy)m).getMessage();
        
         m.setString("map_entry", "map_value");        
         m.setStringProperty("property_entry", "property_value");  
        
         m.setJMSReplyTo(new JBossQueue("wibble"));
        
         JBossMessage check2 = ((MessageProxy)m).getMessage();
        
         checkSameUnderlyingMessage(check1, check2, true);
         checkSameBody(check1, check2, true);
View Full Code Here
435
436
437
438
439
440
441
442
443
         Iterator iter = suckers.values().iterator();
        
         while (iter.hasNext())
         {
            FakeMessageSucker sucker = (FakeMessageSucker)iter.next();
            sucker.updateQueue(new JBossQueue(queue.getQueueName()));
         }

      }
View Full Code Here
312
313
314
315
316
317
318
319
320
321
322
         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
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.