Package COM.activesw.api.client

Examples of COM.activesw.api.client.BrokerConnectionDescriptor


        if (connectionFactory instanceof QueueConnectionFactoryAdmin)
        {
            try
            {
                cfAdmin = (QueueConnectionFactoryAdmin) connectionFactory;
                final BrokerConnectionDescriptor bcd = new BrokerConnectionDescriptor();

                bcd.setConnectionShare(true);
               
                try
                {
                    bcd.setConnectionShareLimit(100); // some arbitary number to handle concurrent connection.
                }
                catch (NoSuchMethodError ex)
                {
                    // Old version of WebMethods
                }    
View Full Code Here


            throw new NamingException("providerURL (" + providerURL + ") is malformed, format is wme://brokerName@hostname:port");
        }

        try
        {
            BrokerConnectionDescriptor bcd = new BrokerConnectionDescriptor();

            bcd.setConnectionShare(true);
           
            try
            {
                bcd.setConnectionShareLimit(100); // some arbitary number to handle concurrent connection.
            }
            catch (NoSuchMethodError ex)
            {
                // Old version of WebMethods
            }
           
            bcd.setSharedEventOrdering(BrokerConnectionDescriptor.SHARED_ORDER_NONE);

            BrokerAdminClient adminClient = BrokerAdminClient.newOrReconnectAdmin(hostName + ":" + port, brokerName, "admin" + System.currentTimeMillis(), "admin",
                    WMEInitialContextFactory.class.getName(), bcd);

            Context ctx = new ContextImpl(environment);
View Full Code Here

TOP

Related Classes of COM.activesw.api.client.BrokerConnectionDescriptor

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.