Examples of org.apache.axis.transport.jms.JMSTransport

org.apache.axis.transport.jms.JMSTransport
JMSTransport is the JMS-specific implemenation of org.apache.axis.client.Transport. It implements the setupMessageContextImpl() function to set JMS-specific message context fields and transport chains. Connector and connection factory properties are passed in during instantiation and are in turn passed through when creating a connector. @author Jaime Meritt (jmeritt@sonicsoftware.com) @author Richard Chung (rchung@sonicsoftware.com) @author Dave Chappell (chappell@sonicsoftware.com)

            printUsage();


        Service  service = new Service(new XMLStringProvider(wsdd));


        // create the transport
        JMSTransport transport = new JMSTransport(connectorMap, cfMap);


        // create a new Call object
        Call     call    = (Call) service.createCall();


        call.setOperationName( new QName("urn:xmltoday-delayed-quotes", "getQuote") );
        call.addParameter( "symbol", XMLType.XSD_STRING, ParameterMode.IN );
        call.setReturnType( XMLType.XSD_FLOAT );
        call.setTransport(transport);


        // set additional params on the call if desired
        //call.setUsername(username );
        //call.setPassword(password );
        //call.setProperty(JMSConstants.WAIT_FOR_RESPONSE, Boolean.FALSE);
        //call.setProperty(JMSConstants.PRIORITY, new Integer(5));
        //call.setProperty(JMSConstants.DELIVERY_MODE,
        //    new Integer(javax.jms.DeliveryMode.PERSISTENT));
        //call.setProperty(JMSConstants.TIME_TO_LIVE, new Long(20000));


        call.setProperty(JMSConstants.DESTINATION, destination);
        call.setTimeout(new Integer(10000));


        Float res = new Float(0.0F);


        // invoke a call for each of the symbols and print out
        for (int i = 0; i < args.length; i++) {
            res = (Float) call.invoke(new Object[] {args[i]});
            System.out.println(args[i] + ": " + res);
        }


        // shutdown
        listener.shutdown();
        transport.shutdown();
    }

View Full Code Here

            }
            cfProps.put(JMSConstants.CONNECTION_FACTORY_CLASS, cf);
        }


        // create the transport
        JMSTransport transport = new JMSTransport(null, cfProps);


        // create a new Call object
        Call     call    = (Call) service.createCall();


        call.setOperationName( new QName("urn:xmltoday-delayed-quotes", "getQuote") );
        call.addParameter( "symbol", XMLType.XSD_STRING, ParameterMode.IN );
        call.setReturnType( XMLType.XSD_FLOAT );
        call.setTransport(transport);


        // set additional params on the call if desired


        //call.setUsername(opts.getUser() );
        //call.setPassword(opts.getPassword() );


        //call.setProperty(JMSConstants.WAIT_FOR_RESPONSE, Boolean.FALSE);
        //call.setProperty(JMSConstants.PRIORITY, new Integer(5));
        //call.setProperty(JMSConstants.DELIVERY_MODE,
        //    new Integer(javax.jms.DeliveryMode.PERSISTENT));
        //call.setProperty(JMSConstants.TIME_TO_LIVE, new Long(20000));


        call.setProperty(JMSConstants.DESTINATION, "SampleQ1");
        call.setTimeout(new Integer(10000));


        Float res = new Float(0.0F);


        // invoke a call for each of the symbols and print out
        for (int i = 0; i < symbols.length; i++) {
            res = (Float) call.invoke(new Object[] {symbols[i]});
            System.out.println(symbols[i] + ": " + res);
        }


        // shutdown
        listener.shutdown();
        transport.shutdown();
    }

