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.

       //Now route to condition2


       msg = CoreMessageFactory.createCoreMessage(2, persistentMessage, null);;      
       ref = ms.reference(msg);         


       routed = office2.route(ref, new SimpleCondition("condition2"), null);         
       assertTrue(routed.getResult());
       //Messages are sent asych so may take some finite time to arrive
       Thread.sleep(3000);


       for (int i = 0; i < 16; i++)

View Full Code Here

       //Now route to condition2


       msg = CoreMessageFactory.createCoreMessage(2, persistentMessage, null);;      
       ref = ms.reference(msg);         


       routed = office2.route(ref, new SimpleCondition("condition2"), null);         
       assertTrue(routed.getResult());
       //Messages are sent asych so may take some finite time to arrive
       Thread.sleep(3000);


       for (int i = 0; i < 16; i++)

View Full Code Here

       //  Route to myqueue1 from office 2      


       msg = CoreMessageFactory.createCoreMessage(2, persistentMessage, null);      
       ref = ms.reference(msg);         


       routed = office2.route(ref, new SimpleCondition("myqueue1"), null);         
       assertTrue(routed.getResult());


       //Messages are sent asych so may take some finite time to arrive
       Thread.sleep(3000);

View Full Code Here

       //Now route to condition2 from office 2


       msg = CoreMessageFactory.createCoreMessage(4, persistentMessage, null);;      
       ref = ms.reference(msg);         


       routed = office2.route(ref, new SimpleCondition("myqueue2"), null);         
       assertTrue(routed.getResult());
       //Messages are sent asych so may take some finite time to arrive
       Thread.sleep(3000);


       // Only queue3 should get the message

View Full Code Here

       //  Route to myqueue1 from office 2      


       msg = CoreMessageFactory.createCoreMessage(2, persistentMessage, null);      
       ref = ms.reference(msg);         


       routed = office2.route(ref, new SimpleCondition("myqueue1"), null);         
       assertTrue(routed.getResult());


       //Messages are sent asych so may take some finite time to arrive
       Thread.sleep(3000);

View Full Code Here

       //Now route to condition2 from office 2


       msg = CoreMessageFactory.createCoreMessage(4, persistentMessage, null);;      
       ref = ms.reference(msg);         


       routed = office2.route(ref, new SimpleCondition("myqueue2"), null);         
       assertTrue(routed.getResult());
       //Messages are sent asych so may take some finite time to arrive
       Thread.sleep(3000);


       // Only queue3 should get the message

View Full Code Here

         Message msg2 = CoreMessageFactory.createCoreMessage(2, persistentMessage, null);      
         MessageReference ref2 = ms.reference(msg2);
         
         Transaction tx = tr.createTransaction();
         
         RouteResult routed = postOffice.route(ref1, condition1, tx);            
         assertTrue(routed.getResult());
         routed = postOffice.route(ref2, condition1, tx);            
         assertTrue(routed.getResult());
               
         List msgs = queue1.browse(null);

View Full Code Here

         
         Transaction tx = tr.createTransaction();
         
         RouteResult routed = postOffice.route(ref1, condition1, tx);            
         assertTrue(routed.getResult());
         routed = postOffice.route(ref2, condition1, tx);            
         assertTrue(routed.getResult());
               
         List msgs = queue1.browse(null);
         assertNotNull(msgs);
         assertTrue(msgs.isEmpty());

View Full Code Here

         Message msg4 = CoreMessageFactory.createCoreMessage(4, persistentMessage, null);      
         MessageReference ref4 = ms.reference(msg4);
         
         tx = tr.createTransaction();
         
         routed = postOffice.route(ref3, condition1, tx);            
         assertTrue(routed.getResult());
         routed = postOffice.route(ref4, condition1, tx);            
         assertTrue(routed.getResult());
               
         msgs = queue1.browse(null);

View Full Code Here

         
         tx = tr.createTransaction();
         
         routed = postOffice.route(ref3, condition1, tx);            
         assertTrue(routed.getResult());
         routed = postOffice.route(ref4, condition1, tx);            
         assertTrue(routed.getResult());
               
         msgs = queue1.browse(null);
         assertNotNull(msgs);
         assertTrue(msgs.isEmpty());

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.