[mule-user] Mule 1.6 and HermesJMS
rajkiran
Hello,
I want to read a jms message from a queue and print it on System.out using
SystemStreamConnector.
Could anyone please help me with a simple mule config file for the same.
Also, how do i connect to HermesJMS from Mule ? If it is through the mule
config file then please add that also in the config file.
My queue is created in HermesJMS using IBM Wesphere MQ. The
ConnectionFactory is com.ibm.mq.jms.MQQueueConnectionFactory.
Please help. Thanks in advance.
--
View this message in context: http://www.nabble.com/Mule-1.6-and-HermesJMS-tp19265798p19265798.html
Sent from the Mule - User mailing list archive at Nabble.com.
---------------------------------------------------------------------
To unsubscribe from this list, please visit:
http://xircles.codehaus.org/manage_email
Antoine Borg
There are many examples of using JMS endpoints and System Stream endpoints,
these two wiki pages will help:
http://mule.mulesource.org/display/MULEUSER/Jms+Provider
http://mule.mulesource.org/display/MULEUSER/Stream+Provider
I presume that you are using Mule 1.x, right?
All you will need is a simple bridge component to "bridge" the two
transports together. If you're using WebSphere, perhaps the Mule WMQ
transport will be useful.
A
Antoine Borg, Senior Consultant | Tel: +32 28 504 696
ricston Ltd., BP 2, 1180 Uccle, Brussels, BELGIUM
email: antoin...@ricston.com | blog: blog.ricston.com | web: ricston.com
NascentToMule
Thanks a lot for your response. God Bless You.
I need some help on the foll. questions :
1) can i make a queue in mule, send a message through the console to this
queue and then retrieve that message back from the queue into the console.
2) in the config file that i have mentioned below, i have set the outbound
endpoint to a queue. i have not created this queue. will it get created
automatically? if not how can i create that queue?
foll. is my config file: i have also pasted the error below. Can i call you
if i need any further help on the number you have given below?
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mule-configuration PUBLIC
"-//MuleSource //DTD mule-configuration XML V1.0//EN"
"http://mule.mulesource.org/dtds/mule/mule-configuration.dtd">
<mule-configuration id="trial" version="1.0">
<connector name="SystemStreamConnector"
className="org.mule.providers.stream.SystemStreamConnector">
<properties>
<property name="promptMessage"
value="Please enter ur name :" />
<property name="messageDelayTime" value="1000" />
</properties>
</connector>
<connector name="jmsConnector"
className="org.mule.providers.jms.JmsConnector">
<!-- <connector name="jmsConnector"
className="org.mule.providers.jms.websphere.WebsphereJmsConnector"> -->
<properties>
<property name="specification" value="1.0.2b" />
<property name="connectionFactory"
value="com.ibm.mq.jms.MQConnectionFactory" />
</properties>
</connector>
<transformers>
<transformer name="JMSMessageToObject"
className="org.mule.providers.jms.transformers.JMSMessageToObject"
returnClass="java.lang.String" />
<transformer name="ObjectToJMSMessage"
className="org.mule.providers.jms.transformers.ObjectToJMSMessage" />
</transformers>
<model name="READ_Console">
<mule-descriptor name="read"
implementation="org.mule.components.simple.BridgeComponent">
<inbound-router>
<endpoint address="stream://System.in" />
</inbound-router>
<outbound-router>
<router
className="org.mule.routing.outbound.OutboundPassThroughRouter">
<endpoint address="jms://MyJMSQueue" connector="jmsConnector"
transformers="ObjectToJMSMessage"/>
</router>
</outbound-router>
</mule-descriptor>
</model>
</mule-configuration>
I get the foll. error :
INFO 2008-09-06 16:41:17,958 [main] org.mule.MuleServer: Mule Server
starting...
INFO 2008-09-06 16:41:22,817 [main] org.mule.MuleManager: Creating new
MuleManager instance
ERROR 2008-09-06 16:41:24,302 [main]
org.apache.commons.beanutils.PropertyUtils: Method invocation failed.
java.lang.IllegalArgumentException: argument type mismatch
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
at java.lang.reflect.Method.invoke(Unknown Source)
at
org.apache.commons.beanutils.PropertyUtilsBean.invokeMethod(PropertyUtilsBean.java:1773)
at
org.apache.commons.beanutils.PropertyUtilsBean.setSimpleProperty(PropertyUtilsBean.java:1759)
at
org.apache.commons.beanutils.PropertyUtilsBean.setNestedProperty(PropertyUtilsBean.java:1648)
at
org.apache.commons.beanutils.PropertyUtilsBean.setProperty(PropertyUtilsBean.java:1677)
at
org.apache.commons.beanutils.BeanUtilsBean.setProperty(BeanUtilsBean.java:1022)
at org.apache.commons.beanutils.BeanUtils.setProperty(BeanUtils.java:313)
at org.mule.util.BeanUtils.populateWithoutFail(BeanUtils.java:65)
at
org.mule.config.builders.MulePropertiesRuleSet$1.end(MulePropertiesRuleSet.java:95)
at org.apache.commons.digester.Digester.endElement(Digester.java:1130)
at org.apache.xerces.parsers.AbstractSAXParser.endElement(Unknown Source)
at org.apache.xerces.impl.XMLNamespaceBinder.endElement(Unknown Source)
at org.apache.xerces.impl.dtd.XMLDTDValidator.endNamespaceScope(Unknown
Source)
at org.apache.xerces.impl.dtd.XMLDTDValidator.handleEndElement(Unknown
Source)
at org.apache.xerces.impl.dtd.XMLDTDValidator.endElement(Unknown Source)
at
org.apache.xerces.impl.XMLDocumentFragmentScannerImpl.scanEndElement(Unknown
Source)
at
org.apache.xerces.impl.XMLDocumentFragmentScannerImpl$FragmentContentDispatcher.dispatch(Unknown
Source)
at
org.apache.xerces.impl.XMLDocumentFragmentScannerImpl.scanDocument(Unknown
Source)
at org.apache.xerces.parsers.DTDConfiguration.parse(Unknown Source)
at org.apache.xerces.parsers.DTDConfiguration.parse(Unknown Source)
at org.apache.xerces.parsers.XMLParser.parse(Unknown Source)
at org.apache.xerces.parsers.AbstractSAXParser.parse(Unknown Source)
at org.apache.commons.digester.Digester.parse(Digester.java:1685)
at
org.mule.config.builders.AbstractDigesterConfiguration.process(AbstractDigesterConfiguration.java:101)
at
org.mule.config.builders.MuleXmlConfigurationBuilder.configure(MuleXmlConfigurationBuilder.java:268)
at
org.mule.config.builders.MuleXmlConfigurationBuilder.configure(MuleXmlConfigurationBuilder.java:221)
at org.mule.MuleServer.initialize(MuleServer.java:298)
at org.mule.MuleServer.run(MuleServer.java:219)
at org.mule.MuleServer.start(MuleServer.java:207)
at org.mule.MuleServer.main(MuleServer.java:177)
WARN 2008-09-06 16:41:24,302 [main] org.mule.util.BeanUtils: Property:
connectionFactory=com.ibm.mq.jms.MQConnectionFactory not found on object:
org.mule.providers.jms.JmsConnector
INFO 2008-09-06 16:41:24,411 [main] org.mule.MuleManager: Transformer
JMSMessageToObject has been initialised successfully
INFO 2008-09-06 16:41:24,427 [main] org.mule.MuleManager: Transformer
ObjectToJMSMessage has been initialised successfully
INFO 2008-09-06 16:41:24,927 [main]
org.mule.config.builders.TransformerReference: Setting transformer:
ObjectToJMSMessage on org.mule.impl.endpoint.MuleEndpoint.transformer
ERROR 2008-09-06 16:41:25,146 [main]
org.mule.EnterpriseBootstrapModulesInitializer: Failed to read enterprise
bootstrap modules information.
INFO 2008-09-06 16:41:25,208 [main] org.mule.providers.jms.JmsConnector:
Initialising: JmsConnector{this=11db6bb, started=false, initialised=false,
name='jmsConnector', disposed=false,
numberOfConcurrentTransactedReceivers=4,
createMultipleTransactedReceivers=true, connected=false,
supportedProtocols=[jms], serviceOverrides=null}
INFO 2008-09-06 16:41:25,239 [main]
org.mule.providers.service.TransportServiceDescriptor: Loading default
inbound transformer: org.mule.providers.jms.transformers.JMSMessageToObject
INFO 2008-09-06 16:41:25,239 [main]
org.mule.providers.service.TransportServiceDescriptor: Loading default
outbound transformer: org.mule.providers.jms.transformers.ObjectToJMSMessage
INFO 2008-09-06 16:41:25,239 [main]
org.mule.providers.service.TransportServiceDescriptor: Loading default
response transformer: org.mule.providers.jms.transformers.ObjectToJMSMessage
INFO 2008-09-06 16:41:25,239 [main]
org.mule.providers.service.TransportServiceDescriptor: Loading default
inbound transformer: org.mule.providers.jms.transformers.JMSMessageToObject
INFO 2008-09-06 16:41:25,239 [main]
org.mule.providers.service.TransportServiceDescriptor: Loading default
outbound transformer: org.mule.providers.jms.transformers.ObjectToJMSMessage
INFO 2008-09-06 16:41:25,239 [main]
org.mule.providers.service.TransportServiceDescriptor: Loading default
response transformer: org.mule.providers.jms.transformers.ObjectToJMSMessage
INFO 2008-09-06 16:41:25,239 [main] org.mule.impl.DefaultExceptionStrategy:
Initialising exception listener:
org.mule.impl.DefaultExceptionStrategy@d6b059
INFO 2008-09-06 16:41:25,255 [main]
org.mule.providers.stream.SystemStreamConnector: Initialising:
SystemStreamConnector{this=1843a75, started=false, initialised=false,
name='SystemStreamConnector', disposed=false,
numberOfConcurrentTransactedReceivers=4,
createMultipleTransactedReceivers=true, connected=false,
supportedProtocols=[stream], serviceOverrides=null}
INFO 2008-09-06 16:41:25,255 [main] org.mule.impl.DefaultExceptionStrategy:
Initialising exception listener:
org.mule.impl.DefaultExceptionStrategy@1fcc0a2
INFO 2008-09-06 16:41:25,255 [main] org.mule.MuleManager: Connectors have
been initialised successfully
INFO 2008-09-06 16:41:25,255 [main] org.mule.MuleManager: Initialising
agents...
INFO 2008-09-06 16:41:25,317 [main] org.mule.MuleManager: Agents
Successfully Initialised
INFO 2008-09-06 16:41:25,317 [main]
org.mule.impl.DefaultComponentExceptionStrategy: Initialising exception
listener: org.mule.impl.DefaultComponentExceptionStrategy@17aece8
INFO 2008-09-06 16:41:25,349 [main]
org.mule.impl.DefaultComponentExceptionStrategy: Initialising exception
listener: org.mule.impl.DefaultComponentExceptionStrategy@29c58e
INFO 2008-09-06 16:41:25,380 [main] org.mule.impl.model.seda.SedaModel:
Component read-file has been started successfully
INFO 2008-09-06 16:41:25,536 [main] org.mule.providers.tcp.TcpConnector:
Initialising: TcpConnector{this=df0438, started=false, initialised=false,
name='connector.tcp.0', disposed=false,
numberOfConcurrentTransactedReceivers=4,
createMultipleTransactedReceivers=true, connected=false,
supportedProtocols=[tcp], serviceOverrides=null}
INFO 2008-09-06 16:41:25,536 [main] org.mule.impl.DefaultExceptionStrategy:
Initialising exception listener:
org.mule.impl.DefaultExceptionStrategy@1552b76
INFO 2008-09-06 16:41:25,536 [main] org.mule.providers.tcp.TcpConnector:
Starting: TcpConnector{this=df0438, started=false, initialised=true,
name='connector.tcp.0', disposed=false,
numberOfConcurrentTransactedReceivers=4,
createMultipleTransactedReceivers=true, connected=true,
supportedProtocols=[tcp], serviceOverrides=null}
INFO 2008-09-06 16:41:25,567 [main] org.mule.providers.tcp.TcpConnector:
Started: TcpConnector{this=df0438, started=true, initialised=true,
name='connector.tcp.0', disposed=false,
numberOfConcurrentTransactedReceivers=4,
createMultipleTransactedReceivers=true, connected=true,
supportedProtocols=[tcp], serviceOverrides=null}
INFO 2008-09-06 16:41:25,567 [main] org.mule.providers.tcp.TcpConnector:
Connected: TcpConnector{this=df0438, started=true, initialised=true,
name='connector.tcp.0', disposed=false,
numberOfConcurrentTransactedReceivers=4,
createMultipleTransactedReceivers=true, connected=true,
supportedProtocols=[tcp], serviceOverrides=null}
INFO 2008-09-06 16:41:25,567 [main]
org.mule.impl.internal.admin.MuleAdminAgent: Registering Admin listener on:
tcp://localhost:60504
INFO 2008-09-06 16:41:25,583 [main] org.mule.impl.model.seda.SedaModel:
Initialising component: _muleManagerComponent
INFO 2008-09-06 16:41:25,599 [main]
org.mule.util.queue.TransactionalQueueManager: Starting ResourceManager
INFO 2008-09-06 16:41:25,645 [main]
org.mule.util.queue.TransactionalQueueManager: Started ResourceManager
FATAL 2008-09-06 16:41:25,724 [main] org.mule.MuleServer:
********************************************************************************
Message : The required object/property "jndiInitialFactory" is
null
Type : org.mule.umo.lifecycle.InitialisationException
Code : MULE_ERROR-72045
JavaDoc :
http://mule.mulesource.org/docs/apidocs/org/mule/umo/lifecycle/InitialisationException.html
********************************************************************************
Exception stack is:
1. The required object/property "jndiInitialFactory" is null
(org.mule.umo.lifecycle.InitialisationException)
org.mule.providers.jms.JmsConnector:208
(http://mule.mulesource.org/docs/apidocs/org/mule/umo/lifecycle/InitialisationException.html)
********************************************************************************
Root Exception stack trace:
org.mule.umo.lifecycle.InitialisationException: The required object/property
"jndiInitialFactory" is null
at
org.mule.providers.jms.JmsConnector.initJndiContext(JmsConnector.java:208)
at org.mule.providers.jms.JmsConnector.doConnect(JmsConnector.java:349)
at
org.mule.providers.AbstractConnector.connect(AbstractConnector.java:1147)
at
org.mule.providers.SingleAttemptConnectionStrategy.doConnect(SingleAttemptConnectionStrategy.java:25)
at
org.mule.providers.AbstractConnectionStrategy.connectImmediately(AbstractConnectionStrategy.java:183)
at
org.mule.providers.AbstractConnectionStrategy.connect(AbstractConnectionStrategy.java:54)
at
org.mule.providers.AbstractConnector.connect(AbstractConnector.java:1157)
at
org.mule.providers.SingleAttemptConnectionStrategy.doConnect(SingleAttemptConnectionStrategy.java:25)
at
org.mule.providers.AbstractConnectionStrategy.connectImmediately(AbstractConnectionStrategy.java:183)
at
org.mule.providers.AbstractConnectionStrategy.connect(AbstractConnectionStrategy.java:54)
at
org.mule.providers.AbstractConnector.startConnector(AbstractConnector.java:359)
at org.mule.MuleManager.startConnectors(MuleManager.java:934)
at org.mule.MuleManager.start(MuleManager.java:890)
at
org.mule.config.builders.MuleXmlConfigurationBuilder.configure(MuleXmlConfigurationBuilder.java:282)
at
org.mule.config.builders.MuleXmlConfigurationBuilder.configure(MuleXmlConfigurationBuilder.java:221)
at org.mule.MuleServer.initialize(MuleServer.java:298)
at org.mule.MuleServer.run(MuleServer.java:219)
at org.mule.MuleServer.start(MuleServer.java:207)
at org.mule.MuleServer.main(MuleServer.java:177)
********************************************************************************
FATAL 2008-09-06 16:41:25,739 [main] org.mule.MuleServer:
********************************************************************************
* A Fatal error has occurred while the server was running:
*
* The required object/property "jndiInitialFactory" is null
*
* (org.mule.umo.lifecycle.InitialisationException)
*
*
*
* The error is fatal, the system must shutdown
*
* Server started: 9/6/08 4:41 PM
*
* Server shutdown: 9/6/08 4:41 PM
*
********************************************************************************
INFO 2008-09-06 16:41:25,739 [main] org.mule.providers.jms.JmsConnector:
Disposing: JmsConnector{this=11db6bb, started=false, initialised=true,
name='jmsConnector', disposed=false,
numberOfConcurrentTransactedReceivers=4,
createMultipleTransactedReceivers=true, connected=false,
supportedProtocols=[jms], serviceOverrides=null}
INFO 2008-09-06 16:41:25,739 [main] org.mule.providers.jms.JmsConnector:
Stopped: JmsConnector{this=11db6bb, started=false, initialised=false,
name='jmsConnector', disposed=false,
numberOfConcurrentTransactedReceivers=4,
createMultipleTransactedReceivers=true, connected=false,
supportedProtocols=[jms], serviceOverrides=null}
INFO 2008-09-06 16:41:25,739 [main] org.mule.providers.jms.JmsConnector:
Disposed: JmsConnector{this=11db6bb, started=false, initialised=false,
name='jmsConnector', disposed=true, numberOfConcurrentTransactedReceivers=4,
createMultipleTransactedReceivers=true, connected=false,
supportedProtocols=[jms], serviceOverrides=null}
INFO 2008-09-06 16:41:25,739 [main] org.mule.providers.tcp.TcpConnector:
Disposing: TcpConnector{this=df0438, started=true, initialised=true,
name='connector.tcp.0', disposed=false,
numberOfConcurrentTransactedReceivers=4,
createMultipleTransactedReceivers=true, connected=true,
supportedProtocols=[tcp], serviceOverrides=null}
INFO 2008-09-06 16:41:25,739 [main] org.mule.providers.tcp.TcpConnector:
Stopping: TcpConnector{this=df0438, started=true, initialised=true,
name='connector.tcp.0', disposed=false,
numberOfConcurrentTransactedReceivers=4,
createMultipleTransactedReceivers=true, connected=true,
supportedProtocols=[tcp], serviceOverrides=null}
INFO 2008-09-06 16:41:25,739 [main] org.mule.providers.tcp.TcpConnector:
Stopped: TcpConnector{this=df0438, started=false, initialised=false,
name='connector.tcp.0', disposed=false,
numberOfConcurrentTransactedReceivers=4,
createMultipleTransactedReceivers=true, connected=false,
supportedProtocols=[tcp], serviceOverrides=null}
INFO 2008-09-06 16:41:25,739 [main] org.mule.providers.tcp.TcpConnector:
Disconnected: TcpConnector{this=df0438, started=false, initialised=false,
name='connector.tcp.0', disposed=false,
numberOfConcurrentTransactedReceivers=4,
createMultipleTransactedReceivers=true, connected=false,
supportedProtocols=[tcp], serviceOverrides=null}
INFO 2008-09-06 16:41:25,739 [main] org.mule.providers.tcp.TcpConnector:
Stopped: TcpConnector{this=df0438, started=false, initialised=false,
name='connector.tcp.0', disposed=false,
numberOfConcurrentTransactedReceivers=4,
createMultipleTransactedReceivers=true, connected=false,
supportedProtocols=[tcp], serviceOverrides=null}
INFO 2008-09-06 16:41:25,739 [main] org.mule.util.monitor.ExpiryMonitor:
disposing monitor
INFO 2008-09-06 16:41:25,739 [main] org.mule.providers.tcp.TcpConnector:
Disposed: TcpConnector{this=df0438, started=false, initialised=false,
name='connector.tcp.0', disposed=true,
numberOfConcurrentTransactedReceivers=4,
createMultipleTransactedReceivers=true, connected=false,
supportedProtocols=[tcp], serviceOverrides=null}
INFO 2008-09-06 16:41:25,739 [main]
org.mule.providers.stream.SystemStreamConnector: Disposing:
SystemStreamConnector{this=1843a75, started=false, initialised=true,
name='SystemStreamConnector', disposed=false,
numberOfConcurrentTransactedReceivers=4,
createMultipleTransactedReceivers=true, connected=false,
supportedProtocols=[stream], serviceOverrides=null}
INFO 2008-09-06 16:41:25,739 [main]
org.mule.providers.stream.SystemStreamConnector: Stopped:
SystemStreamConnector{this=1843a75, started=false, initialised=false,
name='SystemStreamConnector', disposed=false,
numberOfConcurrentTransactedReceivers=4,
createMultipleTransactedReceivers=true, connected=false,
supportedProtocols=[stream], serviceOverrides=null}
INFO 2008-09-06 16:41:25,739 [main]
org.mule.providers.stream.SystemStreamConnector: Disposed:
SystemStreamConnector{this=1843a75, started=false, initialised=false,
name='SystemStreamConnector', disposed=true,
numberOfConcurrentTransactedReceivers=4,
createMultipleTransactedReceivers=true, connected=false,
supportedProtocols=[stream], serviceOverrides=null}
INFO 2008-09-06 16:41:25,739 [main] org.mule.impl.model.seda.SedaModel:
_muleManagerComponent has been destroyed successfully
INFO 2008-09-06 16:41:25,739 [main] org.mule.impl.model.seda.SedaModel:
read-file has been destroyed successfully
INFO 2008-09-06 16:41:25,739 [main] org.mule.MuleManager: disposing
agents...
INFO 2008-09-06 16:41:25,739 [main] org.mule.MuleManager: Agents
Successfully Disposed
INFO 2008-09-06 16:41:25,770 [main]
org.mule.util.queue.TransactionalQueueManager: Stopping ResourceManager
INFO 2008-09-06 16:41:25,770 [main]
org.mule.util.queue.TransactionalQueueManager: Stopped ResourceManager
INFO 2008-09-06 16:41:25,786 [main] org.mule.MuleManager:
******************************************************************************
* Mule shut down normally on: 9/6/08 4:41 PM
*
* Server was up for: 0 days, 0 hours, 0 mins, 0.843 sec
*
******************************************************************************
Please suggest. Thanks in advance.
Regards.
antoine.borg wrote:
>
> Hello,
>
> There are many examples of using JMS endpoints and System Stream
> endpoints,
> these two wiki pages will help:
>
> http://mule.mulesource.org/display/MULEUSER/Jms+Provider
> http://mule.mulesource.org/display/MULEUSER/Stream+Provider
>
> I presume that you are using Mule 1.x, right?
>
> All you will need is a simple bridge component to "bridge" the two
> transports together. If you're using WebSphere, perhaps the Mule WMQ
> transport will be useful.
>
> A
>
>
> Antoine Borg, Senior Consultant | Tel: +32 28 504 696
> ricston Ltd., BP 2, 1180 Uccle, Brussels, BELGIUM
> email: antoin...@ricston.com | blog: blog.ricston.com | web:
> ricston.com
>
> -----Original Message-----
> From: rajkiran [mailto:rajkir...@polaris.co.in]
> Sent: Tuesday, September 02, 2008 10:03 AM
> To: us...@mule.codehaus.org
> Subject: [mule-user] Mule 1.6 and HermesJMS
>
>
--
View this message in context: http://www.nabble.com/Mule-1.6-and-HermesJMS-tp19265798p19345607.html
Antoine Borg
You can configure Mule to read information off the console and send it to a
queue - that is a simple use case. Retrieving it from the queue and printing
it on the console is also simple to do.
The queue will be created automatically BUT only if your JMS server does
this. ActiveMQ, for instance, does auto-create a queue if one does not
already exist. MQSeries, if memory serves, doesn't. If your JMS server does
not, you will have to create the queues manually through the JMS server
before running Mule.
The error that you pasted below indicates that the 'The required
object/property "jndiInitialFactory" is
Null' which means that the property called jndiInitialFactory of the JMS
server was not configured.
Regards
</mule-configuration>
****************************************************************************