Re: Facing "Failed to remove inactive durable subscriber"

Did anyone get a chance to look at this ? -- View this message in context: http://activemq.2283324.n4.nabble.com/Facing-Failed-to-remove-inactive-durable-subscriber-tp4690820p4690909.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: org.apache.activemq.broker.region.Queue.doBrowse never returns

I have encountered this kind of infinite loop of doBrowse:toPageIn: 0, Inflight: 263, pagedInMessages.size 263, pagedInPendingDispatch.size 0, enqueueCount: 1700826, dequeueCount: 1700556, memUsage:514431toPageIn: 0, Inflight: 263, pagedInMessages.size 263, pagedInPendingDispatch.size 0, enqueueCou

Re: NoSuchMethod exception running ActiveMQ 5.10.0

Sounds to me like a conflicting (duplicate) or missing server-api v2.5+ jar file The recommendations in the accepted answer below are reasonable, particularly #3 which is about jar duplicates activemq has a version 2.5 already, so if you installation has one the classloader will likely complai

Re: NoSuchMethod exception running ActiveMQ 5.10.0

Hmm, OpenJDK -- isn't that a kind of "pre-release" of the next gen of java? Can you try with a standard oracle java distribution? -- View this message in context: http://activemq.2283324.n4.nabble.com/NoSuchMethod-exception-running-ActiveMQ-5-10-0-tp4690810p4690904.html Sent from the ActiveMQ

Re: NoSuchMethod exception running ActiveMQ 5.10.0

Can you provide the precise steps to start the broker? I have started 5.10.0 and 5.10.1 brokers without problem. Also, is this with Windows, Linux, Mac, or another environment? -- View this message in context: http://activemq.2283324.n4.nabble.com/NoSuchMethod-exception-running-ActiveMQ-5-10-

Re: Cannot concurrently consume from embedded broker

Ah, Tim got there before me - apologies for the extra response. -- View this message in context: http://activemq.2283324.n4.nabble.com/Cannot-concurrently-consume-from-embedded-broker-tp4690872p4690902.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Cannot concurrently consume from embedded broker

Did you set prefetch to 1 for all of the consumers? If not, perhaps one consumer is getting more than its share of messages, leaving the barrier logic to keep waiting. -- View this message in context: http://activemq.2283324.n4.nabble.com/Cannot-concurrently-consume-from-embedded-broker-tp4690

freeing up prefetch, if that is what this is (which I doubt)

Greetings, I'm a new sub and searched far a wide (including archives) for this but am not hitting... Scenario is pretty simple setup: all localhost - consumer (nodejs) and broker (standalone 5.8.0) A separate producer loaded up about 6000 message, all around 250K each into a persistent queue Day

non-persistence of messages with leveldb replication…

Given that: 1. ActiveMQ shouldn’t be your main database. You should have a secondary system to store message and send them to AMQ 2. You may have repair code to re-push messages into AMQ 3. you’re running with LevelDB replication… .. then what’s the purpose of persistence? It really only han

Re: Cannot concurrently consume from embedded broker

Thank you! On Mon Feb 02 2015 at 9:06:40 PM Timothy Bish wrote: > > On 02/02/2015 05:59 PM, Thiago Kronig wrote: > > Timothy, last question, I promise. > > > > Prefetch = 1 means that at most 2 messages will be dispatched to a > > consumer, the in-flight message and the "prefetched" one? I ask y

Re: Cannot concurrently consume from embedded broker

On 02/02/2015 05:59 PM, Thiago Kronig wrote: Timothy, last question, I promise. Prefetch = 1 means that at most 2 messages will be dispatched to a consumer, the in-flight message and the "prefetched" one? I ask you because setting to one resulted in four consumers with dispatched counter = 1, t

Re: Cannot concurrently consume from embedded broker

Timothy, last question, I promise. Prefetch = 1 means that at most 2 messages will be dispatched to a consumer, the in-flight message and the "prefetched" one? I ask you because setting to one resulted in four consumers with dispatched counter = 1, three consumers with dispatched counter = 2, and

Re: Sending directly to a queue doesn’t raise ActiveMQ.Advisory.Producer.Queue.>

> This is by design as the second case creates an anonymous producer that > can send to any destination that it has permission to write to. Sending > that advisory every time an anonymous producer sent a message to a given > destination would create a flood of advisories which would not really be

Re: Sending directly to a queue doesn’t raise ActiveMQ.Advisory.Producer.Queue.>

On 02/02/2015 05:24 PM, Kevin Burton wrote: I’m unsure if this is a bug or another ActiveMQ idiosyncrasy… If I send to a producer with: MessageProducer producer = session.createProducer( dest ); producer.send( message ); That works and I receive the advisory. However, if sen

Re: Cannot concurrently consume from embedded broker

