You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@activemq.apache.org by Jeff Wysong <je...@roundboxmedia.com> on 2006/11/06 23:12:18 UTC
Embedded JMS transactions
I am getting a javax.management.InstanceAlreadyExistsException when
trying to set up embedded transactions. When I googled it, the answers
seemed to be restart the computer. I did that, but I still get the same
error. Attached is a snipet of the catalina.out log and my
mule-spring-config.xml. What am I doing wrong??? Thanks.
-Jeff
*************************** catalina.out *************************
**********************************************************************
* Mule Version Info not set *
* *
* Server started: Monday, November 6, 2006 4:29:13 PM EST *
* Server ID: null *
* JDK: 1.5.0_04 (mixed mode) *
* OS: Windows XP - Service Pack 2 (5.1, x86) *
* Host: dongerWy (10.0.0.120) *
* *
* Agents Running: *
* Mule Admin: accepting connections on tcp://localhost:60504 *
**********************************************************************
Nov 6, 2006 4:29:15 PM org.mule.extras.spring.events.MuleEventMulticaster getDefaultDescriptor
INFO: No receive endpoints have been set, using default '*'
Nov 6, 2006 4:29:15 PM org.mule.impl.model.AbstractModel registerComponent
INFO: Initialising component: muleEventMulticasterDescriptor
Nov 6, 2006 4:29:15 PM org.mule.impl.model.AbstractModel registerComponent
INFO: Starting component: muleEventMulticasterDescriptor
Nov 6, 2006 4:29:15 PM org.mule.providers.AbstractConnector registerListener
INFO: registering listener: muleEventMulticasterDescriptor on endpointUri: vm://*
Nov 6, 2006 4:29:15 PM org.mule.providers.AbstractMessageReceiver connect
INFO: Successfully connected to: vm://*
Nov 6, 2006 4:29:15 PM org.mule.impl.container.MultiContainerContext getComponent
INFO: Object: 'applicationEventMulticaster' found in container: spring
Nov 6, 2006 4:29:15 PM org.springframework.web.context.ContextLoader initWebApplicationContext
INFO: Using context class [org.springframework.web.context.support.XmlWebApplicationContext] for root WebApplicationContext
Nov 6, 2006 4:29:15 PM org.springframework.web.context.ContextLoader initWebApplicationContext
INFO: Root WebApplicationContext: initialization completed in 4296 ms
Nov 6, 2006 4:29:15 PM org.apache.coyote.http11.Http11BaseProtocol start
INFO: Starting Coyote HTTP/1.1 on http-8080
Nov 6, 2006 4:29:15 PM org.apache.activemq.broker.jmx.ManagedRegionBroker registerSubscription
SEVERE: Failed to register subscription QueueSubscription: consumer=ID:dongerWy-4560-1162848553413-4:0:9:1, destinations=0, dispatched=0, delivered=0,
pending=0
javax.management.InstanceAlreadyExistsException: org.apache.activemq:BrokerName=windows,Type=Subscription, persistentMode=Non-Durable, destinationType
=Queue, destinationName=resource.aquire.queue, clientID=connectionFactory-4560-1162848553413-5_0
at com.sun.jmx.mbeanserver.RepositorySupport.addMBean(RepositorySupport.java:452)
at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.internal_addObject(DefaultMBeanServerInterceptor.java:1410)
at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:936)
at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:337)
at com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:497)
at org.apache.activemq.broker.jmx.ManagedRegionBroker.registerSubscription(ManagedRegionBroker.java:285)
at org.apache.activemq.broker.jmx.ManagedRegionBroker.registerSubscription(ManagedRegionBroker.java:205)
at org.apache.activemq.broker.jmx.ManagedQueueRegion.createSubscription(ManagedQueueRegion.java:45)
at org.apache.activemq.broker.region.AbstractRegion.addConsumer(AbstractRegion.java:202)
at org.apache.activemq.broker.region.RegionBroker.addConsumer(RegionBroker.java:325)
at org.apache.activemq.broker.BrokerFilter.addConsumer(BrokerFilter.java:85)
at org.apache.activemq.advisory.AdvisoryBroker.addConsumer(AdvisoryBroker.java:78)
at org.apache.activemq.broker.BrokerFilter.addConsumer(BrokerFilter.java:85)
at org.apache.activemq.broker.MutableBrokerFilter.addConsumer(MutableBrokerFilter.java:95)
at org.apache.activemq.broker.AbstractConnection.processAddConsumer(AbstractConnection.java:534)
at org.apache.activemq.command.ConsumerInfo.visit(ConsumerInfo.java:296)
at org.apache.activemq.broker.AbstractConnection.service(AbstractConnection.java:238)
at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:62)
at org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:92)
at org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:67)
at org.apache.activemq.transport.vm.VMTransport.syncOneWay(VMTransport.java:97)
at org.apache.activemq.transport.vm.VMTransport.oneway(VMTransport.java:84)
at org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:45)
at org.apache.activemq.transport.ResponseCorrelator.asyncRequest(ResponseCorrelator.java:67)
at org.apache.activemq.transport.ResponseCorrelator.request(ResponseCorrelator.java:72)
at org.apache.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:1146)
at org.apache.activemq.ActiveMQSession.syncSendPacket(ActiveMQSession.java:1660)
at org.apache.activemq.ActiveMQMessageConsumer.<init>(ActiveMQMessageConsumer.java:198)
at org.apache.activemq.ActiveMQSession.createConsumer(ActiveMQSession.java:838)
at org.mule.providers.jms.Jms11Support.createConsumer(Jms11Support.java:92)
at org.mule.providers.jms.TransactedJmsMessageReceiver.createConsumer(TransactedJmsMessageReceiver.java:302)
at org.mule.providers.jms.TransactedJmsMessageReceiver.poll(TransactedJmsMessageReceiver.java:147)
at org.mule.providers.PollingMessageReceiver.run(PollingMessageReceiver.java:71)
at org.mule.impl.work.WorkerContext.run(WorkerContext.java:301)
at edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:650)
at edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:675)
at java.lang.Thread.run(Thread.java:595)
Nov 6, 2006 4:29:15 PM org.apache.activemq.broker.jmx.ManagedRegionBroker registerSubscription
SEVERE: Failed to register subscription QueueSubscription: consumer=ID:dongerWy-4560-1162848553413-4:0:2:1, destinations=0, dispatched=0, delivered=0,
pending=0
javax.management.InstanceAlreadyExistsException: org.apache.activemq:BrokerName=windows,Type=Subscription, persistentMode=Non-Durable, destinationType
=Queue, destinationName=resource.conversion.queue, clientID=connectionFactory-4560-1162848553413-5_0
at com.sun.jmx.mbeanserver.RepositorySupport.addMBean(RepositorySupport.java:452)
at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.internal_addObject(DefaultMBeanServerInterceptor.java:1410)
at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:936)
at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:337)
at com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:497)
at org.apache.activemq.broker.jmx.ManagedRegionBroker.registerSubscription(ManagedRegionBroker.java:285)
at org.apache.activemq.broker.jmx.ManagedRegionBroker.registerSubscription(ManagedRegionBroker.java:205)
at org.apache.activemq.broker.jmx.ManagedQueueRegion.createSubscription(ManagedQueueRegion.java:45)
at org.apache.activemq.broker.region.AbstractRegion.addConsumer(AbstractRegion.java:202)
at org.apache.activemq.broker.region.RegionBroker.addConsumer(RegionBroker.java:325)
at org.apache.activemq.broker.BrokerFilter.addConsumer(BrokerFilter.java:85)
at org.apache.activemq.advisory.AdvisoryBroker.addConsumer(AdvisoryBroker.java:78)
at org.apache.activemq.broker.BrokerFilter.addConsumer(BrokerFilter.java:85)
at org.apache.activemq.broker.MutableBrokerFilter.addConsumer(MutableBrokerFilter.java:95)
at org.apache.activemq.broker.AbstractConnection.processAddConsumer(AbstractConnection.java:534)
at org.apache.activemq.command.ConsumerInfo.visit(ConsumerInfo.java:296)
at org.apache.activemq.broker.AbstractConnection.service(AbstractConnection.java:238)
at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:62)
at org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:92)
at org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:67)
at org.apache.activemq.transport.vm.VMTransport.syncOneWay(VMTransport.java:97)
at org.apache.activemq.transport.vm.VMTransport.oneway(VMTransport.java:84)
at org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:45)
at org.apache.activemq.transport.ResponseCorrelator.asyncRequest(ResponseCorrelator.java:67)
at org.apache.activemq.transport.ResponseCorrelator.request(ResponseCorrelator.java:72)
at org.apache.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:1146)
at org.apache.activemq.ActiveMQSession.syncSendPacket(ActiveMQSession.java:1660)
at org.apache.activemq.ActiveMQMessageConsumer.<init>(ActiveMQMessageConsumer.java:198)
at org.apache.activemq.ActiveMQSession.createConsumer(ActiveMQSession.java:838)
at org.mule.providers.jms.Jms11Support.createConsumer(Jms11Support.java:92)
at org.mule.providers.jms.TransactedJmsMessageReceiver.createConsumer(TransactedJmsMessageReceiver.java:302)
at org.mule.providers.jms.TransactedJmsMessageReceiver.poll(TransactedJmsMessageReceiver.java:147)
at org.mule.providers.PollingMessageReceiver.run(PollingMessageReceiver.java:71)
at org.mule.impl.work.WorkerContext.run(WorkerContext.java:301)
at edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:650)
at edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:675)
at java.lang.Thread.run(Thread.java:595)
************************* end catalina.out ****************************
*********************** mule-spring-config.xml
***************************
<beans>
<bean id="muleManager"
class="org.mule.extras.spring.config.AutowireUMOManagerFactoryBean"
destroy-method="dispose"/>
<!-- Used to set mule object names to their corresponding bean id -->
<bean id="muleNameProcessor"
class="org.mule.extras.spring.config.MuleObjectNameProcessor"/>
<bean id="applicationEventMulticaster"
class="org.mule.extras.spring.events.MuleEventMulticaster">
<property name="asynchronous" value="false"/>
</bean>
<bean id="jmsConnector" class="org.mule.providers.jms.JmsConnector">
<property name="specification" value="1.1"/>
<property name="connectionFactory" ref="connectionFactory"/>
<property name="maxRedelivery" value="3"/>
<property name="durable" value="false"/>
</bean>
<bean id="connectionFactory" singleton="false"
class="org.apache.activemq.spring.ActiveMQConnectionFactory">
<property name="brokerURL"
value="peer://${activemq.peer.group.name}/windows"/>
<property name="useBeanNameAsClientIdPrefix" value="true"/>
</bean>
<bean id="jmsTransationFactory"
class="org.mule.providers.jms.JmsTransactionFactory"/>
<bean id="defaultInterceptorStack" singleton="false"
class="java.util.ArrayList">
<constructor-arg>
<list>
<bean id="loggingInterceptor" singleton="false"
class="org.mule.interceptors.LoggingInterceptor"/>
<bean id="timerInterceptor" singleton="false"
class="org.mule.interceptors.TimerInterceptor"/>
</list>
</constructor-arg>
</bean>
<bean id="resourceDownloadUMO" class="org.mule.impl.MuleDescriptor">
<property name="inboundEndpoint">
<bean class="org.mule.impl.endpoint.MuleEndpoint">
<property name="endpointURI">
<bean class="org.mule.impl.endpoint.MuleEndpointURI">
<constructor-arg>
<value>jms://resource.aquire.queue</value>
</constructor-arg>
</bean>
</property>
<property name="transactionConfig"
ref="muleTransactionConfig"/>
</bean>
</property>
<property name="implementation" ref="resourceSaveOnLocalFileSystem"/>
<property name="interceptors">
<ref local="defaultInterceptorStack"/>
</property>
</bean>
<bean id="muleTransactionConfig"
class="org.mule.impl.MuleTransactionConfig">
<property name="factory" ref="jmsTransationFactory"/>
<property name="actionAsString" value="BEGIN_OR_JOIN"/>
</bean>
<bean id="resourceConversionUMO" class="org.mule.impl.MuleDescriptor">
<property name="inboundEndpoint">
<bean class="org.mule.impl.endpoint.MuleEndpoint">
<property name="synchronous" value="true"/>
<property name="endpointURI">
<bean class="org.mule.impl.endpoint.MuleEndpointURI">
<constructor-arg>
<value>jms://resource.conversion.queue</value>
</constructor-arg>
</bean>
</property>
<property name="transactionConfig"
ref="muleTransactionConfig"/>
</bean>
</property>
<property name="implementation" ref="fPJob"/>
</bean>
<bean id="resourcePersistanceUMO" class="org.mule.impl.MuleDescriptor">
<property name="inboundEndpoint">
<bean class="org.mule.impl.endpoint.MuleEndpoint">
<property name="synchronous" value="true"/>
<property name="endpointURI">
<bean class="org.mule.impl.endpoint.MuleEndpointURI">
<constructor-arg>
<value>vm://resource.persist.queue</value>
</constructor-arg>
</bean>
</property>
</bean>
</property>
<property name="implementation" ref="resourcePersister"/>
</bean>
...
</beans>
************* end mule-spring-config.xml *****************
Re: Embedded JMS transactions
Posted by Jeff Wysong <je...@roundboxmedia.com>.
I am using ActiveMQ 4.1 SNAPSHOT as of Oct 12, 2006.
Jeff Wysong wrote:
> I am getting a javax.management.InstanceAlreadyExistsException when
> trying to set up embedded transactions. When I googled it, the
> answers seemed to be restart the computer. I did that, but I still
> get the same error. Attached is a snipet of the catalina.out log and
> my mule-spring-config.xml. What am I doing wrong??? Thanks.
>
> -Jeff
>
> *************************** catalina.out
> *************************
>
> **********************************************************************
> * Mule Version Info not set *
> * *
> * Server started: Monday, November 6, 2006 4:29:13 PM EST *
> * Server ID: null *
> * JDK: 1.5.0_04 (mixed mode) *
> * OS: Windows XP - Service Pack 2 (5.1, x86) *
> * Host: dongerWy (10.0.0.120) *
> * *
> * Agents Running: *
> * Mule Admin: accepting connections on tcp://localhost:60504 *
> **********************************************************************
> Nov 6, 2006 4:29:15 PM
> org.mule.extras.spring.events.MuleEventMulticaster getDefaultDescriptor
> INFO: No receive endpoints have been set, using default '*'
> Nov 6, 2006 4:29:15 PM org.mule.impl.model.AbstractModel
> registerComponent
> INFO: Initialising component: muleEventMulticasterDescriptor
> Nov 6, 2006 4:29:15 PM org.mule.impl.model.AbstractModel
> registerComponent
> INFO: Starting component: muleEventMulticasterDescriptor
> Nov 6, 2006 4:29:15 PM org.mule.providers.AbstractConnector
> registerListener
> INFO: registering listener: muleEventMulticasterDescriptor on
> endpointUri: vm://*
> Nov 6, 2006 4:29:15 PM org.mule.providers.AbstractMessageReceiver connect
> INFO: Successfully connected to: vm://*
> Nov 6, 2006 4:29:15 PM org.mule.impl.container.MultiContainerContext
> getComponent
> INFO: Object: 'applicationEventMulticaster' found in container: spring
> Nov 6, 2006 4:29:15 PM org.springframework.web.context.ContextLoader
> initWebApplicationContext
> INFO: Using context class
> [org.springframework.web.context.support.XmlWebApplicationContext] for
> root WebApplicationContext
> Nov 6, 2006 4:29:15 PM org.springframework.web.context.ContextLoader
> initWebApplicationContext
> INFO: Root WebApplicationContext: initialization completed in 4296 ms
> Nov 6, 2006 4:29:15 PM org.apache.coyote.http11.Http11BaseProtocol start
> INFO: Starting Coyote HTTP/1.1 on http-8080
> Nov 6, 2006 4:29:15 PM
> org.apache.activemq.broker.jmx.ManagedRegionBroker registerSubscription
> SEVERE: Failed to register subscription QueueSubscription:
> consumer=ID:dongerWy-4560-1162848553413-4:0:9:1, destinations=0,
> dispatched=0, delivered=0,
> pending=0
> javax.management.InstanceAlreadyExistsException:
> org.apache.activemq:BrokerName=windows,Type=Subscription,
> persistentMode=Non-Durable, destinationType
> =Queue, destinationName=resource.aquire.queue,
> clientID=connectionFactory-4560-1162848553413-5_0
> at
> com.sun.jmx.mbeanserver.RepositorySupport.addMBean(RepositorySupport.java:452)
>
> at
> com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.internal_addObject(DefaultMBeanServerInterceptor.java:1410)
>
> at
> com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:936)
>
> at
> com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:337)
>
> at
> com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:497)
>
> at
> org.apache.activemq.broker.jmx.ManagedRegionBroker.registerSubscription(ManagedRegionBroker.java:285)
>
> at
> org.apache.activemq.broker.jmx.ManagedRegionBroker.registerSubscription(ManagedRegionBroker.java:205)
>
> at
> org.apache.activemq.broker.jmx.ManagedQueueRegion.createSubscription(ManagedQueueRegion.java:45)
>
> at
> org.apache.activemq.broker.region.AbstractRegion.addConsumer(AbstractRegion.java:202)
>
> at
> org.apache.activemq.broker.region.RegionBroker.addConsumer(RegionBroker.java:325)
>
> at
> org.apache.activemq.broker.BrokerFilter.addConsumer(BrokerFilter.java:85)
> at
> org.apache.activemq.advisory.AdvisoryBroker.addConsumer(AdvisoryBroker.java:78)
>
> at
> org.apache.activemq.broker.BrokerFilter.addConsumer(BrokerFilter.java:85)
> at
> org.apache.activemq.broker.MutableBrokerFilter.addConsumer(MutableBrokerFilter.java:95)
>
> at
> org.apache.activemq.broker.AbstractConnection.processAddConsumer(AbstractConnection.java:534)
>
> at
> org.apache.activemq.command.ConsumerInfo.visit(ConsumerInfo.java:296)
> at
> org.apache.activemq.broker.AbstractConnection.service(AbstractConnection.java:238)
>
> at
> org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:62)
>
> at
> org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:92)
>
> at
> org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:67)
>
> at
> org.apache.activemq.transport.vm.VMTransport.syncOneWay(VMTransport.java:97)
>
> at
> org.apache.activemq.transport.vm.VMTransport.oneway(VMTransport.java:84)
> at
> org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:45)
>
> at
> org.apache.activemq.transport.ResponseCorrelator.asyncRequest(ResponseCorrelator.java:67)
>
> at
> org.apache.activemq.transport.ResponseCorrelator.request(ResponseCorrelator.java:72)
>
> at
> org.apache.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:1146)
>
> at
> org.apache.activemq.ActiveMQSession.syncSendPacket(ActiveMQSession.java:1660)
>
> at
> org.apache.activemq.ActiveMQMessageConsumer.<init>(ActiveMQMessageConsumer.java:198)
>
> at
> org.apache.activemq.ActiveMQSession.createConsumer(ActiveMQSession.java:838)
>
> at
> org.mule.providers.jms.Jms11Support.createConsumer(Jms11Support.java:92)
> at
> org.mule.providers.jms.TransactedJmsMessageReceiver.createConsumer(TransactedJmsMessageReceiver.java:302)
>
> at
> org.mule.providers.jms.TransactedJmsMessageReceiver.poll(TransactedJmsMessageReceiver.java:147)
>
> at
> org.mule.providers.PollingMessageReceiver.run(PollingMessageReceiver.java:71)
>
> at org.mule.impl.work.WorkerContext.run(WorkerContext.java:301)
> at
> edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:650)
>
> at
> edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:675)
>
> at java.lang.Thread.run(Thread.java:595)
> Nov 6, 2006 4:29:15 PM
> org.apache.activemq.broker.jmx.ManagedRegionBroker registerSubscription
> SEVERE: Failed to register subscription QueueSubscription:
> consumer=ID:dongerWy-4560-1162848553413-4:0:2:1, destinations=0,
> dispatched=0, delivered=0,
> pending=0
> javax.management.InstanceAlreadyExistsException:
> org.apache.activemq:BrokerName=windows,Type=Subscription,
> persistentMode=Non-Durable, destinationType
> =Queue, destinationName=resource.conversion.queue,
> clientID=connectionFactory-4560-1162848553413-5_0
> at
> com.sun.jmx.mbeanserver.RepositorySupport.addMBean(RepositorySupport.java:452)
>
> at
> com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.internal_addObject(DefaultMBeanServerInterceptor.java:1410)
>
> at
> com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:936)
>
> at
> com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:337)
>
> at
> com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:497)
>
> at
> org.apache.activemq.broker.jmx.ManagedRegionBroker.registerSubscription(ManagedRegionBroker.java:285)
>
> at
> org.apache.activemq.broker.jmx.ManagedRegionBroker.registerSubscription(ManagedRegionBroker.java:205)
>
> at
> org.apache.activemq.broker.jmx.ManagedQueueRegion.createSubscription(ManagedQueueRegion.java:45)
>
> at
> org.apache.activemq.broker.region.AbstractRegion.addConsumer(AbstractRegion.java:202)
>
> at
> org.apache.activemq.broker.region.RegionBroker.addConsumer(RegionBroker.java:325)
>
> at
> org.apache.activemq.broker.BrokerFilter.addConsumer(BrokerFilter.java:85)
> at
> org.apache.activemq.advisory.AdvisoryBroker.addConsumer(AdvisoryBroker.java:78)
>
> at
> org.apache.activemq.broker.BrokerFilter.addConsumer(BrokerFilter.java:85)
> at
> org.apache.activemq.broker.MutableBrokerFilter.addConsumer(MutableBrokerFilter.java:95)
>
> at
> org.apache.activemq.broker.AbstractConnection.processAddConsumer(AbstractConnection.java:534)
>
> at
> org.apache.activemq.command.ConsumerInfo.visit(ConsumerInfo.java:296)
> at
> org.apache.activemq.broker.AbstractConnection.service(AbstractConnection.java:238)
>
> at
> org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:62)
>
> at
> org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:92)
>
> at
> org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:67)
>
> at
> org.apache.activemq.transport.vm.VMTransport.syncOneWay(VMTransport.java:97)
>
> at
> org.apache.activemq.transport.vm.VMTransport.oneway(VMTransport.java:84)
> at
> org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:45)
>
> at
> org.apache.activemq.transport.ResponseCorrelator.asyncRequest(ResponseCorrelator.java:67)
>
> at
> org.apache.activemq.transport.ResponseCorrelator.request(ResponseCorrelator.java:72)
>
> at
> org.apache.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:1146)
>
> at
> org.apache.activemq.ActiveMQSession.syncSendPacket(ActiveMQSession.java:1660)
>
> at
> org.apache.activemq.ActiveMQMessageConsumer.<init>(ActiveMQMessageConsumer.java:198)
>
> at
> org.apache.activemq.ActiveMQSession.createConsumer(ActiveMQSession.java:838)
>
> at
> org.mule.providers.jms.Jms11Support.createConsumer(Jms11Support.java:92)
> at
> org.mule.providers.jms.TransactedJmsMessageReceiver.createConsumer(TransactedJmsMessageReceiver.java:302)
>
> at
> org.mule.providers.jms.TransactedJmsMessageReceiver.poll(TransactedJmsMessageReceiver.java:147)
>
> at
> org.mule.providers.PollingMessageReceiver.run(PollingMessageReceiver.java:71)
>
> at org.mule.impl.work.WorkerContext.run(WorkerContext.java:301)
> at
> edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:650)
>
> at
> edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:675)
>
> at java.lang.Thread.run(Thread.java:595)
>
>
> ************************* end catalina.out
> ****************************
>
> *********************** mule-spring-config.xml
> ***************************
> <beans>
>
> <bean id="muleManager"
> class="org.mule.extras.spring.config.AutowireUMOManagerFactoryBean"
> destroy-method="dispose"/>
>
> <!-- Used to set mule object names to their corresponding bean id -->
> <bean id="muleNameProcessor"
> class="org.mule.extras.spring.config.MuleObjectNameProcessor"/>
>
> <bean id="applicationEventMulticaster"
> class="org.mule.extras.spring.events.MuleEventMulticaster">
> <property name="asynchronous" value="false"/>
> </bean>
>
> <bean id="jmsConnector" class="org.mule.providers.jms.JmsConnector">
> <property name="specification" value="1.1"/>
> <property name="connectionFactory" ref="connectionFactory"/>
> <property name="maxRedelivery" value="3"/>
> <property name="durable" value="false"/>
> </bean>
>
> <bean id="connectionFactory" singleton="false"
> class="org.apache.activemq.spring.ActiveMQConnectionFactory">
> <property name="brokerURL"
> value="peer://${activemq.peer.group.name}/windows"/>
> <property name="useBeanNameAsClientIdPrefix" value="true"/>
> </bean>
>
> <bean id="jmsTransationFactory"
> class="org.mule.providers.jms.JmsTransactionFactory"/>
>
> <bean id="defaultInterceptorStack" singleton="false"
> class="java.util.ArrayList">
> <constructor-arg>
> <list>
> <bean id="loggingInterceptor" singleton="false"
> class="org.mule.interceptors.LoggingInterceptor"/>
> <bean id="timerInterceptor" singleton="false"
> class="org.mule.interceptors.TimerInterceptor"/>
> </list>
> </constructor-arg>
> </bean>
>
> <bean id="resourceDownloadUMO" class="org.mule.impl.MuleDescriptor">
> <property name="inboundEndpoint">
> <bean class="org.mule.impl.endpoint.MuleEndpoint">
> <property name="endpointURI">
> <bean class="org.mule.impl.endpoint.MuleEndpointURI">
> <constructor-arg>
> <value>jms://resource.aquire.queue</value>
> </constructor-arg>
> </bean>
> </property>
> <property name="transactionConfig"
> ref="muleTransactionConfig"/>
> </bean>
> </property>
> <property name="implementation"
> ref="resourceSaveOnLocalFileSystem"/>
> <property name="interceptors">
> <ref local="defaultInterceptorStack"/>
> </property>
> </bean>
>
> <bean id="muleTransactionConfig"
> class="org.mule.impl.MuleTransactionConfig">
> <property name="factory" ref="jmsTransationFactory"/>
> <property name="actionAsString" value="BEGIN_OR_JOIN"/>
> </bean>
>
> <bean id="resourceConversionUMO" class="org.mule.impl.MuleDescriptor">
> <property name="inboundEndpoint">
> <bean class="org.mule.impl.endpoint.MuleEndpoint">
> <property name="synchronous" value="true"/>
> <property name="endpointURI">
> <bean class="org.mule.impl.endpoint.MuleEndpointURI">
> <constructor-arg>
> <value>jms://resource.conversion.queue</value>
> </constructor-arg>
> </bean>
> </property>
> <property name="transactionConfig"
> ref="muleTransactionConfig"/>
> </bean>
> </property>
> <property name="implementation" ref="fPJob"/>
> </bean>
>
> <bean id="resourcePersistanceUMO" class="org.mule.impl.MuleDescriptor">
> <property name="inboundEndpoint">
> <bean class="org.mule.impl.endpoint.MuleEndpoint">
> <property name="synchronous" value="true"/>
> <property name="endpointURI">
> <bean class="org.mule.impl.endpoint.MuleEndpointURI">
> <constructor-arg>
> <value>vm://resource.persist.queue</value>
> </constructor-arg>
> </bean>
> </property>
> </bean>
> </property>
> <property name="implementation" ref="resourcePersister"/>
> </bean>
> ...
> </beans>
>
>
> ************* end mule-spring-config.xml *****************
>