pendingLock in PrefetchSubscription

There's the per-durable-subscription lock called "pendingLock" inside the PrefetchSubscription and PrefetchSubscription#dispatchPending method grabs this mutex for message dispatching. In the ActiveMQ 5.7 that we use, there are 3 requests calling this #dispatchPending as follows: PrefetchSubscrip

How to configure channel/selector thread pools for NIOTransport?

Hi, Using activemq 5.6.0, and wonder how I can configure the custom thread pools for channel workers. For example, I'd like to assign only 100 threads for channel event processing and with 5 selector threads. How can I configure these? Thanks, Jake -- View this message in context: http://ac

Re: cursor memory usage/limit vs memory usage/limit

Let me summarize my observations so far (and I think all of these are bugs in activemq-core-5.7.0): 1. Improper PFC kicking-in to persistent topic message publishers When a durable topic subscriber(s) is (are) not consuming, *persistent* message publishing is blocked (PFC) by exceeding topic's *pe

Re: cursor memory usage/limit vs memory usage/limit

at runtime is the 3rd one... Christian, could you possibly confirm if this is a bug or 5.7.0? Jake Choi wrote > I think I got it. With activemq-core-5.7.0, there's a clear difference > between doing and not-doing the following: > > policyEntry.setPendingDurableSub

Re: cursor memory usage/limit vs memory usage/limit

I think I got it. With activemq-core-5.7.0, there's a clear difference between doing and non-doing the following: policyEntry.setPendingDurableSubscriberPolicy(new StorePendingDurableSubscriberMessageStoragePolicy()); One resulting difference was that, StoreDurableSubscriberCursor#topics member

Re: cursor memory usage/limit vs memory usage/limit

And, this is the pom.xml I use... pom.xml -- View this message in context: http://activemq.2283324.n4.nabble.com/cursor-memory-usage-limit-vs-memory-usage-limit-tp4669679p4670033.html Sent from the ActiveMQ - User mailing list arch

Re: cursor memory usage/limit vs memory usage/limit

Quite strange that you didn't see any difference. BTW, I'm using 5.7.0, not 5.8.0. I see you're using 5.8.0 at https://github.com/christian-posta/activemq-durable-sub-pfc-tests/tree/jake-choi-tests ceposta wrote > Just tried that on my side and didn't make a difference

Re: cursor memory usage/limit vs memory usage/limit

I just got a pretty interesting observation: I just tried my own tweaked PendingDurableSubscriberPolicy (as I learned from the other thread, see below) to the test code I've been using: http://activemq.2283324.n4.nabble.com/How-to-configure-this-combination-of-queue-cursors-tt4670003.html#a467002

Re: How to configure this combination of queue cursors?

ursor = (StoreDurableSubscriberCursor) super .getSubscriberPendingMessageCursor(broker, clientId, name, maxBatchSize, sub); broker.getBrokerService().setPersistent(persistent); return cursor; } }); Jake Choi wrote > Now, I want to do the same

Re: How to configure this combination of queue cursors?

Now, I want to do the same for the durable topic subscription but looks not possible at this time, unlike the queue case: PolicyEntry policyEntry = new PolicyEntry(); policyEntry.setPendingDurableSubscriberPolicy(new StorePendingDurableSubscriberMessageStoragePolicy() {

Re: How to configure this combination of queue cursors?

Cool, it works! Thanks. --Jake -- View this message in context: http://activemq.2283324.n4.nabble.com/How-to-configure-this-combination-of-queue-cursors-tp4670003p4670022.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: How to configure this combination of queue cursors?

persistent part is QueueStorePrefetch > > > On Thu, Aug 1, 2013 at 9:59 AM, Jake Choi < > jw@ > > wrote: > >> ActiveMQ 5.7 (embedded broker only with activemq-core-5.7.0.jar) >> --- >> >> I couldn't seem find a way to configure the following combina

How to configure this combination of queue cursors?

ActiveMQ 5.7 (embedded broker only with activemq-core-5.7.0.jar) --- I couldn't seem find a way to configure the following combination of pending message cursors for a certain queue: queue cursor non-persistent cursor => VMPendingMessageCursor persistent cursor => QueueStorePrefetch >F

Re: cursor memory usage/limit vs memory usage/limit

@Christian: Sorry for bugging you bug wonder if you've gotten a chance to test the queue case as well, as I suggested. Or please shed the light once more if I'm still missing or misunderstanding something. Regards, Jake Jake Choi wrote > Thanks for your test. But I still don'

Re: ActiveMQ stops sending messages to Queue Consumer in case of consumer not acknowledging messages

Swapnil wrote > Active MQ stops sending further messages to sole consumer after certain > number of messages. Is this "certain number of messages" equal to persistent adapter's MAX_PAGE_SIZE (200)? -- View this message in context: http://activemq.2283324.n4.nabble.com/ActiveMQ-stops-sending-me

Re: cursor memory usage/limit vs memory usage/limit

eventually you'll hit PFC. > > Does that make sense? > > > On Mon, Jul 29, 2013 at 9:16 AM, Jake Choi < > jw@ > > wrote: > >> I'm testing only durable subscribers (as non-durable subscribers are >> working >> as expected as all of their mes

Re: cursor memory usage/limit vs memory usage/limit

gt; Give me one more piece of information. > > What is the prefetch settings you're using for your topics (durable and > non-durable subscribers), and how many durable subscribers are connected? > > > On Sun, Jul 28, 2013 at 8:40 PM, Jake Choi < > jw@ > > wrote: >

Re: cursor memory usage/limit vs memory usage/limit

Thanks a lot Christian for the well-explained documentation and this explains why I'm seeing the trouble with topic durable subscriptions regarding the per-destination memory usage & limit. First, let me quote some from your writing: "Main Broker Memory, Destination Memory, Subscription Memory .

cursor memory usage/limit vs memory usage/limit

Hi, Using activemq-core-5.7.0 (embedded broker), I noticed that there is the separate memory usage/limit called "cursor memory usage/limit" which the per-destination memory limit (that I set via per-destination policy) doesn't account for, but shared between all queues. For example, from the JMX

Re: persistent message missing to a durable subscriber when it reconnects(restarts)

I filed a JIRA for this issue. https://issues.apache.org/jira/browse/AMQ-4413 It has a simple Test.java attached with that anyone can easily reproduce the problem. Thanks, Jake -- View this message in context: http://activemq.2283324.n4.nabble.com/persistent-message-missing-to-a-durable-subsc