Package org.apache.qpid.server.binding

Examples of org.apache.qpid.server.binding.BindingImpl

138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
                        _exchange.isBound(_routingKey));
        assertTrue("Queue was not bound to key",
                    _exchange.isBound(_routingKey,_queue));
        assertEquals("Exchange binding count", 1,
                     _queue.getBindings().size());
        final BindingImpl firstBinding = _queue.getBindings().iterator().next();
        assertEquals("Wrong exchange bound", _routingKey,
                     firstBinding.getBindingKey());
        assertEquals("Wrong exchange bound", _exchange,
                     firstBinding.getExchange());

        _exchange.deleteBinding(_routingKey, _queue);
        assertFalse("Routing key was still bound",
                _exchange.isBound(_routingKey));
View Full Code Here
90
91
92
93
94
95
96
97
98
99
100
    }

    public void testNoRoute() throws Exception
    {
        AMQQueue<?> queue = createQueue("a*#b");
        _exchange.registerQueue(new BindingImpl(null, "a.*.#.b",queue, _exchange, null));


        routeMessage("a.b", 0l);

        Assert.assertEquals(0, queue.getQueueDepthMessages());
View Full Code Here
101
102
103
104
105
106
107
108
109
110
111
    }

    public void testDirectMatch() throws Exception
    {
        AMQQueue<?> queue = createQueue("ab");
        _exchange.registerQueue(new BindingImpl(null, "a.b",queue, _exchange, null));


        routeMessage("a.b",0l);

        Assert.assertEquals(1, queue.getQueueDepthMessages());
View Full Code Here
123
124
125
126
127
128
129
130
131
132
133

    public void testStarMatch() throws Exception
    {
        AMQQueue<?> queue = createQueue("a*");
        _exchange.registerQueue(new BindingImpl(null, "a.*",queue, _exchange, null));


        routeMessage("a.b",0l);

        Assert.assertEquals(1, queue.getQueueDepthMessages());
View Full Code Here
154
155
156
157
158
159
160
161
162
163
164
    }

    public void testHashMatch() throws Exception
    {
        AMQQueue<?> queue = createQueue("a#");
        _exchange.registerQueue(new BindingImpl(null, "a.#",queue, _exchange, null));


        routeMessage("a.b.c",0l);

        Assert.assertEquals(1, queue.getQueueDepthMessages());
View Full Code Here
205
206
207
208
209
210
211
212
213
214
215

    public void testMidHash() throws Exception
    {
        AMQQueue<?> queue = createQueue("a");
        _exchange.registerQueue(new BindingImpl(null, "a.*.#.b",queue, _exchange, null));

        routeMessage("a.c.d.b",0l);

        Assert.assertEquals(1, queue.getQueueDepthMessages());

View Full Code Here
230
231
232
233
234
235
236
237
238
239
240
    }

    public void testMatchAfterHash() throws Exception
    {
        AMQQueue<?> queue = createQueue("a#");
        _exchange.registerQueue(new BindingImpl(null, "a.*.#.b.c",queue, _exchange, null));


        int queueCount = routeMessage("a.c.b.b",0l);
        Assert.assertEquals("Message should not route to any queues", 0, queueCount);

View Full Code Here
268
269
270
271
272
273
274
275
276
277
278

    public void testHashAfterHash() throws Exception
    {
        AMQQueue<?> queue = createQueue("a#");
        _exchange.registerQueue(new BindingImpl(null, "a.*.#.b.c.#.d",queue, _exchange, null));

        int queueCount = routeMessage("a.c.b.b.c",0l);
        Assert.assertEquals("Message should not route to any queues", 0, queueCount);

        Assert.assertEquals(0, queue.getQueueDepthMessages());
View Full Code Here
289
290
291
292
293
294
295
296
297
298
299
    }

    public void testHashHash() throws Exception
    {
        AMQQueue<?> queue = createQueue("a#");
        _exchange.registerQueue(new BindingImpl(null, "a.#.*.#.d",queue, _exchange, null));

        int queueCount = routeMessage("a.c.b.b.c",0l);
        Assert.assertEquals("Message should not route to any queues", 0, queueCount);

        Assert.assertEquals(0, queue.getQueueDepthMessages());
View Full Code Here
310
311
312
313
314
315
316
317
318
319
320
    }

    public void testSubMatchFails() throws Exception
    {
        AMQQueue<?> queue = createQueue("a");
        _exchange.registerQueue(new BindingImpl(null, "a.b.c.d",queue, _exchange, null));

        int queueCount = routeMessage("a.b.c",0l);
        Assert.assertEquals("Message should not route to any queues", 0, queueCount);

        Assert.assertEquals(0, queue.getQueueDepthMessages());
View Full Code Here
TOP

Related Classes of org.apache.qpid.server.binding.BindingImpl

  • org.apache.qpid.server.configuration.updater.VoidTask
  • org.apache.qpid.server.exchange.AbstractExchange
  • org.apache.qpid.server.exchange.HeadersBindingTest
  • org.apache.qpid.server.exchange.HeadersExchange
  • org.apache.qpid.server.exchange.TopicExchangeTest
  • org.apache.qpid.server.logging.subjects.BindingLogSubject
  • org.apache.qpid.server.queue.AbstractQueueTestBase
  • org.apache.qpid.server.queue.AMQQueue
  • org.apache.qpid.server.security.SecurityManagerTest
  • org.apache.qpid.server.store.AbstractDurableConfigurationStoreTestCase
    • 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.