View Full Code Here

            printUsage();


        Service  service = new Service(new XMLStringProvider(wsdd));


        // create the transport
        JMSTransport transport = new JMSTransport(connectorMap, cfMap);


        // create a new Call object
        Call     call    = (Call) service.createCall();


        call.setOperationName( new QName("urn:xmltoday-delayed-quotes", "getQuote") );
        call.addParameter( "symbol", XMLType.XSD_STRING, ParameterMode.IN );
        call.setReturnType( XMLType.XSD_FLOAT );
        call.setTransport(transport);


        // set additional params on the call if desired
        //call.setUsername(username );
        //call.setPassword(password );
        //call.setProperty(JMSConstants.WAIT_FOR_RESPONSE, Boolean.FALSE);
        //call.setProperty(JMSConstants.PRIORITY, new Integer(5));
        //call.setProperty(JMSConstants.DELIVERY_MODE,
        //    new Integer(javax.jms.DeliveryMode.PERSISTENT));
        //call.setProperty(JMSConstants.TIME_TO_LIVE, new Long(20000));


        call.setProperty(JMSConstants.DESTINATION, destination);
        call.setTimeout(new Integer(10000));


        Float res = new Float(0.0F);


        // invoke a call for each of the symbols and print out
        for (int i = 0; i < args.length; i++)
        {
            try
            {
            res = (Float) call.invoke(new Object[] {args[i]});
            System.out.println(args[i] + ": " + res);
            }
            catch(AxisFault af)
            {
                System.out.println(af.dumpToString());
            }
        }


        // shutdown
        listener.shutdown();
        transport.shutdown();
    }

View Full Code Here

            printUsage();


        Service  service = new Service(new XMLStringProvider(wsdd));


        // create the transport
        JMSTransport transport = new JMSTransport(connectorMap, cfMap);


        // create a new Call object
        Call     call    = (Call) service.createCall();


        call.setOperationName( new QName("urn:xmltoday-delayed-quotes", "getQuote") );
        call.addParameter( "symbol", XMLType.XSD_STRING, ParameterMode.IN );
        call.setReturnType( XMLType.XSD_FLOAT );
        call.setTransport(transport);


        // set additional params on the call if desired
        //call.setUsername(username );
        //call.setPassword(password );
        //call.setProperty(JMSConstants.WAIT_FOR_RESPONSE, Boolean.FALSE);
        //call.setProperty(JMSConstants.PRIORITY, new Integer(5));
        //call.setProperty(JMSConstants.DELIVERY_MODE,
        //    new Integer(javax.jms.DeliveryMode.PERSISTENT));
        //call.setProperty(JMSConstants.TIME_TO_LIVE, new Long(20000));


        call.setProperty(JMSConstants.DESTINATION, destination);
        call.setTimeout(new Integer(10000));


        Float res = new Float(0.0F);


        // invoke a call for each of the symbols and print out
        for (int i = 0; i < args.length; i++)
        {
            try
            {
            res = (Float) call.invoke(new Object[] {args[i]});
            System.out.println(args[i] + ": " + res);
            }
            catch(AxisFault af)
            {
                System.out.println(af.dumpToString());
            }
        }


        // shutdown
        listener.shutdown();
        transport.shutdown();
    }

View Full Code Here

            printUsage();


        Service  service = new Service(new XMLStringProvider(wsdd));


        // create the transport
        JMSTransport transport = new JMSTransport(connectorMap, cfMap);


        // create a new Call object
        Call     call    = (Call) service.createCall();


        call.setOperationName( new QName("urn:xmltoday-delayed-quotes", "getQuote") );
        call.addParameter( "symbol", XMLType.XSD_STRING, ParameterMode.IN );
        call.setReturnType( XMLType.XSD_FLOAT );
        call.setTransport(transport);


        // set additional params on the call if desired
        //call.setUsername(username );
        //call.setPassword(password );
        //call.setProperty(JMSConstants.WAIT_FOR_RESPONSE, Boolean.FALSE);
        //call.setProperty(JMSConstants.PRIORITY, new Integer(5));
        //call.setProperty(JMSConstants.DELIVERY_MODE,
        //    new Integer(javax.jms.DeliveryMode.PERSISTENT));
        //call.setProperty(JMSConstants.TIME_TO_LIVE, new Long(20000));


        call.setProperty(JMSConstants.DESTINATION, destination);
        call.setTimeout(new Integer(10000));


        Float res = new Float(0.0F);


        // invoke a call for each of the symbols and print out
        for (int i = 0; i < args.length; i++)
        {
            try
            {
            res = (Float) call.invoke(new Object[] {args[i]});
            System.out.println(args[i] + ": " + res);
            }
            catch(AxisFault af)
            {
                System.out.println(af.dumpToString());
            }
        }


        // shutdown
        listener.shutdown();
        transport.shutdown();
    }

View Full Code Here

TOP

Related Classes of org.apache.axis.transport.jms.JMSTransport

org.apache.axis.AxisFault

org.apache.axis.components.jms.JMSVendorAdapter

samples.jms.JMSTest

java.util.Iterator

java.util.HashMap

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.