time a Slow Consumers draw from
queue (Throttling: 4msg/1s). Is it a good idea?
Sorry, but I'm new on this concept.
Thanks a lot again.
Best Regards
Michele
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Pooled-connection-factory-does-not-work-tp4710421p4710574.h
to add concurrentConsumers=10 as option in endpoint uri,
but always only one works.
I also tried with prefetchSize = 1 but with errors... I'm investigating.
Any suggestions?
Thanks in advance.
Michele
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Pooled-conne
y
connections, sessions, producers and consumers.
As you can see bt attached picture pooled-connection.png
<http://activemq.2283324.n4.nabble.com/file/n4710461/pooled-connection.png>
, why is there only one consumer that works on Queue?
I hope i was clear.
Thanks a lot again
Kind greetings
Mi
I hope to work on right way.
Thanks so much again
Kind Greetings
Michele
Michele
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Active-MQ-OutOfMemory-in-JbossFuse-6-2-context-tp4709960p4710458.html
Sent from the ActiveMQ - User
prefetch size with 0 to handle a slow consumer.
Any idea?
Thanks in advance
Best regards
Michele
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Pooled-connection-factory-does-not-work-tp4710421.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
8:org.apache.camel.camel-core:2.15.1.redhat-620133]
However, I'm working on both fronts in order to optimize Producer and
Consumer.
In this scenario, i prefer that the producer is fastest than the consumer in
order to don't overload the destination endpoint.
Thanks in advance.
Best
sages(Queue.java:2107)
at org.apache.activemq.broker.region.Queue.iterate(Queue.java:1583)
at
org.apache.activemq.thread.PooledTaskRunner.runTask(PooledTaskRunner.java:133)
How to configure Broker to handle the load?
Thanks in advance
Best Regards
Michele
--
View this message in co
${in.body}
But no message is logged.
Is there an error in my configuration?
Thanks in advance
Kind Greeting
Michele
a certain delay,
messages are moved to ActiveMQ.DLQ.
Is there a way to detect when message is moved in DLQ? Is possible to
retrieve a copy of message to send to Aggregator reporting that an error has
occurred related to original message?
Thanks in advance.
Kind Regards.
Michele
--
View this
Hi again,
here are the full stack traces.
1 - Broker
Loading message broker from: xbean:activemq.xml
INFO BrokerService - Using Persistence Adapter:
AMQPersistenceAdapter(/work/michele/apache-activemq-5.0.0/data/localhost)
INFO BrokerService - ActiveMQ 5.0.0
Hi Jamie,
thanks for your reply. Unfortunately the HeapDumpOnOutOfMemoryError
options works only when the OOME is due to heap space problems, not
when the system is unable to create new threads [1].
Michele
[1] http://java.sun.com/javase/6/webnotes/trouble/TSG-VM/html/
gdaog.html#gbzrr
Filip,
are you talking about the broker or the client? The settings below
are for the broker.
Michele
On 2 May 2008, at 00:20, Filip Hanik - Dev Lists wrote:
-Xms512m -Xmx1024m -Xmn500m
On 2 May 2008, at 00:20, Filip Hanik - Dev Lists wrote:
Michele Mazzucco wrote:
Filip,
if you mean on the client side, I have a thread pool configured to
create max 100 threads.
there could still be a thread leak in your application somewhere
No, there's no leak on my client app. I
Filip,
if you mean on the client side, I have a thread pool configured to
create max 100 threads.
about -Xmx, that's the maximum amount of memory. Why are you telling
me that by decreasing that value there would be more space for
threads?
Michele
On Thu, May 1, 2008 at 7:50 PM, Filip
ned up after
use), but their lifetime is very short (a few seconds, they are just
used to receive a response message).
A similar problem occurs on my test client too (maybe it's related to
the error on the broker), but not on the server.
Any help would be appreciated,
Michele
15 matches
Mail list logo
