Thanks artnaseef, for pointing me in the right direction.The issue was mainly
because it was running under JTA transaction, and hence the consumers were
not releasing the connection. So after around 50-100 polls, all the
connections were exhausted.
I was able to fix it by making
TransactionSuppor
Thanks for posting your findings.
That's an interesting fix given the fact that the JMS spec states that a JMS
connection created within a JTA transaction participates in that transaction
automatically (although I'm sure it's fine for a provider to allow a means
to pull it out of the transaction).
Are you hitting your catch block? Add logging before you re-throw to find
out.
Also, a thread dump could help determine if you're stuck in a blocking call
or bombing out early, though it won't tell you why you bombed out (that's
what the logging in the catch block is for).
What are the queue sta
So there are a few concerns with the code.
First off, to your question of consumption stopping - based on the fact that
the code uses ActiveMQResourceAdapter, I assume this is running in the
context of a JTA Transaction. If so, all operations are transacted, and the
client acknowledge mode is ign
I'm not sure what your use case is, so I can't say for sure whether
throwing away a potentially-large number of messages is a valid option for
you. But if it were me, I'd focus on figuring out why your broker can't
handle your required workload and on how you can adjust either the broker
or your u
Setting broker to fail producer in case its out of resources, instead of
making producer wait forever
<.
Your views on this?
Broker machine is very high config vm (56 G ARM out of which 70% for broker
and has 8 cores )
--
View this message in context:
http://activemq.22
It really sounds like you're simply overwhelming the broker with those
40,000 messages you're publishing. If the broker couldn't keep up with the
volume of messages you were sending (or worse, if you ran it into a limit
and the broker stopped accepting messages until something started consuming
th
Yes all the messages are getting published to the same broker.
Producer window size was introduced to avoid message loss, previously we
used to lose ~10-20% of messages as we use async send. Usually we get huge
number of messages in short time (message burst).
--
View this message in context:
Step #2 looks like your problem, based on that thread dump. Are you
publishing back to the same broker, or another one? Whichever one it is,
is it just overloaded trying to accept 4 messages all at once? Are
those messages actually getting to that broker, and at what rate?
Why is a produce
No, the broker logs are clear and I dont see any warnings in broker logs.
*I am worried as, even broker resources are within limit this waiting thread
never returns causing this consumer to die*.
My workflow is
Queue -> Camel route jms consumer (uses connectionfactory without
producer window s
Um, that looks like Producer Flow Control kicking in, which would result in
warnings in the broker's logs. Is that what you're seeing?
On Oct 14, 2015 11:47 AM, "dhananjay.patkar"
wrote:
> I was able to capture a thread dump on the jvm on which consumers are
> vanishing.
> The threads are blocke
I was able to capture a thread dump on the jvm on which consumers are
vanishing.
The threads are blocked on producer window, waitForSpace().
"Camel (CamelContext) thread #573 - JmsConsumer[RequestQueue]" daemon prio=6
tid=0x11ded000 nid=0x156c in Object.wait() [0x5b69d000]
java
So you're using ActiveMQ, Camel, and Spring, and the problem (whether it's
your error or a bug) could be in any of them. I've got to say, given that
this isn't clearly a problem with any one of those technologies, I'd post
this to StackOverflow and tag it with all three technologies and hope that
I am able to reproduce this issue by restarting the broker, when camel
consumers are sending those millions of messages on the queue.
I am planning to set recoveryInterval on the camel JmsConfiguration, please
post your views on this.
--
View this message in context:
http://activemq.2283324.n4
We are using ActiveMQ 5.10 broker with following configuration
JVM heap 48G out of which 70% allocated for memoryUsage
70G storage and 1G for temp
we are using Apache camel 2.10.2 route to consume messages from queue. After
receiving message, we create ~40k smaller messages/ received message and
To clarify, I mean that you should post the actual Camel routes you're
using.
On Oct 8, 2015 1:48 PM, "Tim Bain" wrote:
> If you're hoping for help from anyone other than the OP, you'll want to
> provide the same information about your clients that Art asked the OP for.
> On Oct 8, 2015 8:35 AM,
If you're hoping for help from anyone other than the OP, you'll want to
provide the same information about your clients that Art asked the OP for.
On Oct 8, 2015 8:35 AM, "dhananjay.patkar"
wrote:
> We are experiencing same issue, with activemq 5.10 broker and consumers are
> created through came
We are experiencing same issue, with activemq 5.10 broker and consumers are
created through camel routes.
Are you able to conclude on your problem, please share the if you have fixed
it.
Thanks,
Dhananjay
--
View this message in context:
http://activemq.2283324.n4.nabble.com/ActiveMQ-consumer
That does sound like a race condition based on the description provided. It
also sounds like you have almost solved it - if you can finish tracking it
down and provide a patch, that would be most welcome.
Good work!
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Active
I have opened JIRA AMQ-5313
Thanks
--
View this message in context:
http://activemq.2283324.n4.nabble.com/ActiveMq-consumer-intermittently-hanging-after-reconnect-tp4684226p4684258.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Please raise a jira issue to track this. we may need to track pull requests
or it could be some sort of race. In any event it is a bug.
On 7 Aug 2014 01:09, "wayn23" wrote:
> I have run into an intermittent problem with ActiveMQ V5.9.0. The
> intermittent
> was tracked down to being a connection
Hello ? Please respond !!
--
View this message in context:
http://activemq.2283324.n4.nabble.com/ActiveMQ-consumer-not-getting-removed-tp4678812p4679254.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Please respond !!
--
View this message in context:
http://activemq.2283324.n4.nabble.com/ActiveMQ-consumer-not-getting-removed-tp4678812p4679193.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Hey,
I saw some configurations in ActiveMQConnectionFactory and FailoverTransport
like "initialReconnectDelay" "backOffMultiplier" "maxReconnectAttempts"
"useExponentialBackOff". If we cannot stop client in above case than atleast
we can create delay after each reconnect.
I found that if a clien
that is a sort of firewall, dynamic white/black list, type feature and
we don't have anything like that atm.
maybe reverting to OS level firewall rules can keep that client away
once you know its ip.
This has come up before in the context of the abortslowconsumer
policy, where an aborted client wi
Please respond !!
--
View this message in context:
http://activemq.2283324.n4.nabble.com/ActiveMQ-consumer-not-getting-removed-tp4678812p4678829.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Typically the failover transport is used by applications which will make sure
clients reconnect once the broker restarts, and will survive across multiple
broker restarts.
Is the failover transport being used?
If you can post the connection factory configuration for the application,
that could he
Hi,
The consumer is created when the application is deployed. In my case, the
ActiveMQ went down due to DB connectivity issues and had to be restarted.
Once I restarted ActiveMQ, I observed that, out of 4 queues, 3 queues had
correct consumer count but one did not. I had to restart the application
Do you have any logs for the consumer? Without knowing the internals of the
solution, there are a lot of possibilities.
For example, does the consumer get created immediately at application
startup time, or after some event occurs?
But first, besides the consumer count reading as 0, are there an
You can embed a local broker in your "producer" (
http://activemq.apache.org/how-do-i-embed-a-broker-inside-a-connection.html)
and make a network connection to the remote broker (
http://activemq.apache.org/networks-of-brokers.html)
Regards
--
Dejan Bosanac - http://twitter.com/dejanb
--
On Wed, Dec 15, 2010 at 11:47 AM, Stanislaw Kogut wrote:
> On Wed, Dec 15, 2010 at 8:08 PM, Bruce Snyder
> wrote:
>>
>> On Wed, Dec 15, 2010 at 10:56 AM, Stanislaw Kogut
>> wrote:
>> > On Wed, Dec 15, 2010 at 7:37 PM, Bruce Snyder
>> > wrote:
>> >
>> >> On Wed, Dec 15, 2010 at 10:32 AM, Stanisla
On Wed, Dec 15, 2010 at 8:08 PM, Bruce Snyder wrote:
> On Wed, Dec 15, 2010 at 10:56 AM, Stanislaw Kogut
> wrote:
> > On Wed, Dec 15, 2010 at 7:37 PM, Bruce Snyder >wrote:
> >
> >> On Wed, Dec 15, 2010 at 10:32 AM, Stanislaw Kogut
> >> wrote:
> >> > I already tried every topic here, with no sig
On Wed, Dec 15, 2010 at 10:56 AM, Stanislaw Kogut wrote:
> On Wed, Dec 15, 2010 at 7:37 PM, Bruce Snyder wrote:
>
>> On Wed, Dec 15, 2010 at 10:32 AM, Stanislaw Kogut
>> wrote:
>> > I already tried every topic here, with no significant effect.
>> > I'm already using KahaDB for peristence (even pl
On Wed, Dec 15, 2010 at 7:37 PM, Bruce Snyder wrote:
> On Wed, Dec 15, 2010 at 10:32 AM, Stanislaw Kogut
> wrote:
> > I already tried every topic here, with no significant effect.
> > I'm already using KahaDB for peristence (even placing it's data to
> tmpfs).
> > I can't use async send/receive,
On Wed, Dec 15, 2010 at 10:32 AM, Stanislaw Kogut wrote:
> I already tried every topic here, with no significant effect.
> I'm already using KahaDB for peristence (even placing it's data to tmpfs).
> I can't use async send/receive, as I need reliable transport.
> I'm using transactions (this is a
I already tried every topic here, with no significant effect.
I'm already using KahaDB for peristence (even placing it's data to tmpfs).
I can't use async send/receive, as I need reliable transport.
I'm using transactions (this is a requirement).
What about multiple consumers? Should they use one
On Wed, Dec 15, 2010 at 7:41 AM, Stanislaw Kogut wrote:
> Hello.
>
> I'm currently evaluating ActiveMQ as a message broker for our service. We
> need scalable, transacted, low-latency message broker, but ActiveMQ shows
> not very good results to me.
>
> Config: ActiveMQ 5.4.2 with nio:// transport
Hi,
you can find some additional tips for performance tuning here:
http://activemq.apache.org/performance-tuning.html
and
http://fusesource.com/wiki/display/ProdInfo/FUSE%20Message%20Broker%20Performance%20Tuning%20Guide
Cheers
--
Dejan Bosanac
-
FuseSource - The experts in ope
Actually, I was wrong thinking that the Stomp events couldn't be catched in
ActiveMQ. I've written my conclusions at
http://stackoverflow.com/questions/1702755/activemq-consumer-producer-connection-listener/1721658#1721658.
Thanks again for your help.
--
View this message in context:
http://ol
The only workaround I can think of right now is to use the AMon framework and
develop a Monlet that listens for these events (addConnection, addProducer,
removeProducer, etc.) and then sends some sort of informational message that
it produces. The contents of the message are based on the info that
Thank you for the answer, Joe. The advisory messages seem to be what I want.
However, I would also need this to work with Stomp. As I saw here:
http://old.nabble.com/Consuming-Advisory-messages-from-ActiveMQ-using-stomp-td21977199.html
it seems impossible for me to really understand what the event
You may want to look at using advisory messages
http://activemq.apache.org/advisory-message.html
Or for more finer-grained control check out this free AMQ monitoring
framework.
http://www.ttmsolutions.com/Transactional_Software_Solutions/Active_Monitor_AMon.php
Joe
Boarder wrote:
>
> I can
42 matches
Mail list logo
