Hi,
I am using replicated leveldb for the persistent storage.
In my setup: zookeeper server is running and and using kerberos
authentication for all the clients connecting to the zookeeper server. I
don't know how ActiveMQ can pass kerberos credential to the zk server.
Does ActiveMQ allows
Please respond...
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Acknowledgements-and-transacted-sessions-tp4652740p4675021.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
I have a test case where I am using CLIENT_ACK on consumer side and also
using session.recovery()
In this case, message redelivery is expected, right ? (according to
http://activemq.apache.org/message-redelivery-and-dlq-handling.html)
and what if my consumer throws exception and continuous to
Hi,
I have a use case where I want redelivery of messages in case of exception
thrown by consumer. So for that I searched and found out to use transactions
because they guarantee redelivery.
I want to commit the session after receiving bunch of messages, but I am not
able to achieve this
Hi,
I am confused between DUPS_OK_ACKNOWLEDGE and CLIENT_ACKNOWLEDGEMENT.
I am not able to understand what is the meaning of *lazily acknowledging the
delivery of message* in case of DUPS_OK_ACKNOWLEDGE.
where does acknowledge happens in DUPS_OK_ACKNOWLEDGE ?
Thanks,
John
--
View this
Can some one respond here...
This is a basic requirement and I cannot find any ActiveMQ documentation for
this.
Let me know if there is a way to achieve above requirement ?
--
View this message in context:
As you have specified Yes, auto redelivery and dlq handling are the key
differences between
the batch ack in a session.commit and an application initiated client
ack. (message.acknowledge)
I am able to under dlq handling prospective ? I got that redelivery can only
be achieved by using
I am beginner in ActiveMQ, I want to use transactions within spring file, But
as I saw in org.springframework.jms.core.JmsTemplate
It commit transaction after each message is sent. I want to commit after a
batch of messages. How should I configure this ?
--
View this message in context:
Hey,
According to my understanding when a message is send, producer sets
expiration time with that message, and after that time if message is not
delivered broker expires that message.
But when producer don't specify any timetolive for a message it stays
forever in the broker.
So I want to expire
I am little bir confused here: as you posted Twice the prefetch limit ==
slow consumer
But i have seen in the source code of activemq
(activemq-parent-5.8.0/activemq-client/src/main/java/org/apache/activemq/ActiveMQPrefetchPolicy.java)
That prefetch limit default value for
QUEUE is 1000
DURABLE
Hi if my last post is not clear,
I just want to ask:
As you have specified Twice the prefetch limit == slow consumer .
So a message will be discarded and a consumer will be declared as slow,
after:
a) no of msgs ((prefetchlimit * 2) + constantPendingMessageLimit
OR
Thanks for the reply, In addition to the above context, Can you please tell
me when broker is decide that the consumer is slow ? There must have been
some limit, is it that as soon as as broker realize that pre-fetch limit for
consumer is exceeded, it report that consumer as slow ?
Another
waiting for someone to reply...
One more thing.
Other than slow consumer handling, is there any case when a message is
discarded ? After discarding a message, where does it go, is it deleted
forever or send to some disk ?
--
View this message in context:
Hi,
I am using ActiveMQ-5.8.0. ActiveMQ internally takes care of handling the
slow consumers. But i have never seen any slow consumer in my broker.
I am trying to create a slow consumer but not successful yet --
I have a test application(ping-pong) in which requester sends a message and
waits
Hi,
I am also trying to use http transport, and I also like to know about http
transport more, I have searched on internet but didn't get much, If someone
from ActiveMQ dev team will help me.
In addition to above questions i want to ask:
-- Can ActiveMQ http transport be used for java web
take a look here:
https://github.com/chirino/jms-benchmark
On Thu, Sep 26, 2013 at 3:24 AM, johnbing [hidden
email]http://user/SendEmail.jtp?type=nodenode=4671852i=0
wrote:
Hey,
I have searched but not able to find any results or any graphs for
ActiveMQ
performance. I mean do we
Hey,
Currently I am not using camel with my broker.
After your last post I read about camel, but got stuck with some questions.
-- Is camel uses same PID as of ActiveMQ broker ? I want to log all stats
into the same ActiveMQ log file.
-- I am not able to understand how camel can be used to
Hey,
I have searched but not able to find any results or any graphs for ActiveMQ
performance. I mean do we have any numbers for ActiveMQ performance (
throughput, memory uses , threads etc.)
Most of the other frameworks always share performance analysis and graphs.
Thanks,
John
--
View this
Thanks Christian for the links. However currently I am thinking to write my
own broker plugging using StatisticsBroker and instead of sending the stats,
I will dump those stats into the log file.
So is this a correct way to do this ? Any suggestions from your side.
Thanks,
John
--
View this
Hi,
Please find attached configuration file. NIO_broker_configuration.txt
http://activemq.2283324.n4.nabble.com/file/n4671813/NIO_broker_configuration.txt
My launcher file contains :
max_heap_size = 2700M
max_perm_size = 128M
broker
name = mqbroker
activemq_jar
During this stack trace 20 clients were there, but I sent you snapshot of
small portion of the stack trace, if you want I can send the whole stack
trace for 20 clients. But as I specified NIO threads are continuously
increasing with number of clients, So is there a threshold value, or some
Hi Ceposta,
When I connect my clients using NIO transport I can see NIO worker threads
in my logs.
Like:
40 5 3 3 0 0 ActiveMQ
InactivityMonitor WriteCheckTimer
41 5 25 25 10 10 ActiveMQ
Hi ceposta,
I am sorry for this John and Anuj confusion. I was copying and pasting
anuj's reply in this thread to get the context and forgot to remove the
thanks part. I am not Anuj, don't even know who is the guy.
Regarding NIO I am attaching my broker configuration file and thread logs
for you
Yes I have also tested it with 20 producers consumers. But still not seeing
any reduction in the number of threads. I have tested NIO with STOMP as well
as JMS producers.
USING(Language) No. of threads before running producer No. of
threads after running producers(~20)
STOMP (PYTHON
Hi,
I am using 5.8.0 version of ActiveMQ. I am trying to use NIO to improve
performance and scalability of my ActiveMQ broker but it is not working
well. I was expecting that it should reduce number of threads but I have not
observed any changes in number of threads. It is even reducing the
25 matches
Mail list logo
