I have exactly the same problem. Any help is greatly appreciated.
Type: Posts; User: janylj; Keyword(s):
I have exactly the same problem. Any help is greatly appreciated.
Hello,
Because of sharding, we have multiple data sources. And we injected a list of all available data sources to the service. The service would determine which data source to use at run time.
...
Hello,
I have exposed a Java service using Spring Remoting and JMS as the underlying communication protocol. I exactly followed Spring Reference Doc.
My Java client works just fine. Now I have...
I ran another test and here is the thread dump when consumer stops receiving. All of message listener container threads are waiting for dequeueing. I notice that default receive timeout is 1000ms...
Thanks for your reply.
1. It usually took 5-10 minutes to reproduce the problem. However, there is no fixed steps to repo it. We just changed the load between 10 mesg/sec to 10K mesg/sec until the...
The DefaultMessageListenerContainer stops receiving message after some time. The problem seems to be triggered by varying the load. I am using Spring 2.5.5 and ActiveMQ 5.1. I am attaching the...
We have some monitoring requirements of ActiveMQ. But the built-in JMX support from ActiveMQ comes in short of Notification and Alert. The SpringSource AMS looks promising as a monitoring platform...
OK. I understand that durable subscriber will not go away when JVM closes. It's exactly what my use case for durable subscriber to receive messages during its downtime. However, how to permanently...
I set up a DefaultMessageListenerContainer for a durable subscriber. After running my test program, the container bean should be destroyed and all the resources should be released. However, from...
My problem is fixed when I replaced with the latest 2.0.7 spring.jar. Thank you for everyone who viewed my post.
Could anyone please help?
I checked out the Spring document. It says:
If the target object to be proxied implements at least one interface then a JDK dynamic proxy will be used. All of the...
I have the Command interface:
public interface Command<A extends Action> {
public Response execute(A action);
}
The LoginCommand class:
public class LoginCommand implements...