disable persistence, and help w/ missing messages

Hi, I have just a few questions ... I'm running activemq 5.1.0 and would like to know how to turn off persistence. I downloaded the activemq binaries, decompressed them in my home dir, and started them via './bin/activemq > a.log &'. I looked at the default xml file in the ./conf dir, but saw no

Re: receiveNoWait() return null even if there are messages in queue

One more thing I noticed in the stack is that there is thread in MQ which never finishes even though the main function is done Below is the stack. "ActiveMQ Transport: tcp:///10.10.15.156:61616" prio=6 tid=0x0b1e1000 nid=0x1078 runnable [0x0b83f000..0x0b83fb14] java.lang.Thread.State: RUNNABLE

receiveNoWait() return null even if there are messages in queue

Hi We are using JAVA Program standalone to poll activeMQ queues. The way we do is following we go and try to get the message using consumer.receive(timeout) call and if the it receives the message we use while loop to get more messages if they are in the queue. The sample code of what we do is att

Re: Topic selector with non ASCII characters

On Thu, Mar 26, 2009 at 9:10 AM, retep wrote: > > Ok, i have found, that the problem is in the ActiveMQ-C++-Client. The client > do not handle the encoding correct. I have correct it. Now it's works fine. Care to submit a patch for the correction so that it gets into the next ActiveMQ-CPP client

Re: Embedded broker hangs after restart

Hi Jarek, great that it reproduced easily. That test case should be fine. I have created a jira issue to track this: https://issues.apache.org/activemq/browse/AMQ-2185 Could you attach your test case to the issue (file attach) and grant the ASF license to your test. (tick the check box) thanks, G

Re: Alternatives for deprecated setKeyAndTrustManagers in ActiveMQSSLConnectionFactory

Just looked at SslTransportFactory.setKeyAndTrustManagers again, it makes sense to deprecate because this api used to set the sslcontext for the factory. It is now changed in line with the use of thread local but the api for setting the thread local is SSLContext.setCurrentContext. So the behavio

Re: Alternatives for deprecated setKeyAndTrustManagers in ActiveMQSSLConnectionFactory

An ActiveMQ ssl client is just like an other java application that wants to use ssl. Configuration is through JSSE. The ActiveMQ SSLContext is just a thread specific holder for a regular SSLContext, if no context is specified the platform default (from JSSE) will be used. The thread specific nature

Re: Embedded broker hangs after restart

Gary, It was not so hard to reproduce this exception as it looked to me in the beginning. Maybe it is not the best test case I have every written in my life, but at least I get the same error message. package com.assembla.client.impl.tests; import java.io.File; import java.net.URISyntaxException

RE: problems reading a cms::BytesMessage.

