Re: Implementing failover for Net::Stomp

Hi Simon, An async receives patch would be great. Thanks! BTW, would it be possible for you to release a failover patch for master/slave or broker networks? And transaction support would also be nice. Thanks, Ramit Simon Wistow wrote: > > On Fri, Mar 21, 2008 at 02:44:00PM -0700, Dylan Vanderho

Re: Implementing failover for Net::Stomp

Hello Dejan, I had a look at the PHP client. I was following a similar approach, but the major problem was that the ActiveMQ shutdown hook was enabled, which did not let the socket close for around 10secs. Disabling it has made things a lot better. Thanks for your time. Regards, Ramit Dejan Bosa

enqueue counter always equals pendingqueue size,and dequeue counter=0

when i use jconsole monitor AMQ,i found enqueue counter always equals pendingqueue size,and dequeue counter=0 after running one day. I Use the SNAPSHOT of 0324 any advise -- View this message in context: http://www.nabble.com/enqueue-counter-always-equals-pendingqueue-size%2Cand-dequeue-cou

setting subscription recovery policy...

How do I set the subscription recovery policy options at the bottom of this page? http://activemq.apache.org/subscription-recovery-policy.html Can someone give me an example URL to use in the java code? I'm not using XML config files. Thanks..

Migrating to 5.0 from 4.1

Hi there, Is 5.0 a drop in replacement for 4.1? I am thinking specifically when configuring my jms environment using DefaultMessageListenerContainer in spring 2.5. I cannot find a migration guide any place obvious. Thanks very much, Mike -- View this message in context: http://www.nabble.co

Re: Pushing messages from Adempiere to ActiveMQ

It appears that one of your clients is setting the client identifier explicitly for its connection to the broker called, "wattle.broker". However, that client id has already been taken by another client that is already connected to the broker and thus the client id is being treated as an invalid d

Re: ActiveMQ Transport Server: tcp://localhost:61616] class [TransportConnector] Could not accept connection from /127.0.0.1:53085: java.net.SocketException: Socket closed

Looks like the remote endpoint at the other end of this transport connection closed the connection. Maybe due to an inactivity timeout? Joe Goto www.ttmsolutions.com for a free ActiveMQ user guide Fuddi wrote: > > > Hi, > > Thanks for a good product. > > running ActiveMQ with broker URL

Pushing messages from Adempiere to ActiveMQ

Good Day, I am running adempiere350`s and have configured it for replication.When i start JBOSS it also starts activemq with no errors since i have embedded it in jboss.I have created an order which i want to replicate to another postgresql on our network.When i check for the order in Adempiere it

Re: CPPUnit configuration

How did you install the CPPUnit code in /opt? did you use the ./configure and the make and install CPPUnit into that location. There are certain things that need to be generated and placed in specific locations in the install in order for the autoconf macros to find the CPPUnit tools. On Tue, 20

ActiveMQ Transport Server: tcp://localhost:61616] class [TransportConnector] Could not accept connection from /127.0.0.1:53085: java.net.SocketException: Socket closed

Hi, Thanks for a good product. running ActiveMQ with broker URL = vm:broker:(tcp://localhost:61616)?brokerName=MessageTransport getting sometime this error: [2008-03-25 11:58:17] : [DEBUG] thread [ActiveMQ Transport: tcp:///127.0.0.1:54901] class [Transport] Transport failed: java.net.SocketE

Re: Implementing failover for Net::Stomp

On Fri, Mar 21, 2008 at 02:44:00PM -0700, Dylan Vanderhoof said: > If you get this worked out, would you be willing to release your > Net::Stomp hacks? The original author of the Net::Stomp client on CPAN doesn't work with ActiveMQ any more and so has let it lapse. I had a word with him and I c

Re: setting a MessageListener on a consumer?

On 24/03/2008, Andrew M <[EMAIL PROTECTED]> wrote: > I'm using the method below to create a Topic and Consumer and register my > MessageListener. I'm worried that with a retroactive consumer I'm missing > messages between the .createConsumer() method and when the MessageListener > is actually r

Re: ActiveMQ RA serialization issue in Websphere

Hi, Juvaraj! The problem is that the ManagedConnectionFactory provided in the RA is not serializable (well, it actually is serializable but its reference to the ResourceAdapter implementation is transient). I have created a patch for this problem (which is most likely to occur in any J2EE environ