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

Package org.jboss.messaging.core.contract

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

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

org.jboss.messaging.core.contract.PostOffice.addBinding()
Add a binding to the post office @param binding The binding to add @param allNodes Add this binding on ALL nodes? @throws Exception

         Condition condition1 = new SimpleCondition("topic1");
         
         FakeCoreQueue queue1 =  new FakeCoreQueue("queue1", 1);
         queue1.activate();


         postOffice.addBinding(new Binding(condition1, queue1, false), false);
         
         FakeCoreQueue queue2 =  new FakeCoreQueue("queue2", 2);
         queue2.activate();
         
         postOffice.addBinding(new Binding(condition1, queue2, false), false);

View Full Code Here

         postOffice.addBinding(new Binding(condition1, queue1, false), false);
         
         FakeCoreQueue queue2 =  new FakeCoreQueue("queue2", 2);
         queue2.activate();
         
         postOffice.addBinding(new Binding(condition1, queue2, false), false);
         
         FakeCoreQueue queue3 = new FakeCoreQueue("queue3", 3);
         queue3.activate();
         
         postOffice.addBinding(new Binding(condition1, queue3, false), false);

View Full Code Here

         postOffice.addBinding(new Binding(condition1, queue2, false), false);
         
         FakeCoreQueue queue3 = new FakeCoreQueue("queue3", 3);
         queue3.activate();
         
         postOffice.addBinding(new Binding(condition1, queue3, false), false);
         
         queue2.setFailure(true);
         
         Message msg1 = CoreMessageFactory.createCoreMessage(1);
         MessageReference ref1 = ms.reference(msg1);

View Full Code Here

         Condition condition1 = new SimpleCondition("topic1");
         
         MessagingQueue queue1 = new MessagingQueue(1, "queue1", channelIDManager.getID(), ms, pm, false, -1, null, false);
         queue1.activate();
         
         postOffice.addBinding(new Binding(condition1, queue1, false), false);
         
         MessagingQueue queue2 = new MessagingQueue(1, "queue2", channelIDManager.getID(), ms, pm, false, -1, null, false);
         queue2.activate();
         
         postOffice.addBinding(new Binding(condition1, queue2, false), false);

View Full Code Here

         postOffice.addBinding(new Binding(condition1, queue1, false), false);
         
         MessagingQueue queue2 = new MessagingQueue(1, "queue2", channelIDManager.getID(), ms, pm, false, -1, null, false);
         queue2.activate();
         
         postOffice.addBinding(new Binding(condition1, queue2, false), false);
         
         MessagingQueue queue3 = new MessagingQueue(1, "queue3", channelIDManager.getID(), ms, pm, false, -1, null, false);
         queue3.activate();
         
         postOffice.addBinding(new Binding(condition1, queue3, false), false);

View Full Code Here

         postOffice.addBinding(new Binding(condition1, queue2, false), false);
         
         MessagingQueue queue3 = new MessagingQueue(1, "queue3", channelIDManager.getID(), ms, pm, false, -1, null, false);
         queue3.activate();
         
         postOffice.addBinding(new Binding(condition1, queue3, false), false);
         
         MessagingQueue queue4 = new MessagingQueue(1, "queue4", channelIDManager.getID(), ms, pm, true, -1, null, false);
         queue4.activate();
         
         Condition condition2 = new SimpleCondition("topic2");

View Full Code Here

         MessagingQueue queue4 = new MessagingQueue(1, "queue4", channelIDManager.getID(), ms, pm, true, -1, null, false);
         queue4.activate();
         
         Condition condition2 = new SimpleCondition("topic2");
         
         postOffice.addBinding(new Binding(condition2, queue4, false), false);
         
         MessagingQueue queue5 = new MessagingQueue(1, "queue5", channelIDManager.getID(), ms, pm, true, -1, null, false);
         queue5.activate();
         
         postOffice.addBinding(new Binding(condition2, queue5, false), false);

View Full Code Here

         postOffice.addBinding(new Binding(condition2, queue4, false), false);
         
         MessagingQueue queue5 = new MessagingQueue(1, "queue5", channelIDManager.getID(), ms, pm, true, -1, null, false);
         queue5.activate();
         
         postOffice.addBinding(new Binding(condition2, queue5, false), false);
         
         MessagingQueue queue6 = new MessagingQueue(1, "queue6", channelIDManager.getID(), ms, pm, true, -1, null, false);
         queue6.activate();
         
         postOffice.addBinding(new Binding(condition2, queue6, false), false);

View Full Code Here

         postOffice.addBinding(new Binding(condition2, queue5, false), false);
         
         MessagingQueue queue6 = new MessagingQueue(1, "queue6", channelIDManager.getID(), ms, pm, true, -1, null, false);
         queue6.activate();
         
         postOffice.addBinding(new Binding(condition2, queue6, false), false);
      
         SimpleReceiver receiver1 = new SimpleReceiver("blah", SimpleReceiver.ACCEPTING);;
         queue1.getLocalDistributor().add(receiver1);
         SimpleReceiver receiver2 = new SimpleReceiver("blah", SimpleReceiver.ACCEPTING);;
         queue2.getLocalDistributor().add(receiver2);

View Full Code Here

         // Add another binding on node 3
                  
         Queue queue5 = new MessagingQueue(3, "sub5", channelIDManager.getID(), ms, pm, false, -1, null, true);
         queue5.activate();
         
         added = office3.addBinding(new Binding(condition1, queue5, false), false);
         assertTrue(added);
         
         // Make sure all nodes pick it up
         
         queues = office1.getQueuesForCondition(condition1, false);

View Full Code Here

0 1 2 3 4 5 6 7 8 9

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.