I log when the "onMessage" is executed.
And something is written in my log file.
So, yes, it is touched at startup.
Here is the log...
2013-11-04 16:21:11 ca.berger.amq.server.AuthConsumer processMessageAndReply
INFO: MESSAGE BEAN: Message received by AuthConsumer:
<request>
<dataSource>Auth</dataSource>
<operationType>fetch</operationType>
<data>
<environment>dev</environment>
<session_id>3argDS3GYKLjEVtB7h4l7w</session_id>
<device>pc</device>
</data>
</request>
2013-11-04 16:21:11 org.apache.activemq.ra.ActiveMQEndpointWorker$1$1
onException
GRAVE: Connection to broker failed: Unexpected error occured:
java.lang.InternalError: java.lang.InternalError:
java.lang.reflect.InvocationTargetException
at
org.apache.openejb.util.proxy.LocalBeanProxyFactory.createProxy(LocalBeanProxyFactory.java:136)
at
org.apache.openejb.util.proxy.LocalBeanProxyFactory.createProxy(LocalBeanProxyFactory.java:142)
at
org.apache.openejb.util.proxy.LocalBeanProxyFactory.newProxyInstance(LocalBeanProxyFactory.java:55)
at
org.apache.openejb.core.mdb.EndpointFactory.createEndpoint(EndpointFactory.java:73)
at
org.apache.activemq.ra.ServerSessionPoolImpl.createEndpoint(ServerSessionPoolImpl.java:92)
...
--
Jocelyn Dionne
Romain Manni-Bucau wrote
> Hi
>
> Ensure the mdb is touched at startup
> Le 4 nov. 2013 21:32, "Jocelyn Dionne" <
> jocelynd@
> > a écrit :
>
>> We are having this problem with OpenEJB 4.5.2.
>> We have a durable topic subscriber and when starting, if more than one
>> message are waiting in ActiveMQ for this topic, the problem occurs.
>>
>> You wrote that it could be a concurrency problem.
>>
>> What do I have to do to solve it ?
>>
>>
>> Regards.
>>
>> Jocelyn Dionne
>>
>>
>>
>> Romain Manni-Bucau wrote
>> > Hi
>> >
>> > we had a concurrency issue some times ago on proxying of local beans.
>> Do
>> > you send a bunch of messages at the same time?
>> >
>> > *Romain Manni-Bucau*
>> > *Twitter: @rmannibucau <https://twitter.com/rmannibucau>*
>> > *Blog:
>> > **
>> http://rmannibucau.wordpress.com/*<http://rmannibucau.wordpress.com/>
>> ;
>> > *LinkedIn: **http://fr.linkedin.com/in/rmannibucau*
>> > *Github: https://github.com/rmannibucau*
>> >
>> >
>> >
>> > 2013/8/26 Christian Schlichtherle <
>>
>> > christian@
>>
>> > >
>> >
>> >> Hi everyone,
>> >>
>> >> I use a vanilla standalone TomEE+ 1.5.2 installation. When running my
>> >> messaging apps, I do get several of these exceptions:
>> >>
>> >> Exception in thread "ActiveMQ VMTransport: vm://localhost#0-1"
>> >> java.lang.InternalError: java.lang.InternalError:
>> >> java.lang.reflect.InvocationTargetException
>> >> at
>> >>
>> org.apache.openejb.util.proxy.LocalBeanProxyFactory.createProxy(LocalBeanProxyFactory.java:136)
>> >> at
>> >>
>> org.apache.openejb.util.proxy.LocalBeanProxyFactory.createProxy(LocalBeanProxyFactory.java:142)
>> >> at
>> >>
>> org.apache.openejb.util.proxy.LocalBeanProxyFactory.newProxyInstance(LocalBeanProxyFactory.java:55)
>> >> at
>> >>
>> org.apache.openejb.core.mdb.EndpointFactory.createEndpoint(EndpointFactory.java:73)
>> >> at
>> >>
>> org.apache.activemq.ra.ServerSessionPoolImpl.createEndpoint(ServerSessionPoolImpl.java:92)
>> >> at
>> >>
>> org.apache.activemq.ra.ServerSessionPoolImpl.createServerSessionImpl(ServerSessionPoolImpl.java:76)
>> >> at
>> >>
>> org.apache.activemq.ra.ServerSessionPoolImpl.getServerSession(ServerSessionPoolImpl.java:116)
>> >> at
>> >>
>> org.apache.activemq.ActiveMQConnectionConsumer.dispatch(ActiveMQConnectionConsumer.java:129)
>> >> at
>> >>
>> org.apache.activemq.ActiveMQConnection$3.processMessageDispatch(ActiveMQConnection.java:1840)
>> >> at
>> >>
>> org.apache.activemq.command.MessageDispatch.visit(MessageDispatch.java:109)
>> >> at
>> >>
>> org.apache.activemq.ActiveMQConnection.onCommand(ActiveMQConnection.java:1821)
>> >> at
>> >>
>> org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:116)
>> >> at
>> >>
>> org.apache.activemq.transport.MutexTransport.onCommand(MutexTransport.java:50)
>> >> at
>> >>
>> org.apache.activemq.transport.vm.VMTransport.iterate(VMTransport.java:241)
>> >> at
>> >>
>> org.apache.activemq.thread.PooledTaskRunner.runTask(PooledTaskRunner.java:129)
>> >> at
>> >>
>> org.apache.activemq.thread.PooledTaskRunner$1.run(PooledTaskRunner.java:47)
>> >> at
>> >>
>> java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
>> >> at
>> >>
>> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
>> >> at java.lang.Thread.run(Thread.java:680)
>> >>
>> >> at
>> >>
>> org.apache.openejb.util.proxy.LocalBeanProxyFactory.newProxyInstance(LocalBeanProxyFactory.java:58)
>> >> at
>> >>
>> org.apache.openejb.core.mdb.EndpointFactory.createEndpoint(EndpointFactory.java:73)
>> >> at
>> >>
>> org.apache.activemq.ra.ServerSessionPoolImpl.createEndpoint(ServerSessionPoolImpl.java:92)
>> >> at
>> >>
>> org.apache.activemq.ra.ServerSessionPoolImpl.createServerSessionImpl(ServerSessionPoolImpl.java:76)
>> >> at
>> >>
>> org.apache.activemq.ra.ServerSessionPoolImpl.getServerSession(ServerSessionPoolImpl.java:116)
>> >> at
>> >>
>> org.apache.activemq.ActiveMQConnectionConsumer.dispatch(ActiveMQConnectionConsumer.java:129)
>> >> at
>> >>
>> org.apache.activemq.ActiveMQConnection$3.processMessageDispatch(ActiveMQConnection.java:1840)
>> >> at
>> >>
>> org.apache.activemq.command.MessageDispatch.visit(MessageDispatch.java:109)
>> >> at
>> >>
>> org.apache.activemq.ActiveMQConnection.onCommand(ActiveMQConnection.java:1821)
>> >> at
>> >>
>> org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:116)
>> >> at
>> >>
>> org.apache.activemq.transport.MutexTransport.onCommand(MutexTransport.java:50)
>> >> at
>> >>
>> org.apache.activemq.transport.vm.VMTransport.iterate(VMTransport.java:241)
>> >> at
>> >>
>> org.apache.activemq.thread.PooledTaskRunner.runTask(PooledTaskRunner.java:129)
>> >> at
>> >>
>> org.apache.activemq.thread.PooledTaskRunner$1.run(PooledTaskRunner.java:47)
>> >> at
>> >>
>> java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
>> >> at
>> >>
>> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
>> >> at java.lang.Thread.run(Thread.java:680)
>> >>
>> >> Looking at the source code I see that it can't create a proxy, but I
>> >> can't
>> >> figure what it tries to proxy nor why it fails. Googling it did not
>> help
>> >> either. So has anyone an idea what could cause this? I seem to loose
>> some
>> >> messages, maybe because of this.
>> >>
>> >> Regards,
>> >> Christian Schlichtherle
>> >>
>>
>>
>>
>>
>>
>> --
>> View this message in context:
>> http://openejb.979440.n4.nabble.com/Exception-from-ActiveMQ-tp4664826p4665945.html
>> Sent from the OpenEJB User mailing list archive at Nabble.com.
>>
--
View this message in context:
http://openejb.979440.n4.nabble.com/Exception-from-ActiveMQ-tp4664826p4665952.html
Sent from the OpenEJB User mailing list archive at Nabble.com.