On 02/02/2015 05:27 PM, Thiago Kronig wrote: First of all, thank you Timothy and Tim for your time. In fact, setting jms.prefetchPolicy.all=0 solves the problem, because "*Specifying a prefetch limit of zero means the consumer will poll for more messages, one at a time"*. Please, validate my un

Re: Cannot concurrently consume from embedded broker

First of all, thank you Timothy and Tim for your time. In fact, setting jms.prefetchPolicy.all=0 solves the problem, because "*Specifying a prefetch limit of zero means the consumer will poll for more messages, one at a time"*. Please, validate my understanding: the default prefetch size is 1000

Sending directly to a queue doesn’t raise ActiveMQ.Advisory.Producer.Queue.>

I’m unsure if this is a bug or another ActiveMQ idiosyncrasy… If I send to a producer with: MessageProducer producer = session.createProducer( dest ); producer.send( message ); That works and I receive the advisory. However, if send like this: MessageProducer producer =

Re: ActiveMQ should GC inactive when producers is 0 , even if consumers is > 0

Agreed … I’m usually pretty good at these though :) are there any obvious ActiveMQ ones you’re thinking of or is this just a general warning? On Mon, Feb 2, 2015 at 1:57 PM, artnaseef wrote: > Check carefully. I suspect you'll find race conditions still exist there. > > > > -- > View this mess

Re: ActiveMQ should GC inactive when producers is 0 , even if consumers is > 0

Check carefully. I suspect you'll find race conditions still exist there. -- View this message in context: http://activemq.2283324.n4.nabble.com/ActiveMQ-should-GC-inactive-when-producers-is-0-even-if-consumers-is-0-tp4690776p4690885.html Sent from the ActiveMQ - User mailing list archive at N

Re: Cannot concurrently consume from embedded broker

On 02/02/2015 04:47 PM, Thiago Kronig wrote: I just tried the same approach using JMS consumers. No success. Source at: https://github.com/thiagokronig/activemq-camel-test/blob/master/src/main/java/com/thiagokronig/activemqcameltest/ActiveMQJMSParallelTest.java On Mon Feb 02 2015 at 7:30:00 PM T

Re: Cannot concurrently consume from embedded broker

I just tried the same approach using JMS consumers. No success. Source at: https://github.com/thiagokronig/activemq-camel-test/blob/master/src/main/java/com/thiagokronig/activemqcameltest/ActiveMQJMSParallelTest.java On Mon Feb 02 2015 at 7:30:00 PM Thiago Kronig wrote: > Tim, you're right: 1 se

Re: Cannot concurrently consume from embedded broker

Tim, you're right: 1 second is to small timeout to begin with. But even if I set to 10 minutes, I get the same discouraging results: 3 consumers, sometimes 8 consumers processing different messages in parallel. Sometimes 10 consumers, as my test requires, consumes all the messages in parallel and e

Re: Cannot concurrently consume from embedded broker

Are you sure that your assumption that a Camel context can be initialized enough to consume messages in all 10 threads within 1 second is a valid one? In my experience, Camel contexts aren't quick to start, and it wouldn't surprise me if there was some asynchronous startup logic that took place in

Re: Cannot concurrently consume from embedded broker

Tim, other thing: I tried to Thread.sleep(5000); between the producer commit and the consumer initialization, but had no success. On Mon Feb 02 2015 at 6:45:19 PM Thiago Kronig wrote: > Tim, in may scenario I want to consume N messages in N consumers, one for > each. My consumers wait on a barri

Re: Cannot concurrently consume from embedded broker

Tim, in may scenario I want to consume N messages in N consumers, one for each. My consumers wait on a barrier only to show the parallelism, and to show that none of them processed two messages or more. Maybe my Camel configuration is wrong, or there is something wrong with the broker configuration

Re: ActiveMQ should GC inactive when producers is 0 , even if consumers is > 0

FYI.. I closed this bug as WONTFIX as I think this is the best strategy post feedback. Thanks guys. On Mon, Feb 2, 2015 at 11:52 AM, Kevin Burton wrote: > the problem with this strategy is that queues can come and go.. it’s a > scheduler system for a web crawler. so if a URL request comes in fo

Why are NoConsumer topic advisories only for non-persistent messages??

So this would TOTALLY solve the race condition I talked about in the other thread. I could listen for ActiveMQ.Advisory.NoConsumer.Queue and when a queue lacks a consumer, I can just fire it up. The problem is it won’t work because I’m using a persistent store. Is there a reason they don’t wor

Re: Cannot concurrently consume from embedded broker

Why do your consumers all wait for the Nth message to be received before they return to process another? Why don't you use an AtomicInteger to subtract one each time, and succeed if you hit 0 and fail if you haven't hit 0 by the end of your timeout interval? Based on what you've shows us so far,

