Request-response without clock sync

2010-01-12 Thread uprooter
Hello. I have issue where I can't assure time synchronization between the broker and the clients. I'm using request response and all of my messages are lost if the client time is ahead of the broker time. What would be the right way of soving this problem if I still want to use request-response.

Re: ActiveMQ 5.3.0 and Camel's PollingConsumer

2010-01-12 Thread Dragisa Krsmanovic
I was finally able to write unit test to replicate the problem without using Camel. Here is the issue https://issues.apache.org/activemq/browse/AMQ-2565 On Mon, 2009-12-14 at 09:53 -0800, Dragisa Krsmanovic wrote: > On Mon, 2009-12-14 at 09:48 -0800, Dragisa Krsmanovic wrote: > > while ((exchang

Re: jdbc persistence hangs with error about using a closed statement

2010-01-12 Thread Marshall Pierce
On 01/12/2010 02:06 AM, Gary Tully wrote: > Hi Marshall, > can you add your configuration to that jira. I wonder/could a jdbc pool > timeout or periodic check help to ensure that expired connections are reaped > by the pool before being returned to the jdbc persistence adapter? > > Do you find tha

Problems with prefetch and TemporaryQueues

2010-01-12 Thread Zemus
Hi, I have a problem where TemporaryQueues are left (with 0 consumers) after the applications creating them have finished. This scenario occurs for both ActiveMQ 4.1.1 and 5.3.0 on my P4 2.6 GHz, 3 GB RAM, Ubuntu 9.10, Sun JDK, default settings for ActiveMQ. I've tried to recreate a simpler ver

Re: CMS 3.1 NoSuchElementException with failover

2010-01-12 Thread Sodan
apr-1.3.9 apr-iconv-1.2.1 apr-util-1.3.9 first one comes here: - debug.exe!decaf::lang::exceptions::NoSuchElementException::NoSuchElementException(const char * file=0x01486e78, const int lineNumber=239, const char * msg=0x01486f28, ...) Line 110 C++ debug.exe!decaf::util::StlMap,st

Re: CMS 3.1 NoSuchElementException with failover

2010-01-12 Thread Timothy Bish
On Tue, 2010-01-12 at 06:51 -0800, Sodan wrote: > its simple, all I do is: > > activemq::library::ActiveMQCPP::initializeLibrary(); > itsConnectionFactory = new ActiveMQConnectionFactory(brokerURI); > itsConnection = itsConnectionFactory->createConnection(); > > and at that point 'createConnectio

Re: CMS 3.1 NoSuchElementException with failover

2010-01-12 Thread Sodan
its simple, all I do is: activemq::library::ActiveMQCPP::initializeLibrary(); itsConnectionFactory = new ActiveMQConnectionFactory(brokerURI); itsConnection = itsConnectionFactory->createConnection(); and at that point 'createConnection', the first NoSuchElementException appears... (it comes fro

Re: CMS 3.1 NoSuchElementException with failover

2010-01-12 Thread Timothy Bish
On Tue, 2010-01-12 at 02:59 -0800, Sodan wrote: > Hi all > > (using cms 3.1, vs 2008) > > If we do broker url: > tcp://host:61616 > then everything is fine, but we need failover (for automatic reconnect) so > we do: > failover:(tcp://host:61616) > > but then we get a lot of: > First-chance excep

JMS and DATABASE operations in a single transaction

2010-01-12 Thread Mparida
Hello, I want to execute a message and a DB operation in a single transaction. I know it is only possible using JTA. I am not using spring. I am using Tom Cat server as an App Server. Can any one give an idea of how to achieve this? Had any one implemented similar kind of thing? Thank You, Mano

Re: Thread for each client

2010-01-12 Thread marcin80
Hi, Thanks for your replay. Netstat returns following (for 61616 port): C:\>netstat -an | find "61616" TCP127.0.0.1:1975 127.0.0.1:61616ESTABLISHED TCP127.0.0.1:1979 127.0.0.1:61616ESTABLISHED TCP127.0.0.1:1980 127.0.0.1:61616ESTA

Re: Thread for each client

2010-01-12 Thread Rob Davies
Hi Marcin, the thread is allocated from a pool - it should get collected after a minute (I think) - you not seeing that ? On 12 Jan 2010, at 11:59, marcin80 wrote: Hi, I'm using ActiveMQ 5.2 and I've noticed thad ActiveMQ create new thread for every connection but even the client will d

Re: Thread for each client

2010-01-12 Thread Gary Tully
With a normal disconnect from a java client those reader threads should disappear. With an abnormal disconnect, where the socket is not fully closed, it can take some time (os tcp config dependent) for the broker to identify the connection as closed. What does netstat tell you about the active con

Thread for each client

2010-01-12 Thread marcin80
Hi, I'm using ActiveMQ 5.2 and I've noticed thad ActiveMQ create new thread for every connection but even the client will disconnect its thread still alive (state RUNNABLE). It is ActiveMQ normal behavior? Can I change this? I would like to finalize thread if client will dissconnect. Cheers, Mar

CMS 3.1 NoSuchElementException with failover

2010-01-12 Thread Sodan
Hi all (using cms 3.1, vs 2008) If we do broker url: tcp://host:61616 then everything is fine, but we need failover (for automatic reconnect) so we do: failover:(tcp://host:61616) but then we get a lot of: First-chance exception at 0x7505e124 in server_debug.exe: Microsoft C++ exception: decaf:

Re: jdbc persistence hangs with error about using a closed statement

2010-01-12 Thread Gary Tully
Hi Marshall, can you add your configuration to that jira. I wonder/could a jdbc pool timeout or periodic check help to ensure that expired connections are reaped by the pool before being returned to the jdbc persistence adapter? Do you find that the symptom is unrecoverable, that is, you see the s

Re: amqPersistenceAdapter or kahaDB?

2010-01-12 Thread Dejan Bosanac
Hi Marteen, I think http://activemq.apache.org/persistence.html is the right place for it. We just need more material there. Cheers -- Dejan Bosanac - http://twitter.com/dejanb Open Source Integration - http://fusesource.com/ ActiveMQ in Action - http://www.manning.com/snyder/ Blog - http://ww

Re: JNDI usage

2010-01-12 Thread FranzWong
Thank you. I am looking forward to that :) Franz rajdavies wrote: > > Yes we should do an article on that - I would recommend you look at > Apache Directory Server for what you want: http://directory.apache.org/ > On 12 Jan 2010, at 02:23, FranzWong wrote: > >> >> I have read the page http