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.

Reply via email to