List of bindingQuery() Examples

Examples of bindingQuery()

org.hornetq.api.core.client.ClientSession.bindingQuery()
Queries information on a binding. @param address the address of the biding to query @return a BindingQuery containing information on the binding attached to the given address @throws HornetQException if an exception occurs while querying the binding

Examples of org.hornetq.api.core.client.ClientSession.bindingQuery()

         clientSession.createQueue("a1", "q1", false);
         clientSession.createQueue("a1", "q2", false);
         clientSession.createQueue("a2", "q3", false);
         clientSession.createQueue("a2", "q4", false);
         clientSession.createQueue("a2", "q5", false);
         BindingQuery resp = clientSession.bindingQuery(new SimpleString("a"));
         List<SimpleString> queues = resp.getQueueNames();
         Assert.assertTrue(queues.isEmpty());
         resp = clientSession.bindingQuery(new SimpleString("a1"));
         queues = resp.getQueueNames();
         Assert.assertEquals(queues.size(), 2);

View Full Code Here

Examples of org.hornetq.api.core.client.ClientSession.bindingQuery()

         clientSession.createQueue("a2", "q4", false);
         clientSession.createQueue("a2", "q5", false);
         BindingQuery resp = clientSession.bindingQuery(new SimpleString("a"));
         List<SimpleString> queues = resp.getQueueNames();
         Assert.assertTrue(queues.isEmpty());
         resp = clientSession.bindingQuery(new SimpleString("a1"));
         queues = resp.getQueueNames();
         Assert.assertEquals(queues.size(), 2);
         Assert.assertTrue(queues.contains(new SimpleString("q1")));
         Assert.assertTrue(queues.contains(new SimpleString("q2")));
         resp = clientSession.bindingQuery(new SimpleString("a2"));

View Full Code Here

Examples of org.hornetq.api.core.client.ClientSession.bindingQuery()

         resp = clientSession.bindingQuery(new SimpleString("a1"));
         queues = resp.getQueueNames();
         Assert.assertEquals(queues.size(), 2);
         Assert.assertTrue(queues.contains(new SimpleString("q1")));
         Assert.assertTrue(queues.contains(new SimpleString("q2")));
         resp = clientSession.bindingQuery(new SimpleString("a2"));
         queues = resp.getQueueNames();
         Assert.assertEquals(queues.size(), 3);
         Assert.assertTrue(queues.contains(new SimpleString("q3")));
         Assert.assertTrue(queues.contains(new SimpleString("q4")));
         Assert.assertTrue(queues.contains(new SimpleString("q5")));

View Full Code Here

Examples of org.hornetq.api.core.client.ClientSession.bindingQuery()

    @Test
    public void createQueue() throws HornetQException {
        final ClientSession clientSession = hornetQMixIn.getClientSession();
        final SimpleString queueName = new SimpleString("testQueue");
        clientSession.createQueue(queueName, queueName);
        final BindingQuery bindingQuery = clientSession.bindingQuery(queueName);
        Assert.assertTrue(bindingQuery.isExists());
        Assert.assertEquals(1, bindingQuery.getQueueNames().size());
        final SimpleString actualQueueName = bindingQuery.getQueueNames().get(0);
        Assert.assertEquals(queueName, actualQueueName);
    }

View Full Code Here

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.