ActiveMQ connecting to zookeeper servers using kerberos

2014-11-13 Thread johnbing
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 passi

Re: Acknowledgements and transacted sessions

2013-12-03 Thread johnbing
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.

Re: Acknowledgements and transacted sessions

2013-12-02 Thread johnbing
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 ru

Re: Acknowledgements and transacted sessions

2013-11-28 Thread johnbing
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 transa

Re: Transactions to receive batch messages using spring

2013-11-28 Thread johnbing
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: http://activemq.2283324.n4.nabble.com/Transactions-to-receive-batch-messages-using-sp

DUPS_OK_ACKNOWLEDGE vs CLIENT_ACK

2013-11-28 Thread johnbing
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 mes

Transactions to receive batch messages using spring

2013-11-28 Thread johnbing
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 function

Re: Batch message sending with JmsTransactionManager of Spring?

2013-11-25 Thread johnbing
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: http:

Expire Message by broker

2013-11-06 Thread johnbing
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 expir

Re: How to generate slow consumers.

2013-10-18 Thread johnbing
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 O

Re: How to generate slow consumers.

2013-10-18 Thread johnbing
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

Re: How to generate slow consumers.

2013-10-17 Thread johnbing
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: http://activemq.2283324.n4.nabble.com

Re: How to generate slow consumers.

2013-10-17 Thread johnbing
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 questi

How to generate slow consumers.

2013-10-10 Thread johnbing
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 til

Re: Use case of http transport connector

2013-10-08 Thread johnbing
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 applicat

Re: NIO transport performance for ActiveMQ

2013-09-27 Thread johnbing
> You can 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=node&node=4671852&i=0>> > wrote: > > > Hey, > > > &g

Re: Statistics Plugin for ActiveMQ broker

2013-09-26 Thread johnbing
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

Re: NIO transport performance for ActiveMQ

2013-09-26 Thread johnbing
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 me

Re: Statistics Plugin for ActiveMQ broker

2013-09-26 Thread johnbing
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 extra

Re: NIO transport performance for ActiveMQ

2013-09-25 Thread johnbing
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 estimate

Re: Statistics Plugin for ActiveMQ broker

2013-09-25 Thread johnbing
I think StatisticsBrokerPlugin class can be used for this purpose. To retrieve stats on the broker send a empty message to ActiveMQ.Statistics.Broker (Queue or Topic) with a replyTo set to the destination you want the stats returned to. But using this I am not sure you can log stats into the log

Re: NIO transport performance for ActiveMQ

2013-09-25 Thread johnbing
Hi, Please find attached configuration file. NIO_broker_configuration.txt My launcher file contains : max_heap_size = "2700M" max_perm_size = "128M" name = "mqbroker" activemq_jar

Re: NIO transport performance for ActiveMQ

2013-09-24 Thread johnbing
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 BrokerService[amqDevBroke

Re: NIO transport performance for ActiveMQ

2013-09-13 Thread johnbing
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

Re: NIO transport performance for ActiveMQ

2013-09-06 Thread johnbing
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 pro

Re: NIO transport performance for ActiveMQ

2013-09-04 Thread johnbing
Hey, I am seeing the throughput drop using NIO. With 1 producer and 1 consumer in non-persistence mode using queues I got 47K msgs/sec using NIO while 53K msgs/sec using TCP. My major concern is number of threads, there is no decrement in number of threads. At least NIO supposed to reduce threads

NIO transport performance for ActiveMQ

2013-08-30 Thread johnbing
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 through