Cannot concurrently consume from embedded broker

Hi list. I'm trying to concurrently consume 10 messages sent to an embedded ActiveMQ broker over the VM transport. Sometimes my code works, sometimes it hangs at the n-th message, randomly. If I change to a JBossMQ, my Camel client works. Can someone help me in setting my ActiveMQ broker? Sourc

Re: ActiveMQ should GC inactive when producers is 0 , even if consumers is > 0

the problem with this strategy is that queues can come and go.. it’s a scheduler system for a web crawler. so if a URL request comes in for an IP we place it in that queue. And if, a month from now, we have to request another resources from that IP, we place it in a queue for that IP. MOST of the

Re: ActiveMQ should GC inactive when producers is 0 , even if consumers is > 0

It sounds like the advisory message you mentioned should let you work around the problem. But what it sounds like you really need is a way to know, for sure, that the producer is finished using a queue. If your producers write an EOF message when they're through, your consumer can then safely go

Message priority and message selector - Active MQ version 5.4

Here is my use case.. I have two producers sending messages to a queue and there are two consumers on this queue. Producer one sets a message header on the message e.g. MyName=one and priority 8. Producer two sets message header MyName=two and priority 6. The consumers use message selector My

Re: Error Code for Failover available in ActiveMQ?

The whole idea is that the activemq client handles the reconnect, use the failover URI with two tcp connections. On Mon, Feb 2, 2015 at 12:05 PM, arpita wrote: > We have a application which currently uses IBM MQ as messaging provider. For > the fail-over implementation, the application tries to

Re: ActiveMQ driver implictly shutting down mysql connection

The reason this was happening was because of inherent bug introduced with mysql 5.5 . Upgrading to version 5.6 solved the issue. The issue was introduced in version 5.2 of the mysql server. -- View this message in context: http://activemq.2283324.n4.nabble.com/ActiveMQ-driver-implictly-shutting

Re: Mysql 5.6 and activemq

upgrading the mysql connector java jar to 5.1.23 solved the problem. -- View this message in context: http://activemq.2283324.n4.nabble.com/Mysql-5-6-and-activemq-tp4690436p4690574.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

How to Enforce TLS 1.1 or 1.2

Hi everyone, I am currently using ActiveMQ 1.7 and according to Wireshark, the connection is using TLS 1 which is expected. I recently tried to enforce TLS 1.1 or 1.2 but was not able to. I added transport.sslProtocol=Tls11 to the URI attributes but nothing changed. Wireshark still tells me that

Spring AMQP ActiveMQ

I'm looking for some documentation and examples around Spring with ActiveMQ AMQP protocol. I see there are examples with Spring JMS, but I didn't see any with Spring AMQP with ActiveMQ. Thanks! -- View this message in context: http://activemq.2283324.n4.nabble.com/Spring-AMQP-ActiveMQ-tp4690

Error Code for Failover available in ActiveMQ?

We have a application which currently uses IBM MQ as messaging provider. For the fail-over implementation, the application tries to re-connect based on some error-codes thrown by the MQ provider. For the IBM MQ, the fail-over error codes registered in the application are like MQJMS2005,MQJMS2007,MQ

Re: Any issues with creating lots of short lived queues?

Yeah. I agree but it’s complicated :-P …there are a lot of requirements and it would take 2-10 pages to write them up I think. On Mon, Feb 2, 2015 at 5:49 AM, Tim Bain wrote: > The only problem with asking the small questions instead of laying out the > architectural issue is that this feels lik

Message order when use PooledConnectionFactory

Hello! I use spring's JmsTemplate to send queue messages (not pesisted) and use PooledConnectionFactory to hold 10 connections with Active MQ. If I call JmsTemplate.send method in multiple thread to the same destination, can the consumer get messages in the same order the message sned by JmsTempla

How retry is working in ActiveMQ - "Master/Slave" configuration with failover protocol

We have a application which is configured with the "Master/Slave" Active MQ failover protocol. But while testing the Failover scenarios sometime switch-over between Master and Slave is working fine but some time we faced following exception and our programs throw Exception. How can we track/sure th

What is your production experience with Activemq Apollo?

Hi Would appreciate feedback from Apollo users, especially those who have successfully migrated from Activemq old gen to Apollo. Would be comforting to hear of large-ish financial corporations using Apollo for "mission-critical" stuff. Mostly interested in comment surrounding non-functional attri

Re: RFE , print that LevelDB is doing a recovery...

Sorry. I answered the wrong question. The LevelDB recovery does seem to be a function of number of queues and number of outstanding messages. On Sun, Feb 1, 2015 at 2:44 PM, artnaseef wrote: > Are the recovery times related to the number of messages stored in LevelDB > at > startup? I've seen

