Link between BPEL process and JMS Queue

You can use JMS transport to implement your requirement. First you need to enable JMS transport in WSO2 BPS. After that you can communicate through JMS. Please use WSO2 BPs 2.0.0 to test this. You have to use a activity which talks to a JMS endpoint, if you need to send message out. Hope this helps. Please let us know if you have any questions.

Hi Thanks you very much for your reply. As your reply, I enabled the server and restarted the ESB. I am getting following errors. Can you please help on this. [2010-07-01 16:48:11,392] INFO - JMSConnectionFactory JMS ConnectionFactory : myTopicConnectionFactory initialized [2010-07-01 16:48:11,392] INFO - JMSConnectionFactory JMS ConnectionFactory : myQueueConnectionFactory initialized [2010-07-01 16:48:11,407] INFO - JMSConnectionFactory JMS ConnectionFactory : default initialized [2010-07-01 16:48:11,407] INFO - JMSListener JMS Transport Receiver/Listener initialized... [2010-07-01 16:48:11,423] INFO - HttpCoreNIOListener HTTPS Listener started on port : 8243 [2010-07-01 16:48:11,423] INFO - HttpCoreNIOListener HTTP Listener started on port : 8280 [2010-07-01 16:48:11,423] INFO - JMSListener JMS Listener started [2010-07-01 16:48:11,438] INFO - ServiceTaskManager Task manager for service : wso2carbon-sts [re-]initialized [2010-07-01 16:48:11,454] INFO - JMSListener Started to listen on destination : wso2carbon-sts of type Queue for service wso2carbon-sts [2010-07-01 16:48:11,454] INFO - ServiceTaskManager Task manager for service : echo [re-]initialized [2010-07-01 16:48:12,454] INFO - JMSListener Started to listen on destination : echo of type Queue for service echo [2010-07-01 16:48:12,454] INFO - ServiceTaskManager Task manager for service : XKMS [re-]initialized [2010-07-01 16:48:12,454] INFO - JMSListener Started to listen on destination : XKMS of type Queue for service XKMS [2010-07-01 16:48:12,454] INFO - ServiceTaskManager Task manager for service : version [re-]initialized [2010-07-01 16:48:13,470] INFO - JMSListener Started to listen on destination : version of type Queue for service version [2010-07-01 16:48:13,470] INFO - ServiceTaskManager Task manager for service : WSDLValidatorService [re-]initialized [2010-07-01 16:48:13,485] INFO - JMSListener Started to listen on destination : WSDLValidatorService of type Queue for service WSDLValidatorService [2010-07-01 16:48:13,485] INFO - ServiceTaskManager Task manager for service : WSDLConverterService [re-]initialized [2010-07-01 16:48:14,485] INFO - JMSListener Started to listen on destination : WSDLConverterService of type Queue for service WSDLConverterService [2010-07-01 16:48:14,485] INFO - ServiceTaskManager Task manager for service : Java2WSDLService [re-]initialized [2010-07-01 16:48:14,485] INFO - JMSListener Started to listen on destination : Java2WSDLService of type Queue for service Java2WSDLService [2010-07-01 16:48:14,485] INFO - ServiceTaskManager Task manager for service : WSDL2CodeService [re-]initialized [2010-07-01 16:48:15,485] INFO - JMSListener Started to listen on destination : WSDL2CodeService of type Queue for service WSDL2CodeService [2010-07-01 16:48:15,735] ERROR - Registry Error registering carbonEngine:type=Connector,port=9443 java.security.AccessControlException: access denied (javax.management.MBeanTrustPermission register) at java.security.AccessControlContext.checkPermission(AccessControlContext.java:323) at java.lang.SecurityManager.checkPermission(SecurityManager.java:568) at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.checkMBeanTrustPermission(DefaultMBeanServerInterceptor.java:1824) at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:310) at com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:482) at org.apache.commons.modeler.Registry.registerComponent(Registry.java:871) at org.apache.catalina.connector.Connector.initialize(Connector.java:999) at org.apache.catalina.core.StandardService.addConnector(StandardService.java:261) at org.apache.catalina.startup.Embedded.addConnector(Embedded.java:327) at org.wso2.carbon.server.TomcatServerCache.addConnector(TomcatServerCache.java:49) at org.wso2.carbon.server.transports.http.HttpsTransport.start(HttpsTransport.java:85) at org.wso2.carbon.server.transports.TransportManager.startTransport(TransportManager.java:187) at org.wso2.carbon.server.transports.TransportManager.startTransports(TransportManager.java:218) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25) at java.lang.reflect.Method.invoke(Method.java:597) at org.wso2.carbon.core.internal.StartupFinalizerServiceComponent.completeInitialization(StartupFinalizerServiceComponent.java:179) at org.wso2.carbon.core.internal.StartupFinalizerServiceComponent.activate(StartupFinalizerServiceComponent.java:111) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25) at java.lang.reflect.Method.invoke(Method.java:597) at org.eclipse.equinox.internal.ds.model.ServiceComponent.activate(ServiceComponent.java:230) at org.eclipse.equinox.internal.ds.model.ServiceComponentProp.activate(ServiceComponentProp.java:140) at org.eclipse.equinox.internal.ds.model.ServiceComponentProp.build(ServiceComponentProp.java:330) at org.eclipse.equinox.internal.ds.InstanceProcess.buildComponent(InstanceProcess.java:560) at org.eclipse.equinox.internal.ds.InstanceProcess.buildComponents(InstanceProcess.java:182) at org.eclipse.equinox.internal.ds.Resolver.getEligible(Resolver.java:292) at org.eclipse.equinox.internal.ds.SCRManager.serviceChanged(SCRManager.java:226) at org.eclipse.osgi.internal.serviceregistry.FilteredServiceListener.serviceChanged(FilteredServiceListener.java:124) at org.eclipse.osgi.framework.internal.core.BundleContextImpl.dispatchEvent(BundleContextImpl.java:930) at org.eclipse.osgi.framework.eventmgr.EventManager.dispatchEvent(EventManager.java:220) at org.eclipse.osgi.framework.eventmgr.ListenerQueue.dispatchEventSynchronous(ListenerQueue.java:149) at org.eclipse.osgi.internal.serviceregistry.ServiceRegistry.publishServiceEventPrivileged(ServiceRegistry.java:757) at org.eclipse.osgi.internal.serviceregistry.ServiceRegistry.publishServiceEvent(ServiceRegistry.java:712) at org.eclipse.osgi.internal.serviceregistry.ServiceRegistrationImpl.register(ServiceRegistrationImpl.java:129) at org.eclipse.osgi.internal.serviceregistry.ServiceRegistry.registerService(ServiceRegistry.java:206) at org.eclipse.osgi.framework.internal.core.BundleContextImpl.registerService(BundleContextImpl.java:506) at org.eclipse.osgi.framework.internal.core.BundleContextImpl.registerService(BundleContextImpl.java:524) at org.wso2.carbon.core.init.CarbonServerManager.initializeCarbon(CarbonServerManager.java:380) at org.wso2.carbon.core.init.CarbonServerManager.removePendingItem(CarbonServerManager.java:208) at org.wso2.carbon.core.init.PreAxis2ConfigItemListener.bundleChanged(PreAxis2ConfigItemListener.java:100) at org.eclipse.osgi.framework.internal.core.BundleContextImpl.dispatchEvent(BundleContextImpl.java:916) at org.eclipse.osgi.framework.eventmgr.EventManager.dispatchEvent(EventManager.java:220) at org.eclipse.osgi.framework.eventmgr.EventManager$EventThread.run(EventManager.java:330) [2010-07-01 16:48:15,782] ERROR - Connector Error registering connector java.security.AccessControlException: access denied (javax.management.MBeanTrustPermission register) at java.security.AccessControlContext.checkPermission(AccessControlContext.java:323) at java.lang.SecurityManager.checkPermission(SecurityManager.java:568) at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.checkMBeanTrustPermission(DefaultMBeanServerInterceptor.java:1824) at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:310) at com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:482) at org.apache.commons.modeler.Registry.registerComponent(Registry.java:871) at org.apache.catalina.connector.Connector.initialize(Connector.java:999) at org.apache.catalina.core.StandardService.addConnector(StandardService.java:261) at org.apache.catalina.startup.Embedded.addConnector(Embedded.java:327) at org.wso2.carbon.server.TomcatServerCache.addConnector(TomcatServerCache.java:49) at org.wso2.carbon.server.transports.http.HttpsTransport.start(HttpsTransport.java:85) at org.wso2.carbon.server.transports.TransportManager.startTransport(TransportManager.java:187) at org.wso2.carbon.server.transports.TransportManager.startTransports(TransportManager.java:218) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25) at java.lang.reflect.Method.invoke(Method.java:597) at org.wso2.carbon.core.internal.StartupFinalizerServiceComponent.completeInitialization(StartupFinalizerServiceComponent.java:179) at org.wso2.carbon.core.internal.StartupFinalizerServiceComponent.activate(StartupFinalizerServiceComponent.java:111) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25) at java.lang.reflect.Method.invoke(Method.java:597) at org.eclipse.equinox.internal.ds.model.ServiceComponent.activate(ServiceComponent.java:230) at org.eclipse.equinox.internal.ds.model.ServiceComponentProp.activate(ServiceComponentProp.java:140) at org.eclipse.equinox.internal.ds.model.ServiceComponentProp.build(ServiceComponentProp.java:330) at org.eclipse.equinox.internal.ds.InstanceProcess.buildComponent(InstanceProcess.java:560) at org.eclipse.equinox.internal.ds.InstanceProcess.buildComponents(InstanceProcess.java:182) at org.eclipse.equinox.internal.ds.Resolver.getEligible(Resolver.java:292) at org.eclipse.equinox.internal.ds.SCRManager.serviceChanged(SCRManager.java:226) at org.eclipse.osgi.internal.serviceregistry.FilteredServiceListener.serviceChanged(FilteredServiceListener.java:124) at org.eclipse.osgi.framework.internal.core.BundleContextImpl.dispatchEvent(BundleContextImpl.java:930) at org.eclipse.osgi.framework.eventmgr.EventManager.dispatchEvent(EventManager.java:220) at org.eclipse.osgi.framework.eventmgr.ListenerQueue.dispatchEventSynchronous(ListenerQueue.java:149) at org.eclipse.osgi.internal.serviceregistry.ServiceRegistry.publishServiceEventPrivileged(ServiceRegistry.java:757) at org.eclipse.osgi.internal.serviceregistry.ServiceRegistry.publishServiceEvent(ServiceRegistry.java:712) at org.eclipse.osgi.internal.serviceregistry.ServiceRegistrationImpl.register(ServiceRegistrationImpl.java:129) at org.eclipse.osgi.internal.serviceregistry.ServiceRegistry.registerService(ServiceRegistry.java:206) at org.eclipse.osgi.framework.internal.core.BundleContextImpl.registerService(BundleContextImpl.java:506) at org.eclipse.osgi.framework.internal.core.BundleContextImpl.registerService(BundleContextImpl.java:524) at org.wso2.carbon.core.init.CarbonServerManager.initializeCarbon(CarbonServerManager.java:380) at org.wso2.carbon.core.init.CarbonServerManager.removePendingItem(CarbonServerManager.java:208) at org.wso2.carbon.core.init.PreAxis2ConfigItemListener.bundleChanged(PreAxis2ConfigItemListener.java:100) at org.eclipse.osgi.framework.internal.core.BundleContextImpl.dispatchEvent(BundleContextImpl.java:916) at org.eclipse.osgi.framework.eventmgr.EventManager.dispatchEvent(EventManager.java:220) at org.eclipse.osgi.framework.eventmgr.EventManager$EventThread.run(EventManager.java:330) [2010-07-01 16:48:16,485] ERROR - Registry Error registering null:type=ProtocolHandler,port=9443 java.security.AccessControlException: access denied (javax.management.MBeanTrustPermission register) at java.security.AccessControlContext.checkPermission(AccessControlContext.java:323) at java.lang.SecurityManager.checkPermission(SecurityManager.java:568) at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.checkMBeanTrustPermission(DefaultMBeanServerInterceptor.java:1824) at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:310) at com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:482) at org.apache.commons.modeler.Registry.registerComponent(Registry.java:871) at org.apache.catalina.connector.Connector.start(Connector.java:1077) at org.wso2.carbon.server.transports.http.HttpsTransport.start(HttpsTransport.java:86) at org.wso2.carbon.server.transports.TransportManager.startTransport(TransportManager.java:187) at org.wso2.carbon.server.transports.TransportManager.startTransports(TransportManager.java:218) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25) at java.lang.reflect.Method.invoke(Method.java:597) at org.wso2.carbon.core.internal.StartupFinalizerServiceComponent.completeInitialization(StartupFinalizerServiceComponent.java:179) at org.wso2.carbon.core.internal.StartupFinalizerServiceComponent.activate(StartupFinalizerServiceComponent.java:111) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25) at java.lang.reflect.Method.invoke(Method.java:597) at org.eclipse.equinox.internal.ds.model.ServiceComponent.activate(ServiceComponent.java:230) at org.eclipse.equinox.internal.ds.model.ServiceComponentProp.activate(ServiceComponentProp.java:140) at org.eclipse.equinox.internal.ds.model.ServiceComponentProp.build(ServiceComponentProp.java:330) at org.eclipse.equinox.internal.ds.InstanceProcess.buildComponent(InstanceProcess.java:560) at org.eclipse.equinox.internal.ds.InstanceProcess.buildComponents(InstanceProcess.java:182) at org.eclipse.equinox.internal.ds.Resolver.getEligible(Resolver.java:292) at org.eclipse.equinox.internal.ds.SCRManager.serviceChanged(SCRManager.java:226) at org.eclipse.osgi.internal.serviceregistry.FilteredServiceListener.serviceChanged(FilteredServiceListener.java:124) at org.eclipse.osgi.framework.internal.core.BundleContextImpl.dispatchEvent(BundleContextImpl.java:930) at org.eclipse.osgi.framework.eventmgr.EventManager.dispatchEvent(EventManager.java:220) at org.eclipse.osgi.framework.eventmgr.ListenerQueue.dispatchEventSynchronous(ListenerQueue.java:149) at org.eclipse.osgi.internal.serviceregistry.ServiceRegistry.publishServiceEventPrivileged(ServiceRegistry.java:757) at org.eclipse.osgi.internal.serviceregistry.ServiceRegistry.publishServiceEvent(ServiceRegistry.java:712) at org.eclipse.osgi.internal.serviceregistry.ServiceRegistrationImpl.register(ServiceRegistrationImpl.java:129) at org.eclipse.osgi.internal.serviceregistry.ServiceRegistry.registerService(ServiceRegistry.java:206) at org.eclipse.osgi.framework.internal.core.BundleContextImpl.registerService(BundleContextImpl.java:506) at org.eclipse.osgi.framework.internal.core.BundleContextImpl.registerService(BundleContextImpl.java:524) at org.wso2.carbon.core.init.CarbonServerManager.initializeCarbon(CarbonServerManager.java:380) at org.wso2.carbon.core.init.CarbonServerManager.removePendingItem(CarbonServerManager.java:208) at org.wso2.carbon.core.init.PreAxis2ConfigItemListener.bundleChanged(PreAxis2ConfigItemListener.java:100) at org.eclipse.osgi.framework.internal.core.BundleContextImpl.dispatchEvent(BundleContextImpl.java:916) at org.eclipse.osgi.framework.eventmgr.EventManager.dispatchEvent(EventManager.java:220) at org.eclipse.osgi.framework.eventmgr.EventManager$EventThread.run(EventManager.java:330) [2010-07-01 16:48:16,485] ERROR - Connector Protocol JMX registration failed

