Re:Re: Data loss for ActiveMQ 5.6.0

2013-03-10 Thread yin wang
If only the index files are stale you can try to remove all index files (*.data) and restart the broker to rebuild the index. The broker will get stopped when IO exception occurs so new messages are unable to enqueue the broker in fact. At 2013-03-10 00:59:13,jcamus wrote: >Thanks for your answe

Re: can we combine message groups and jms selectors

2013-03-27 Thread Yin Wang
Yes, you can assume that works. It seems you want your message flow to be split into two message flows, one for the lower priority messages while the other for the higher priority messages and you want they are stuck on two 'exclusive' consumers respectively. For the sparse selector In one word ,

Re: Durable Topic, only most-recent message needed

2013-05-02 Thread Yin Wang
The non-durable retroactive consumer of Topic will do the trick. http://activemq.apache.org/retroactive-consumer.html Only one condition is not satisfied,messages can not survive from the restart of the broker. 2013/5/2 Andrea Arcuri > Hi, > I am new to ActiveMQ. Reading documentation and pla

Re: Question regarding to EnqueueCount and ExpiredCount for topic destination

2013-05-06 Thread Yin Wang
+1 2013/5/7 Yi Pan > Hi, Christian, > > Thanks for the quick response. However, the stats and its explanation is > still very confusing to me. > > The standard explanation of Enqueue Count - the total number of messages > sent to the queue since the last restart. That's counting the action of >

Re: Is there an timeout exception for session.commit() ?

2013-09-10 Thread Yin Wang
haha! 在 2013-9-9 下午9:39,"HellKnight" 写道: > I feel a little shamed...The problem is actually simple : I am using async > sending , but I did not register any exception listener for the connection > I > used > > > > -- > View this message in context: > http://activemq.2283324.n4.nabble.com/Is-there-

Re: Error occur when I setup pure master/slave

2013-12-07 Thread Yin Wang
Pure master/slave is departed in later releases and wont get supported any more. You should consider other cluster topology. 2013/12/3 赵振华 ZhenhuaZhao > hi,all > I’m a newbie in activemq. >I use active-5.5.5 on rhel5.4 X86_64 in pure master/slave mode. > I leave master’s config

Re: Client side producer flow control exception never thrown

2014-02-19 Thread Yin Wang
NoSpaceException is also a response come from broker. when asyn send is used,client will not expect response for request. You can try to use non-transactional session or enforce sync send and that should work. 2014-02-20 7:04 GMT+08:00 Gary Tully : > It looks like you are using async send so th

Re: Activemq issue when Slave started

2014-02-19 Thread Yin Wang
What's message ack mode you're using? If your consumer does not acknowledge messages that have been processed, eg, you may forget to manual ack message when using client ack mode or forget to commit session when using transaction, those messages will be redelivered when consumer or broker gets rest

Re: Duplex networkConnector can not reconnect when network is restored on ActiveMQ 5.9.

2014-02-20 Thread Yin Wang
It's hard to enumerate differences between them, even for developers. You'd better to create a similar test case to see what's up inside broker, here are some examples, https://git-wip-us.apache.org/repos/asf?p=activemq.git;a=blob_plain;f=activemq-core/src/test/java/org/apache/activemq/transport/di

Re: increase Checkpoint interval

2014-02-20 Thread Yin Wang
Yes,that help performance but once broker gets restarted,it will take longer time to complete index recovery. Here is a guide that may help you to tune performance, https://access.redhat.com/site/documentation/en-US/JBoss_A-MQ/6.0/html/Tuning_Guide/files/PersTuning-KahaDB.html 2014-02-13 19:49 GM

Re: does AUTO_ACKNOWLEDGE guarantee once and only once semantic for queue consumer?

2014-02-24 Thread Yin Wang
Seems what you really want to solve is to distribute real task messages evenly between consumers. As default a consumer has a prefetch to allow broker to push messages to it in batch manner, if a consumer is slow to process message then many pending messages will be accumulated and other consumers

Re: does AUTO_ACKNOWLEDGE guarantee once and only once semantic for queue consumer?

2014-02-24 Thread Yin Wang
BTW,AUTO_ACKNOWLEDGE can not guarantee once and only once semantic since the ack is sent async. You can image such a case when your consumer has succeeded in processing a message while the consumer application is crashed before the ack is sent, you will receive that message again if your applicatio

Re: Messages stuck in queue 5.9.0

2014-04-03 Thread Yin Wang
Can you try to disable cache consumer option? Or can you use a plain jms consumer to try to reproduce the issue? Just guess it's maybe related with cache consumer and spring jms template. 2014-03-29 4:19 GMT+08:00 lookers : > Just checked the queuesize and it is increasing when it is blocked. >

Re: Activating consumer for each message groups

2014-07-19 Thread Yin Wang
If you have existing messages in the broker and add consumers at a later stage, it is a good idea to delay message dispatch start until all consumers are present (or at least to give enough time for them to subscribe). If you don't do that the first consumer will probably acquire all message groups