Examples of bindings()

Examples of org.apache.qpid.management.common.mbeans.ManagedExchange.bindings()

72
73
74
75
76
77
78
79
80
81
82
        ManagedExchange mbean = (ManagedExchange)managedObj;

        mbean.createNewBinding(_queue.getNameShortString().toString(), "binding1");
        mbean.createNewBinding(_queue.getNameShortString().toString(), "binding2");

        TabularData data = mbean.bindings();
        ArrayList<Object> list = new ArrayList<Object>(data.values());
        assertTrue(list.size() == 2);
    }

    public void testTopicExchangeMBean() throws Exception
View Full Code Here

Examples of org.apache.qpid.management.common.mbeans.ManagedExchange.bindings()

87
88
89
90
91
92
93
94
95
96
97
        ManagedExchange mbean = (ManagedExchange)managedObj;

        mbean.createNewBinding(_queue.getNameShortString().toString(), "binding1");
        mbean.createNewBinding(_queue.getNameShortString().toString(), "binding2");

        TabularData data = mbean.bindings();
        ArrayList<Object> list = new ArrayList<Object>(data.values());
        assertTrue(list.size() == 2);
    }

    public void testHeadersExchangeMBean() throws Exception
View Full Code Here

Examples of org.apache.qpid.management.common.mbeans.ManagedExchange.bindings()

101
102
103
104
105
106
107
108
109
110
111
        ManagedObject managedObj = exchange.getManagedObject();
        ManagedExchange mbean = (ManagedExchange)managedObj;

        mbean.createNewBinding(_queue.getNameShortString().toString(), "x-match=any,key1=binding1,key2=binding2");

        TabularData data = mbean.bindings();
        ArrayList<Object> list = new ArrayList<Object>(data.values());
        assertEquals("Unexpected number of bindings", 1, list.size());

        final Iterator<CompositeDataSupport> rowItr = (Iterator<CompositeDataSupport>) data.values().iterator();
        CompositeDataSupport row = rowItr.next();
View Full Code Here

Examples of org.apache.qpid.management.common.mbeans.ManagedExchange.bindings()

123
124
125
126
127
128
129
130
131
132
133
        ManagedObject managedObj = exchange.getManagedObject();
        ManagedExchange mbean = (ManagedExchange)managedObj;

        mbean.createNewBinding(_queue.getNameShortString().toString(), "x-match=any,key4,key5=");

        TabularData data = mbean.bindings();
        ArrayList<Object> list = new ArrayList<Object>(data.values());
        assertEquals("Unexpected number of bindings", 1, list.size());

        final Iterator<CompositeDataSupport> rowItr = (Iterator<CompositeDataSupport>) data.values().iterator();
        CompositeDataSupport row = rowItr.next();
View Full Code Here

Examples of org.apache.qpid.management.common.mbeans.ManagedExchange.bindings()

79
80
81
82
83
84
85
86
87
88
89
        final String queueName = getTestQueueName();
        final ManagedExchange defaultExchange = _jmxUtils.getManagedExchange(ExchangeDefaults.DEFAULT_EXCHANGE_NAME.asString());

        // Check that bind does not exist before queue creation
        assertFalse("Binding to " + queueName + " should not exist in default exchange before queue creation",
                     defaultExchange.bindings().containsKey(new String[] {queueName}));

        _managedBroker.createNewQueue(queueName, "testowner", true);

        // Ensure the queue exists
        assertNotNull("Queue object name expected to exist", _jmxUtils.getQueueObjectName("test", queueName));
View Full Code Here

Examples of org.apache.qpid.management.common.mbeans.ManagedExchange.bindings()

89
90
91
92
93
94
95
96
97
98
99
        assertNotNull("Queue object name expected to exist", _jmxUtils.getQueueObjectName("test", queueName));
        assertNotNull("Manager queue expected to be available", _jmxUtils.getManagedQueue(queueName));

        // Now verify that the default exchange has been bound.
        assertTrue("Binding to " + queueName + " should exist in default exchange after queue creation",
                     defaultExchange.bindings().containsKey(new String[] {queueName}));

        // Now delete the queue
        _managedBroker.deleteQueue(queueName);

        // Finally ensure that the binding has been removed.
View Full Code Here

Examples of org.apache.qpid.management.common.mbeans.ManagedExchange.bindings()

96
97
98
99
100
101
102
103
104
105
106
        // Now delete the queue
        _managedBroker.deleteQueue(queueName);

        // Finally ensure that the binding has been removed.
        assertFalse("Binding to " + queueName + " should not exist in default exchange after queue deletion",
                defaultExchange.bindings().containsKey(new String[] {queueName}));
    }

    /**
     * Tests exchange creation/deletion via JMX API.
     */
 
View Full Code Here

Examples of org.apache.qpid.management.common.mbeans.ManagedExchange.bindings()

383
384
385
386
387
388
389
390
391
392
393
        try
        {
            //verify the DLE exchange exists, has the expected type, and a single binding for the DLQ
            ManagedExchange exchange = jmxUtils.getManagedExchange(QUEUE_WITH_DLQ_NAME + "_DLE");
            assertEquals("Wrong exchange type", "fanout", exchange.getExchangeType());
            TabularDataSupport bindings = (TabularDataSupport) exchange.bindings();
            assertEquals(1, bindings.size());
            for(Object o : bindings.values())
            {
                CompositeData binding = (CompositeData) o;
View Full Code Here

Examples of xsul5.wsdl.WsdlDefinitions.bindings()

419
420
421
422
423
424
425
426
427
428
429
    }
   
   
   
//    find the binding for the operation in the service wsdl
    Iterable<WsdlBinding> serviceBindings = serviceWSDL.bindings();
    WsdlBinding serviceBinding = null;
    for (WsdlBinding wsdlBinding : serviceBindings) {
      if(wsdlBinding.getPortType().equals(servicePortType.getQName())){
        serviceBinding = wsdlBinding;
        break;
View Full Code Here

Examples of xsul5.wsdl.WsdlDefinitions.bindings()

29
30
31
32
33
34
35
36
37
38
39
public class WSDLCleaner {
 
 
  public static void cleanWSDL(WsdlDefinitions definition){
    WsdlDefinitions wsdl = definition;
    Iterable<WsdlBinding> bindings = wsdl.bindings();
    ArrayList<WsdlBinding> removedBindings = new ArrayList<WsdlBinding>();
    for (WsdlBinding wsdlBinding : bindings) {
      XmlElement innerBinding = wsdlBinding.xml().element("binding");
      if( null != innerBinding &&
          !"http://schemas.xmlsoap.org/wsdl/soap/".equals(innerBinding.getNamespace().getName())){
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. 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.