Hi Vinod, Can you please follow the following tutorial[1] and try to enable JMS in your server. Even though it was written for WSAS, this is same for all carbon based products. Also, if you can tell us what is the exact thing your are going to do, we can provide you with a better solution. Thanks Milinda [1] http://charithaka.blogspot.com/2009/09/how-to-enable-jms-in-wso2-wsas-3.html

Hi Milinda, This reference is use less.. I followed the same, But unfortunatley I am not able enable JMS listener by enabling from management console. I am ending up with exceptions. [2010-07-06 09:40:38,795] ERROR - Registry Error registering carbonEngine:type=Connector,port=9443 java.security.AccessControlException: access denied (javax.management.MBeanTrustPermission register) at java.security.AccessControlContext.checkPermission(AccessControlContext.java:323) at java.lang.SecurityManager.checkPermission(SecurityManager.java:568) at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.checkMBeanTrustPermission(DefaultMBeanServerInterceptor.java:1824) at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:310) at com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:482) at org.apache.commons.modeler.Registry.registerComponent(Registry.java:871) at org.apache.catalina.connector.Connector.initialize(Connector.java:999) at org.apache.catalina.core.StandardService.addConnector(StandardService.java:261) at org.apache.catalina.startup.Embedded.addConnector(Embedded.java:327) at org.wso2.carbon.server.TomcatServerCache.addConnector(TomcatServerCache.java:49) at org.wso2.carbon.server.transports.http.HttpsTransport.start(HttpsTransport.java:85) at org.wso2.carbon.server.transports.TransportManager.startTransport(TransportManager.java:187) at org.wso2.carbon.server.transports.TransportManager.startTransports(TransportManager.java:218) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25) at java.lang.reflect.Method.invoke(Method.java:597) at org.wso2.carbon.core.internal.StartupFinalizerServiceComponent.completeInitialization(StartupFinalizerServiceComponent.java:179) at org.wso2.carbon.core.internal.StartupFinalizerServiceComponent.activate(StartupFinalizerServiceComponent.java:111) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25) at java.lang.reflect.Method.invoke(Method.java:597) at org.eclipse.equinox.internal.ds.model.ServiceComponent.activate(ServiceComponent.java:230) at org.eclipse.equinox.internal.ds.model.ServiceComponentProp.activate(ServiceComponentProp.java:140) at org.eclipse.equinox.internal.ds.model.ServiceComponentProp.build(ServiceComponentProp.java:330) at org.eclipse.equinox.internal.ds.InstanceProcess.buildComponent(InstanceProcess.java:560) at org.eclipse.equinox.internal.ds.InstanceProcess.buildComponents(InstanceProcess.java:182) at org.eclipse.equinox.internal.ds.Resolver.getEligible(Resolver.java:292) at org.eclipse.equinox.internal.ds.SCRManager.serviceChanged(SCRManager.java:226) at org.eclipse.osgi.internal.serviceregistry.FilteredServiceListener.serviceChanged(FilteredServiceListener.java:124) at org.eclipse.osgi.framework.internal.core.BundleContextImpl.dispatchEvent(BundleContextImpl.java:930) at org.eclipse.osgi.framework.eventmgr.EventManager.dispatchEvent(EventManager.java:220) at org.eclipse.osgi.framework.eventmgr.ListenerQueue.dispatchEventSynchronous(ListenerQueue.java:149) at org.eclipse.osgi.internal.serviceregistry.ServiceRegistry.publishServiceEventPrivileged(ServiceRegistry.java:757) at org.eclipse.osgi.internal.serviceregistry.ServiceRegistry.publishServiceEvent(ServiceRegistry.java:712) at org.eclipse.osgi.internal.serviceregistry.ServiceRegistrationImpl.register(ServiceRegistrationImpl.java:129) at org.eclipse.osgi.internal.serviceregistry.ServiceRegistry.registerService(ServiceRegistry.java:206) at org.eclipse.osgi.framework.internal.core.BundleContextImpl.registerService(BundleContextImpl.java:506) at org.eclipse.osgi.framework.internal.core.BundleContextImpl.registerService(BundleContextImpl.java:524) at org.wso2.carbon.core.init.CarbonServerManager.initializeCarbon(CarbonServerManager.java:380) at org.wso2.carbon.core.init.CarbonServerManager.removePendingItem(CarbonServerManager.java:208) at org.wso2.carbon.core.init.PreAxis2ConfigItemListener.bundleChanged(PreAxis2ConfigItemListener.java:100) at org.eclipse.osgi.framework.internal.core.BundleContextImpl.dispatchEvent(BundleContextImpl.java:916) at org.eclipse.osgi.framework.eventmgr.EventManager.dispatchEvent(EventManager.java:220)

Finally I found the solution.... Just add the following lines to your java.policy file unter /lib/security. grant { // JMX Java Management eXtensions permission javax.management.MBeanTrustPermission "register"; }; Thanks, Vinod

Hi Vinod, I think you have used Weblogic JMS implementation. To use Weblogic JMS, you need to add the that permission to java.policy. What we have used for sample described in above mentioned blog post is ActiveMQ. It doesn't need that parameter AFAIK. Thanks Milinda

HI vinod, Can you please share with me how you configured WSO2 BPS and weblogic server for consuming a message from the queue. I am in the same situation as you were before. We developed everything using Oracle SOA and now we moved to WSO2. Can you please share how you did this in Wso2 BPEL engine. Thanks, Ravi

HI Milinda, I am new to Wso2 framework. Please let me know how I can consume a message from the weblogic server using BPEL. I did the configuration of the axis2.xml file like this weblogic.jndi.WLInitialContextFactory t3://chelwebhr06.karmalab.net:99 JMS/EXPDPsftConnectionFactory queue xxxx xxxxxx What Should i do to test this? How do I know that I have made the connection?   Thanks, Ravi