KahabDB compatibility issue between ActiveMQ 5.10 and ActiveMQ 5.11

2015-02-24 Thread xabhi
Hi, I was testing to see if kahadb created by ActiveMQ 5.10 can be used with ActiveMQ 5.11. ActiveMQ 5.11 starts up fine but is not able to access the older persistent messages which were stored when KahaDB was being used with ActiveMQ 5.10. Is this expected? Also I see following directories in ka

Wrapper?

2015-02-24 Thread Kevin Burton
I was looking at ActiveMQ’s use of ‘wrapper’. Does anyone use this? http://activemq.apache.org/java-service-wrapper.html Why not run just a normal init script ? I was playing with start-stop-daemon in Debian and the init script generator should work with the bin/activemq script we have. I buil

Two JIRA bugs with merge requests.

2015-02-24 Thread Kevin Burton
Hey guys. Couple questions. I have two JIRA tickets with merge requests: https://issues.apache.org/jira/browse/AMQ-5571 https://issues.apache.org/jira/browse/AMQ-5609 Would like to get these into the next release so that I don’t have to admin them on my end. I’m going to push them into produc

Re: A proposal to rewrite purgeInactiveDestinations locking to prevent queue GC lockups.

2015-02-24 Thread Kevin Burton
Yes. Agreed that they look like integration tests. More than a minute is more of an integration test. What I’ll do is come up with a proposal once I have our internal code testing with parallelism. My ideal is to use the maven dependency graph and possibly something like codeship’s new ParallelC

Re: A proposal to rewrite purgeInactiveDestinations locking to prevent queue GC lockups.

2015-02-24 Thread Hadrian Zbarcea
Kevin, Go for it. Yes, out tests need a lot of love. Actually most of the tests are not really unit tests, but more like integration tests. Helping with the spring (as in season) cleanup would be immensely appreciated. Hadrian On 02/24/2015 02:18 PM, Kevin Burton wrote: Ah. OK… I assume

Re: Specifying prefetchSize using STOMP Protocol

2015-02-24 Thread PerryZirmed
Okay I just found the answer to my problem. Instead of consumer.prefectchSize:1 you must use activemq.prefetchSize:1 . Now that I've got that working it now brings up another issue for which I'll start another thread. Thanks. Perry -- View this message in context: http://activemq.2283324.n4.

Specifying prefetchSize using STOMP Protocol

