Re: Storing message off heap, message compression, and storing the whole message as headers.

2015-04-26 Thread Tim Bain
I didn't follow your second paragraph. The goal with the Chronicle code should be to put the message back in memory after the Chronicle read as it was before the Chronicle write, right? So if the message body (only) was compressed (using the compression algorithm used for ActiveMQ messages, which

Re: Unix init script buggy

2015-04-26 Thread Marc Schöchlin
Hi, it seems that debian is not using the init script provided by the activemq project. I downloaded and extracted the current debian script of the activemq package from https://packages.debian.org/jessie/all/activemq/download (see attached file) In 2009 the init script of the activemq distrib

Re: Storing message off heap, message compression, and storing the whole message as headers.

2015-04-26 Thread Kevin Burton
> > > I don't think it's the network stack where that code works; I'm pretty sure > the message itself does decompression when the body is accessed via the > getter. But when you read the message body to serialize it to Chronicle, > you're likely to invoke that decompression code and end up undoin

Re: Network of Brokers recommendations

2015-04-26 Thread Tim Bain
Your understanding of this is good and you've got the right concepts here. The only two reasons I can think of that you shouldn't use a mesh (which I think is the same as a complete graph, though you drew a distinction between the two in your email so maybe there's a difference I'm not understandin

Re: Network of brokers with multiple worldwide data centers

2015-04-26 Thread Tim Bain
You probably already figured this out, but that setting should be on any machines at either end of a connection across a high-latency network link. So definitely your brokers, but also any hosts of consumers that connect to a broker across a high-latency link. This setting is especially important

Re: Faster detection of failure on network connections in "cable pull" scenario

2015-04-26 Thread Tim Bain
I would have thought that there would be keepalives sent in both directions on any connection irrespective of whether it's used for sending or receiving message, and that the lack of receipt of them on that connection would have declared it dead. If the former is true, then there's a bug in the de

Re: ActiveMQ (using in Camel) In/OUT endpoint creates additional consumers on response queue which are more than maxConcurrentConsumers

2015-04-26 Thread Tim Bain
Your use of an exclusive reply queue with more than 1 producer is broken. The point of an exclusive reply queue is that your publisher knows it's the only one publishing messages for which the replies will go on that reply queue, because all other publishers will use different reply queues for thei

Re: MDB stops consuming messages

2015-04-26 Thread Tim Bain
Oh, I forgot: was there any indication of Producer Flow Control kicking in on the broker prior to when the consumer stopped processing messages? On Sun, Apr 26, 2015 at 9:06 AM, Tim Bain wrote: > Did you ever solve this issue? > > If not, can you please clarify a couple things in your descriptio

Re: MDB stops consuming messages

2015-04-26 Thread Tim Bain
Did you ever solve this issue? If not, can you please clarify a couple things in your description? 1. Did you confirm (via a thread dump) that the MDB wasn't actually hung somewhere in your consumer code? Clearly the broker believed it had dispatched a prefetch buffer worth of messages

Re: ActiveMQ 5.10.0 queue slowed down, restart helped

2015-04-26 Thread Tim Bain
Mo, Sorry for the long delay in getting back to you; maybe you've already figured out your problem, but if not hopefully this will help. My understanding of how RDBMSes use indices is based on Oracle, so take this with a grain of salt since it might not apply to PostgreSQL. As I understand it, m

Re: Disable flow control on certain consumers?

2015-04-26 Thread Tim Bain
You may have figured this out in the past 3 weeks since you sent your first note, but the answer to your question is that no, it's not currently possible to enable PFC selectively, though there are a few tweaks you can make individually. PFC doesn't apply to consumers, so there is nothing you can

Re: Brokerservice stops on DB failure

2015-04-26 Thread gijsbert802
Replying to my own post. I found that 5.11 has a LeaseLockerIOExceptionHandler that seems to be designed to fix this problem. The use of lease-database-locker on the persistance adapter and the LeaseLockerIOExceptionHandler on the brokerService fixed the problem. -- View this message in context