Package org.apache.qpid.server.binding

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

234
235
236
237
238
239
240
241
        matchHeaders.setString("A", "Value of A");
        matchHeaders.setString("B", "Value of B");
        matchHeaders.setString("C", "Value of C");

        BindingImpl b = new BindingImpl(null, getQueueName(), _queue, _exchange, bindHeaders);
        assertTrue(new HeadersBinding(b).matches(matchHeaders));
    }
View Full Code Here
248
249
250
251
252
253
254
255
        matchHeaders.setString("A", "Value of A");
        matchHeaders.setString("B", "Altered value of B");
        matchHeaders.setString("C", "Value of C");

        BindingImpl b = new BindingImpl(null, getQueueName(), _queue, _exchange, bindHeaders);
        assertFalse(new HeadersBinding(b).matches(matchHeaders));
    }
View Full Code Here
259
260
261
262
263
264
265
266
        bindHeaders.put("X-match", "any");
        bindHeaders.put("A", "Value of A");

        matchHeaders.setString("A", "Value of A");

        BindingImpl b = new BindingImpl(null, getQueueName(), _queue, _exchange, bindHeaders);
        assertTrue(new HeadersBinding(b).matches(matchHeaders));
    }
View Full Code Here
271
272
273
274
275
276
277
278
        bindHeaders.put("A", "Value of A");
        bindHeaders.put("B", "Value of B");

        matchHeaders.setString("A", "Value of A");

        BindingImpl b = new BindingImpl(null, getQueueName(), _queue, _exchange, bindHeaders);
        assertTrue(new HeadersBinding(b).matches(matchHeaders));
    }
View Full Code Here
284
285
286
287
288
289
290
291
        bindHeaders.put("B", "Value of B");

        matchHeaders.setString("A", "Value of A");
        matchHeaders.setString("B", "Value of B");

        BindingImpl b = new BindingImpl(null, getQueueName(), _queue, _exchange, bindHeaders);
        assertTrue(new HeadersBinding(b).matches(matchHeaders));
    }
View Full Code Here
298
299
300
301
302
303
304
305
        matchHeaders.setString("A", "Value of A");
        matchHeaders.setString("B", "Value of B");
        matchHeaders.setString("C", "Value of C");

        BindingImpl b = new BindingImpl(null, getQueueName(), _queue, _exchange, bindHeaders);
        assertTrue(new HeadersBinding(b).matches(matchHeaders));
    }
View Full Code Here
312
313
314
315
316
317
318
319
        matchHeaders.setString("A", "Value of A");
        matchHeaders.setString("B", "Altered value of B");
        matchHeaders.setString("C", "Value of C");

        BindingImpl b = new BindingImpl(null, getQueueName(), _queue, _exchange, bindHeaders);
        assertTrue(new HeadersBinding(b).matches(matchHeaders));
    }
View Full Code Here
326
327
328
329
330
331
332
333
        matchHeaders.setString("A", "Altered value of A");
        matchHeaders.setString("B", "Altered value of B");
        matchHeaders.setString("C", "Value of C");

        BindingImpl b = new BindingImpl(null, getQueueName(), _queue, _exchange, bindHeaders);
        assertFalse(new HeadersBinding(b).matches(matchHeaders));
    }
View Full Code Here
581
582
583
584
585
586
587
588
589
590
591
592
    @Override
    public boolean replaceBinding(final String bindingKey,
                                  final AMQQueue queue,
                                  final Map<String, Object> arguments)
    {
        final BindingImpl existingBinding = getBinding(bindingKey, queue);
        return makeBinding(existingBinding == null ? null : existingBinding.getId(),
                           bindingKey,
                           queue,
                           arguments,
                           false,
                           true);
View Full Code Here
612
613
614
615
616
617
618
619
620
621
622
623
624
625
626
627
628
629
630
631
        }

        // Check access
        _virtualHost.getSecurityManager().authoriseUnbind(this, bindingKey, queue);

        BindingImpl b = _bindingsMap.remove(new BindingIdentifier(bindingKey,queue));

        if (b != null)
        {
            doRemoveBinding(b);
            queue.removeBinding(b);

            if (b.isDurable())
            {
                DurableConfigurationStoreHelper.removeBinding(_virtualHost.getDurableConfigurationStore(), b);
            }
            b.delete();
        }

    }
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.