Examples of org.apache.axis2.transport.jms.JMSListener

org.apache.axis2.transport.jms.JMSListener
The JMS Transport listener implementation. A JMS Listner will hold one or more JMS connection factories, which would be created at initialization time. This implementation does not support the creation of connection factories at runtime. This JMS Listener registers with Axis to be notified of service deployment/undeployment/start and stop, and enables or disables listening for messages on the destinations as appropriate.
A Service could state the JMS connection factory name and the destination name for use as Parameters in its services.xml as shown in the example below. If the connection name was not specified, it will use the connection factory named "default" (JMSConstants.DEFAULT_CONFAC_NAME) - if such a factory is defined in the Axis2.xml. If the destination name is not specified it will default to a JMS queue by the name of the service. If the destination should be a Topic, it should be created on the JMS implementation, and specified in the services.xml of the service.
myTopicConnectionFactory dynamicTopics/something.TestTopic

                    deployedURI = servletHost.addServletMapping(endpointURI, servlet);
                }
            } else if (deployedURI.startsWith("jms")) {
                logger.log(Level.INFO, "Axis2 JMS URL=" + deployedURI);


                jmsListener = new JMSListener();
                jmsSender = new JMSSender();
                ListenerManager listenerManager = configContext.getListenerManager();
                TransportInDescription trsIn =
                    configContext.getAxisConfiguration().getTransportIn(org.apache.axis2.Constants.TRANSPORT_JMS);

View Full Code Here

                    //[nash] configContext.setContextRoot(endpointURL);
                    servletHost.addServletMapping(endpointURL, servlet);
                } else if (endpointURL.startsWith("jms")) {
                    logger.log(Level.INFO,"Axis2 JMS URL=" + endpointURL);
                    
                    jmsListener = new JMSListener();
                    jmsSender = new JMSSender();
                    ListenerManager listenerManager = configContext.getListenerManager();
                    TransportInDescription trsIn = configContext.getAxisConfiguration().getTransportIn(Constants.TRANSPORT_JMS);
                                    
                    // get JMS transport parameters from the computed URL

View Full Code Here

                    //[nash] configContext.setContextRoot(endpointURL);
                    servletHost.addServletMapping(endpointURL, servlet);
                } else if (endpointURL.startsWith("jms")) {
                    logger.log(Level.INFO,"Axis2 JMS URL=" + endpointURL);
                    
                    jmsListener = new JMSListener();
                    jmsSender = new JMSSender();
                    ListenerManager listenerManager = configContext.getListenerManager();
                    TransportInDescription trsIn = configContext.getAxisConfiguration().getTransportIn(Constants.TRANSPORT_JMS);
                                    
                    // get JMS transport parameters from the computed URL

View Full Code Here

                    //[nash] configContext.setContextRoot(endpointURL);
                    servletHost.addServletMapping(endpointURL, servlet);
                } else if (endpointURL.startsWith("jms")) {
                    logger.log(Level.INFO, "Axis2 JMS URL=" + endpointURL);


                    jmsListener = new JMSListener();
                    jmsSender = new JMSSender();
                    ListenerManager listenerManager = configContext.getListenerManager();
                    TransportInDescription trsIn =
                        configContext.getAxisConfiguration().getTransportIn(Constants.TRANSPORT_JMS);

View Full Code Here

        try {
            Thread.sleep(2000);
        } catch (InterruptedException e1) {
            throw new AxisFault("Thread interuptted", e1);
        }
        receiver = new JMSListener();
        ListenerManager listenerManager = configurationContext.getListenerManager();
        TransportInDescription trsIn =
                configurationContext.getAxisConfiguration().getTransportIn(Constants.TRANSPORT_JMS);
        trsIn.setReceiver(receiver);
        if (listenerManager == null) {

View Full Code Here

        String axis2xml = repository + "/conf/axis2.xml";
        
        ConfigurationContext configurationContext = ConfigurationContextFactory
                .createConfigurationContextFromFileSystem(repository, axis2xml);
        
        JMSListener receiver = new JMSListener();
        ListenerManager listenerManager = configurationContext
                .getListenerManager();
        TransportInDescription trsIn = configurationContext
                .getAxisConfiguration().getTransportIn(Constants.TRANSPORT_JMS);
        trsIn.setReceiver(receiver);
        if (listenerManager == null) {
            listenerManager = new ListenerManager();
            listenerManager.init(configurationContext);
        }
        listenerManager.addListener(trsIn, true);
        receiver.init(configurationContext, trsIn);
        receiver.start();
    }

View Full Code Here

                    //[nash] configContext.setContextRoot(endpointURL);
                    servletHost.addServletMapping(endpointURL, servlet);
                } else if (endpointURL.startsWith("jms")) {
                    logger.log(Level.INFO,"Axis2 JMS URL=" + endpointURL);
                    
                    jmsListener = new JMSListener();
                    jmsSender = new JMSSender();
                    ListenerManager listenerManager = configContext.getListenerManager();
                    TransportInDescription trsIn = configContext.getAxisConfiguration().getTransportIn(Constants.TRANSPORT_JMS);
                                    
                    // get JMS transport parameters from the computed URL

View Full Code Here

                configContext.setContextRoot(servletURI);
                servletHost.addServletMapping(servletURI, servlet);
            } else if ( axisService.getEndpointURL().startsWith( "jms" ) ) {
                logger.log(Level.INFO,"Axis2 JMS URL=" + axisService.getEndpointURL() );
                
                jmsListener = new JMSListener();
                jmsSender = new JMSSender();
                ListenerManager listenerManager = configContext.getListenerManager();
                TransportInDescription trsIn = configContext.getAxisConfiguration().getTransportIn(Constants.TRANSPORT_JMS);
                                
                // get JMS transport parameters from the binding uri

View Full Code Here

                    deployedURI = servletHost.addServletMapping(endpointURI, servlet);
                }
            } else if (deployedURI.startsWith("jms")) {
                logger.log(Level.INFO, "Axis2 JMS URL=" + deployedURI);


                jmsListener = new JMSListener();
                jmsSender = new JMSSender();
                ListenerManager listenerManager = configContext.getListenerManager();
                TransportInDescription trsIn =
                    configContext.getAxisConfiguration().getTransportIn(org.apache.axis2.Constants.TRANSPORT_JMS);

View Full Code Here

        String axis2xml = repository + "/conf/axis2.xml";
        
        ConfigurationContext configurationContext = ConfigurationContextFactory
                .createConfigurationContextFromFileSystem(repository, axis2xml);
        
        JMSListener receiver = new JMSListener();
        ListenerManager listenerManager = configurationContext
                .getListenerManager();
        TransportInDescription trsIn = configurationContext
                .getAxisConfiguration().getTransportIn(Constants.TRANSPORT_JMS);
        trsIn.setReceiver(receiver);
        if (listenerManager == null) {
            listenerManager = new ListenerManager();
            listenerManager.init(configurationContext);
        }
        listenerManager.addListener(trsIn, true);
        receiver.init(configurationContext, trsIn);
        receiver.start();
    }

View Full Code Here

0 1 2 3 4 5 6 7 8 9

TOP

Related Classes of org.apache.axis2.transport.jms.JMSListener

edu.emory.mathcs.backport.java.util.concurrent.ExecutorService

edu.emory.mathcs.backport.java.util.concurrent.LinkedBlockingQueue

edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor

org.apache.axiom.om.OMElement

org.apache.axiom.soap.impl.builder.StAXSOAPModelBuilder

org.apache.axiom.soap.SOAPFault

org.apache.axiom.soap.SOAPFaultCode

org.apache.axiom.soap.SOAPFaultDetail

org.apache.axiom.soap.SOAPFaultNode

org.apache.axiom.soap.SOAPFaultReason

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.