Examples of org.jboss.messaging.core.contract.PostOffice.route()

Package org.jboss.messaging.core.contract

Class org.jboss.messaging.core.contract.PostOffice

Examples of org.jboss.messaging.core.contract.PostOffice.route()

org.jboss.messaging.core.contract.PostOffice.route()
Route a reference. @param condition - the message will be routed to queue(s) if the specified condition matches thecondition of the bindings. @param tx - the transaction or null if not in the context of a transaction. @return true if reference was accepted by at least one queue.

         queue3.getLocalDistributor().add(receiver3);
         
         Message msg1 = CoreMessageFactory.createCoreMessage(1);      
         MessageReference ref1 = ms.reference(msg1);
         
         RouteResult routed = postOffice.route(ref1, condition1, null);      
         assertTrue(routed.getResult());
         
         List msgs = receiver1.getMessages();
         assertNotNull(msgs);
         assertEquals(1, msgs.size());

View Full Code Here

         msg1 = CoreMessageFactory.createCoreMessage(1);      
         ref1 = ms.reference(msg1);
         
         try
         {
            postOffice.route(ref1, condition1, null);      
            fail("Didn't get expected exception");
         }
         catch (IllegalStateException e)
         {
            //ignore

View Full Code Here

         
         msg1 = CoreMessageFactory.createCoreMessage(1);      
         ref1 = ms.reference(msg1);


         //all received
         routed = postOffice.route(ref1, condition1, null);      
         assertTrue(routed.getResult());
         
         msgs = receiver1.getMessages();
         assertNotNull(msgs);
         assertEquals(1, msgs.size());

View Full Code Here

         queue2.setFailure(true);
         
         Message msg1 = CoreMessageFactory.createCoreMessage(1);
         MessageReference ref1 = ms.reference(msg1);
         
         RouteResult routed = postOffice.route(ref1, condition1, null);      
         assertTrue(routed.isFailue());
      }
      finally
      {
         if (postOffice != null)

View Full Code Here

         assertTrue(queue6.isActive());
         
         Message msg1 = CoreMessageFactory.createCoreMessage(1, persistentMessage, null);      
         MessageReference ref1 = ms.reference(msg1);
         
         RouteResult routed = postOffice.route(ref1, condition1, null);      
         assertTrue(routed.getResult());
         
         List msgs = receiver1.getMessages();
         assertNotNull(msgs);
         assertEquals(1, msgs.size());

View Full Code Here

         
         
         Message msg2 = CoreMessageFactory.createCoreMessage(2, persistentMessage, null);      
         MessageReference ref2 = ms.reference(msg2);
         
         routed = postOffice.route(ref2, condition2, null);      
         assertTrue(routed.getResult());
         
         msgs = receiver4.getMessages();
         assertNotNull(msgs);
         assertEquals(1, msgs.size());

View Full Code Here

       SimpleReceiver receiver4 = new SimpleReceiver("blah", SimpleReceiver.ACCEPTING);
       queue4.getLocalDistributor().add(receiver4);


       Message msg1 = CoreMessageFactory.createCoreMessage(1, true, null);      
       MessageReference ref1 = ms.reference(msg1);  
       boolean routed = office1.route(ref1, new SimpleCondition("condition1"), null);   
       assertTrue(routed);


       Message msg2 = CoreMessageFactory.createCoreMessage(2, true, null);      
       MessageReference ref2 = ms.reference(msg2);         
       routed = office1.route(ref2, new SimpleCondition("condition1"), null);

View Full Code Here

       boolean routed = office1.route(ref1, new SimpleCondition("condition1"), null);   
       assertTrue(routed);


       Message msg2 = CoreMessageFactory.createCoreMessage(2, true, null);      
       MessageReference ref2 = ms.reference(msg2);         
       routed = office1.route(ref2, new SimpleCondition("condition1"), null);      
       assertTrue(routed);


       Message msg3 = CoreMessageFactory.createCoreMessage(3, true, null);      
       MessageReference ref3 = ms.reference(msg3);         
       routed = office1.route(ref3, new SimpleCondition("condition1"), null);

View Full Code Here

       routed = office1.route(ref2, new SimpleCondition("condition1"), null);      
       assertTrue(routed);


       Message msg3 = CoreMessageFactory.createCoreMessage(3, true, null);      
       MessageReference ref3 = ms.reference(msg3);         
       routed = office1.route(ref3, new SimpleCondition("condition1"), null);      
       assertTrue(routed);


       Thread.sleep(3000);
       
       List msgs = receiver1.getMessages();

View Full Code Here

         msg2 = CoreMessageFactory.createCoreMessage(2, persistent, null);     
         ref2 = ms.reference(msg2);
         
         tx = tr.createTransaction();


         routed = office2.route(ref1, new SimpleCondition("condition2"), tx);         
         assertTrue(routed);
         routed = office2.route(ref2, new SimpleCondition("condition2"), tx);         
         assertTrue(routed);
                           
         for (int i = 0; i < 16; i++)

View Full Code Here

0 1 2 3 4 5

TOP

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.