Re: RFE , print that LevelDB is doing a recovery...

Yes. My fault! I just realized I transposed email threads by accident. I have two problems.. one is the queue GC on startup and the other is lack of any message when the broker is doing leveldb recovery. On Mon, Feb 2, 2015 at 6:00 AM, Tim Bain wrote: > That thread dump shows you in LevelDB

Re: ActiveMQ should GC inactive when producers is 0 , even if consumers is > 0

> ActiveMQ provides no means to guarantee that a producer will fail to > deliver > a message when there are no consumers interested in the message. It is > actually designed more for cases of consumers being away and returning at a > later time. > > Perhaps. But I think the advisory queue message

Re: ActiveMQ should GC inactive when producers is 0 , even if consumers is > 0

So, reading carefully, it sounds the solution has orders-of-operation concerns with messages that cannot be lost, consumers that go away, producers that must not produce when the consumers are missing, the application is using an asynchronous messaging solution (ActiveMQ), and AMQ is being used to

Re: ActiveMQ should GC inactive when producers is 0 , even if consumers is > 0

After reading this thread I think I might have a workaround for this problem. The main problem I have is stragglers. If I close a queue, and a moment later one messages is published, I’ll never be able to consume it. BUT… I could use this Advisory message: > ActiveMQ.Advisory.NoConsumer.Queue >

Re: ActiveMQ should GC inactive when producers is 0 , even if consumers is > 0

On Mon, Feb 2, 2015 at 5:39 AM, Tim Bain wrote: > Also, the most common (I think) broker configuration will auto-create a > destination if a client tries to use it and it doesn't exist. So if you > delete the destination while a consumer is still connected, won't the > broker just immediately re

Re: ActiveMQ should GC inactive when producers is 0 , even if consumers is > 0

On Sun, Feb 1, 2015 at 8:22 PM, artnaseef wrote: > Something has me confused here. If there is a consumer, why would messages > sit around unconsumed? > > If you want a queue to GC, you have to close any consumers on it. So lets say the queue has been idle , with no messages, for 60 seconds. a

Facing "Failed to remove inactive durable subscriber"

Hi, Using ActiveMQ 5.10 I am facing below error *sometimes* when broker tries to remove inactive durable subscriber because of long-time inactivity. And after this error, it stays forever in broker. /org.apache.activemq.broker.region.TopicRegion#doCleanup 102 ERROR] - Failed to remove inactive d

Re: ActiveMQ should GC inactive when producers is 0 , even if consumers is > 0

Kevin probably doesn't want a separate control channel given the volumes he's been talking about; that would be twice as many destinations to GC. Just send the "work is done" message via the real queue. But Tim's absolutely right about setting a message expiration time; either make 100% sure every

Re: RFE , print that LevelDB is doing a recovery...

That thread dump shows you in LevelDB doing message replay, not destination GC; are you sure destination GC is to blame for this particular issue? And do you know how many messages were in LevelDB at startup? Thanks. I’m unsure as we still have to use KahaDB for scheduled messages. So there are

Re: ActiveMQ should GC inactive when producers is 0 , even if consumers is > 0

On 02/02/2015 08:39 AM, Tim Bain wrote: Also, the most common (I think) broker configuration will auto-create a destination if a client tries to use it and it doesn't exist. So if you delete the destination while a consumer is still connected, won't the broker just immediately recreate it? If i

Re: Any issues with creating lots of short lived queues?

The only problem with asking the small questions instead of laying out the architectural issue is that this feels like an XY Problem ( http://xyproblem.info/), so us answering the Ys may miss the chance to find a better solution to the X. On Feb 1, 2015 9:44 PM, "artnaseef" wrote: > Yes. Destina

Re: ActiveMQ should GC inactive when producers is 0 , even if consumers is > 0

Also, the most common (I think) broker configuration will auto-create a destination if a client tries to use it and it doesn't exist. So if you delete the destination while a consumer is still connected, won't the broker just immediately recreate it? If implemented, would this enhancement actuall

Re: NoSuchMethod exception running ActiveMQ 5.10.0

This is not the final solution but it allows me to go on. I've removed "Server" bean in conf/jetty.xml: -- View this message in context: http://activemq.2283324.n4.nabble.com/NoSuchMethod-exception-running-ActiveMQ-5-10-0-tp4690810p4690814.html Sent from the ActiveMQ - User mailing lis

NoSuchMethod exception running ActiveMQ 5.10.0

Hi All!I'm trying to deploy ActiveMQ 5.10.0 (I tried 5.10.1 with same results), but getting following exception on start.Everything is untouched from the binary distribution archive. "java -version" is java version "1.7.0_03"OpenJDK Runtime Environment (IcedTea7 2.1.7) (7u3-2.1.7-1)OpenJDK 64-Bit S