On Thu, 2009-03-26 at 17:55 +0100, Eduardo Montoya wrote: > Hello, I have upgraded to the new 2.2.5 version of activemq-cpp > > but when I receive a bytesmessage within onMessage listener method, > I get the following error: > > < 836> 26 March 2009 05:34:55 PM[ERROR] - at [.\MyDispatcher.cpp

Re: Embedded broker hangs after restart

Jarek, good news, but that exception is ugly. It would be smashing if you could reproduce in a Junit tests case using just the JMS apis, but it may be difficult to reproduce. I think I need to turn the queue test case from AMQ-2149 into a Topic scenario. That may reproduce. 2009/3/26 Jarosław Pał

Re: Alternatives for deprecated setKeyAndTrustManagers in ActiveMQSSLConnectionFactory

Am i missing some information or is the question too dumb. Why is no one answering %-| soody wrote: > > We want to use SSL in our client that will be sending messages to > ActiveMQ. But we can't set the trust stores and key stores using > System.setProperty(), as our's is an enterprise applica

Re: Reconnection

The consumer is running in a PC with linux (Fedora Core10). This PC is connected to a HUB. The messagebroker and producer are in other PC and it is connected to other HUB. Two HUBS are connected. The producer is sending messages and consumer receives them well. When I switch off a HUB, the consume

RE: problems reading a cms::BytesMessage.

Hello, I have upgraded to the new 2.2.5 version of activemq-cpp but when I receive a bytesmessage within onMessage listener method, I get the following error: < 836> 26 March 2009 05:34:55 PM[ERROR] - at [.\MyDispatcher.cpp] (MyDispatcher::onMessage ) at line 110 ByteArrayInputStre

Re: Use of MirroredQueues results in OutOfMemoryError

Hi there, I apologize for not heaving read all the information from the beginning - I shouldn't answer mails while traveling ;) I could reproduce the problem using your test case in both AMQ 5.2 and the current trunk. I have made the same observations regarding the objects that are growin

Re: Reconnection

Hi, perhaps you could come up with a small test case that shows the error ? Best regards Andreas On Mar 26, 2009, at 10:11 AM, dongabda wrote: Yes, I'm using the excepcionListener and onException, but any exception is captured when the PC lost the network link. If I stop the messagebrok

Re: Reconnection

The consumer is running in a Linux (Fedora Core 10) I saw (doing netstat) that the tcp connection appears like ESTABLISHED, and this is not true because the netkork link is lost. Any idea? Timothy Bish wrote: > > On Thu, 2009-03-26 at 02:11 -0700, dongabda wrote: >> Yes, I'm using the excepcio

Alternatives for deprecated setKeyAndTrustManagers in ActiveMQSSLConnectionFactory

We want to use SSL in our client that will be sending messages to ActiveMQ. But we can't set the trust stores and key stores using System.setProperty(), as our's is an enterprise application. Are there any ways that I can set the trust and key stores, basically the SSLContext. Currently what we

Re: Topic selector with non ASCII characters

Ok, i have found, that the problem is in the ActiveMQ-C++-Client. The client do not handle the encoding correct. I have correct it. Now it's works fine. Peter retep wrote: > > Hi, > > I'am using UTF8 encoding for the selector and the property value. > > Peter > > > bsnyder wrote: >> >> On

Re: Embedded broker hangs after restart

Gary, I did recommended changes. On the embedded broker side everything looks fine now. I restarted Jetty (embedded broker) many times and it worked. What is interesting I started to see some exceptions in my other application that is listening on the same ActiveMQ server. I think below schema wi

Re: Reconnection

On Thu, 2009-03-26 at 02:11 -0700, dongabda wrote: > Yes, I'm using the excepcionListener and onException, but any exception is > captured when the PC lost the network link. If I stop the messagebroker the > exception occurs, but with link lost not. How can I resolve it? > What OS are you

Stomp client for java, seems to hang?

Hi! I've done a quick test where I tried to publish JMS queues via StompConnect (http://stomp.codehaus.org/StompConnect) and then use ActiveMQ as a JMS implementation for handling the published queues.Unfortunately this didn't work at all, and from spending yesterday in debug-mode and stepping thr

Re: Embedded broker hangs after restart

Hi Jarek, some similar behaviour is expressed by issue AMQ-2149. One aspect of the problem is related to the persistent index used by the Kaha store. You could try using a VM (in memory) index to see if it helps in your case. To configure set th

ActiveMQ-CPP 2.2.5 Released

Hi everyone, The ActiveMQ-CPP 2.2.5 release is now official! You can download the source distribution here: http://activemq.apache.org/cms/activemq-cpp-225-release.html This release offers several bug fixes that have been made since the 2.2.4 release, see the download page for the complete list.

Re: Reconnection

Yes, I'm using the excepcionListener and onException, but any exception is captured when the PC lost the network link. If I stop the messagebroker the exception occurs, but with link lost not. How can I resolve it? -- View this message in context: http://www.nabble.com/Reconnection-tp226

Re: Embedded broker hangs after restart

Sorry I forgot to copy embedded broker configuration: public abstract class UMMClientConfiguration extends ConfigurationSupport{ private static final String OUTGOING_LOCAL_TOPIC = "OUTGOING"; private static final String INCOMING_LOCAL_TOPIC = "INCOMING"; @Bean public BrokerServic

Embedded broker hangs after restart

Hi, I have strange behavior of embedded ActiveMQ 5.2 broker. I have an web application running under Jetty 1.6.14 (with Spring 2.5.6). I have embedded broker that is connected to ActiveMQ server through JMS connector.I have to topics INCOMING and OUTGOING that retrieve and forward messages to Act

Re: Topic selector with non ASCII characters

Hi, I'am using UTF8 encoding for the selector and the property value. Peter bsnyder wrote: > > On Wed, Mar 25, 2009 at 9:24 AM, retep wrote: >> >> Hi, >> >> we are using topic messages to sent messages from one user to another. >> Our >> program subscribe a durable consumer with selector "Us