List of bindings() Examples

Examples of bindings()

com.linkedin.data.schema.DataSchemaResolver.bindings()
Return a map of names to {@link NamedDataSchema} bindings that have been resolved. @return map of names to {@link NamedDataSchema} bindings that have been resolved.
com.sun.tools.ws.wsdl.document.Definitions.bindings()
net.tomp2p.connection.ChannelClientConfiguration.bindings()
@return The bindings
net.tomp2p.connection.ChannelServerConfiguration.bindings()
org.apache.qpid.management.common.mbeans.ManagedExchange.bindings()
Returns all the bindings this exchange has with the queues. @return the bindings with the exchange. @throws IOException @throws JMException
xsul5.wsdl.WsdlDefinitions.bindings()

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

        // 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()

        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 org.apache.qpid.management.common.mbeans.ManagedExchange.bindings()

        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);


        // test general exchange properties
        assertEquals(mbean.getName(), "amq.direct");

View Full Code Here

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

        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);


        // test general exchange properties
        assertEquals(mbean.getName(), "amq.topic");

View Full Code Here

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

        ManagedExchange mbean = (ManagedExchange)managedObj;


        mbean.createNewBinding(_queue.getNameShortString().toString(), "key1=binding1,key2=binding2");
        mbean.createNewBinding(_queue.getNameShortString().toString(), "key3=binding3");


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


        // test general exchange properties
        assertEquals(mbean.getName(), "amq.match");

View Full Code Here

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

        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 org.apache.qpid.management.common.mbeans.ManagedExchange.bindings()

        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 org.apache.qpid.management.common.mbeans.ManagedExchange.bindings()

        ManagedExchange mbean = (ManagedExchange)managedObj;


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


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


        // test general exchange properties
        assertEquals(mbean.getName(), "amq.direct");

View Full Code Here

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

        ManagedExchange mbean = (ManagedExchange)managedObj;


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


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


        // test general exchange properties
        assertEquals(mbean.getName(), "amq.topic");

View Full Code Here

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

        ManagedExchange mbean = (ManagedExchange)managedObj;


        mbean.createNewBinding(_queue.getName().toString(), "key1=binding1,key2=binding2");
        mbean.createNewBinding(_queue.getName().toString(), "key3=binding3");


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


        // test general exchange properties
        assertEquals(mbean.getName(), "amq.match");

View Full Code Here

0 1 2 3

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.