2015-02-24 Thread PerryZirmed
I have been unsuccessful trying to set prefetchSize to 1 using the STOMP protocol. Here is an example SUBSCRIBE frame... `SUBSCRIBE id:0 destination:CLM.PARSE/12345 ack:client-individual consumer.prefetchSize:1 I still get all the messages on the queue. What am I doing wrong? Thanks. -- Vie

Re: A proposal to rewrite purgeInactiveDestinations locking to prevent queue GC lockups.

2015-02-24 Thread Kevin Burton
Ah. OK… I assume continuous integration isn’t a goal. I’m upset if my testing takes more than 20 minutes :-P I bet that this would be taken down to an hour if they were parallelized. But of course someone needs to take the time to get that done. I might be allocating some of our internal dev re

Re: A proposal to rewrite purgeInactiveDestinations locking to prevent queue GC lockups.

2015-02-24 Thread Timothy Bish
On 02/24/2015 01:22 PM, Kevin Burton wrote: oh geez… seriously though. can you give me an estimate? Assuming 30 seconds each I’m assuming about 11 hours. That's probably not to far off, usually just let them run over night for the all profile. http://activemq.apache.org/junit-reports.ht

Re: A proposal to rewrite purgeInactiveDestinations locking to prevent queue GC lockups.

2015-02-24 Thread Kevin Burton
oh geez… seriously though. can you give me an estimate? Assuming 30 seconds each I’m assuming about 11 hours. http://activemq.apache.org/junit-reports.html https://hudson.apache.org/hudson/job/ActiveMQ/ Hudson is down for ActiveMQ. Also, is there a disk space requirement for the tests? I have

Re: A proposal to rewrite purgeInactiveDestinations locking to prevent queue GC lockups.

2015-02-24 Thread Timothy Bish
On 02/24/2015 01:01 PM, Kevin Burton wrote: How long do the tests usually take? An eternity + 1hr I’m looking at 45 minutes right now before I gave up… I think part of it was that the box I was testing on was virtualized and didn’t have enough resources. I tried to parallelize the tests (-T

Re: A proposal to rewrite purgeInactiveDestinations locking to prevent queue GC lockups.

2015-02-24 Thread Kevin Burton
How long do the tests usually take? I’m looking at 45 minutes right now before I gave up… I think part of it was that the box I was testing on was virtualized and didn’t have enough resources. I tried to parallelize the tests (-T 8 with maven) but I got other errors so I assume the ports are singl

Re: kahadb/lock is locked on FreeBSD 9.3

2015-02-24 Thread Tim Bain
Just to check the basics: does the user ActiveMQ is running has have write permission to that directory and file? On Tue, Feb 24, 2015 at 5:40 AM, stp77 wrote: > Hello, > > I've searched around and couldn't find anything relating to my problem. > I'm > trying to install and run ActiveMQ 5.10.0 o

kahadb/lock is locked on FreeBSD 9.3

2015-02-24 Thread stp77
Hello, I've searched around and couldn't find anything relating to my problem. I'm trying to install and run ActiveMQ 5.10.0 on FreeBSD 9.3 with JDK 1.7 but it will not start. When I try and start ActiveMQ via bin/activemq console, everything seems to work until it gets to the database part. Th

Re: A proposal to rewrite purgeInactiveDestinations locking to prevent queue GC lockups.

2015-02-24 Thread Gary Tully
if there are any test failures - try to run them individually -Dtest=a,b etc. There may be an issue with a full test run, but all of the tests that are enabled should work. I know there are some issues with jdbc tests that hang or fail due to previous runs no cleaning up, but that should be the mos

Re: Consumer hanging after a producer fails for being inactive

2015-02-24 Thread Tim Bain
5.11.0 had a couple fixes for bugs related to duplicate messages being delivered after failovers; have you tested with 5.11.1 to see if those fixes address what you're seeing? On Jan 16, 2015 8:47 AM, "errobin" wrote: > artnaseef wrote > > Hmm, check the producer connections to the broker after t

Re: Rebalance clients not working in 5.9.0

2015-02-24 Thread Tim Bain
I'd recommend attaching a debugger and stepping through the rebalancing code. (I think FailoverTransport is where you'd want your breakpoint, but that's from memory so you may need to search around for the right place.) That should make it pretty clear what's happening and why... On Jan 23, 2015 1

Re: ActiveMQ embedded broker 100% cpu usage

2015-02-24 Thread Tim Bain
Sorry for taking so long to respond to this. Have you seen if you can reproduce this in 5.11.1? A recent email by Gary (in the past week) described two bugs that caused duplicate messages to be delivered, both of which were fixed in 5.11.0, so I'd test whether getting those fixes solves your prob

Re: Message groups pattern - "late" consumers

2015-02-24 Thread Tim Bain
As far as I know there's no built-in way to rebalance JMSMessageGroups across consumers, but i think that if you periodically close the message group (every ten minutes?), when the next message comes in for that group it should be eligible to be consumed by any consumer. But since I've never used

Re: Message order when use PooledConnectionFactory

2015-02-24 Thread Tim Bain
If you absolutely have to have messages get sent in a well-defined order, you'd use a single thread instead of many to do your sends, or you'd implement your own synchronization around anywhere your threads called send(). On Feb 2, 2015 12:03 PM, "bencaogm" wrote: > Hello! > > I use spring's JmsT

Re: Consumer queues of virtual topic and the web console

2015-02-24 Thread Tim Bain
I see that Tim closed your JIRA as Not A Problem, but didn't explain why. In case you weren't sure why this is expected behavior, here's an explanation: Messages get read from the broker's persistent store via a cursor (see http://activemq.apache.org/message-cursors.html), which is assumed to alwa

RE: Adding mime type to different type of messages

2015-02-24 Thread Tim Bain
If there isn't a built-in context-type header (you'll have to research that; I don't know either way), you can always set your own custom header by calling setStringProperty()/setDoubleProperty()/etc. (That's for Java; I don't use NMS, but a quick Google seems to indicate that there's a Properties

RE: Adding mime type to different type of messages

2015-02-24 Thread mahendran m
No , i need didn't use stop . In java i am using JMS Message API and in c# i am using NMS Message API . How can i achieve now ? > Subject: Re: Adding mime type to different type of messages > From: she...@gmail.com > Date: Tue, 24 Feb 2015 12:58:25 +0200 > To: users@activemq.apache.org > > If usi

Re: Adding mime type to different type of messages

2015-02-24 Thread Shedis
If using stomp have a look at v1.2 spec for Header content-type section. Sent from my Mobile Device! > On Feb 24, 2015, at 12:48, mahendran m wrote: > > I am sending different type of message like xml , JSON, and text using JMS > Text message. In the consumer side i need to differentiate the

Adding mime type to different type of messages

2015-02-24 Thread mahendran m
I am sending different type of message like xml , JSON, and text using JMS Text message. In the consumer side i need to differentiate the incoming message as Xml or Json or Text message , how can i achieve this ? .Is there any in built option available to set and get the MIME type like we are

Re: ActiveMQ 5.10.0 queue slowed down, restart helped

2015-02-24 Thread mo
Hi Abhi, I can't see any similarities to my problem. I think we're having very different issues. best regards, Mark On 02/24/2015 10:45 AM, xabhi [via ActiveMQ] wrote: > Hi Tim, > The reason I think it might be related (though I use KahaDB for > persistence) is because this issue affected speci

Re: ActiveMQ 5.10.0 queue slowed down, restart helped

2015-02-24 Thread xabhi
Hi Tim, The reason I think it might be related (though I use KahaDB for persistence) is because this issue affected specifically the persistent messages in my case, the issue happens every one week or two. Restarting helped in consumption of messages. In my case the messages consumption was delayed