activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Christopher Shannon <christopher.l.shan...@gmail.com>
Subject Re: Too many updates in MySQL
Date Thu, 06 Aug 2015 19:05:59 GMT
Also, I forgot to mention that no you can't control the frequency of this.
Durable subscriptions need to update the store on acknowledgement because
they are persistent. Message expiration is different and this query
wouldn't be affected by this.

If you are having performance issues I would recommend looking at something
like KahaDB as a message store which should perform much better.

On Thu, Aug 6, 2015 at 2:57 PM, Christopher Shannon <
christopher.l.shannon@gmail.com> wrote:

> These updates typically happen when a client acknowledges a message.  On
> acknowledgement the TopicStore needs to be updated to keep track of which
> subscriptions have acked each message.  This is how the broker knows when a
> message can be deleted (when all durable subscriptions have acknowledged
> the message)
>
> On Thu, Aug 6, 2015 at 6:29 AM, sreekumara <sreekumara@gmail.com> wrote:
>
>> I am using jdbcPersistenceAdapter and MySQL database. In my test scenario
>> some of the durable subscribers are offline for long hours (<24hrs). The
>> tests shows continuous update queries are fired to database to update
>> "LAST_ACKED_ID".
>>
>> Why so many updates are repeatedly fired for every few seconds? Is there
>> any
>> parameter to control the frequency for these updates. How
>> "expireMessagesPeriod" work , does it has any impact on these updates?
>>
>> repeated queries from database general log are given below.
>>
>> Query,UPDATE ACTIVEMQ_ACKS SET LAST_ACKED_ID=25026\, XID = NULL WHERE
>> CONTAINER='topic://testTopic' AND CLIENT_ID='AP8DA27' AND SUB_NAME='test3'
>> Query,UPDATE ACTIVEMQ_ACKS SET LAST_ACKED_ID=25026\, XID = NULL WHERE
>> CONTAINER='topic://testTopic' AND CLIENT_ID='AP8DA26' AND SUB_NAME='test2'
>> Query,UPDATE ACTIVEMQ_ACKS SET LAST_ACKED_ID=25026\, XID = NULL WHERE
>> CONTAINER='topic://testTopic' AND CLIENT_ID='AP8DA29' AND SUB_NAME='test5'
>> Query,UPDATE ACTIVEMQ_ACKS SET LAST_ACKED_ID=25026\, XID = NULL WHERE
>> CONTAINER='topic://testTopic' AND CLIENT_ID='AP8DA28' AND SUB_NAME='test4'
>> Query,UPDATE ACTIVEMQ_ACKS SET LAST_ACKED_ID=25026\, XID = NULL WHERE
>> CONTAINER='topic://testTopic' AND CLIENT_ID='AP8DA23' AND SUB_NAME='test1'
>> Query,UPDATE ACTIVEMQ_ACKS SET LAST_ACKED_ID=25027\, XID = NULL WHERE
>> CONTAINER='topic://testTopic' AND CLIENT_ID='AP8DA27' AND SUB_NAME='test3'
>> Query,UPDATE ACTIVEMQ_ACKS SET LAST_ACKED_ID=25027\, XID = NULL WHERE
>> CONTAINER='topic://testTopic' AND CLIENT_ID='AP8DA26' AND SUB_NAME='test2'
>> Query,UPDATE ACTIVEMQ_ACKS SET LAST_ACKED_ID=25027\, XID = NULL WHERE
>> CONTAINER='topic://testTopic' AND CLIENT_ID='AP8DA29' AND SUB_NAME='test5'
>> Query,UPDATE ACTIVEMQ_ACKS SET LAST_ACKED_ID=25027\, XID = NULL WHERE
>> CONTAINER='topic://testTopic' AND CLIENT_ID='AP8DA28' AND SUB_NAME='test4'
>> Query,UPDATE ACTIVEMQ_ACKS SET LAST_ACKED_ID=25027\, XID = NULL WHERE
>> CONTAINER='topic://testTopic' AND CLIENT_ID='AP8DA23' AND SUB_NAME='test1'
>> Query,UPDATE ACTIVEMQ_LOCK SET TIME = 1438705485091 WHERE ID = 1
>> Query,SELECT ID\, MSG FROM ACTIVEMQ_MSGS WHERE
>> CONTAINER='topic://testTopic'
>> ORDER BY ID
>> Query,UPDATE ACTIVEMQ_ACKS SET LAST_ACKED_ID=25026\, XID = NULL WHERE
>> CONTAINER='topic://testTopic' AND CLIENT_ID='AP8DA27' AND SUB_NAME='test3'
>> Query,UPDATE ACTIVEMQ_ACKS SET LAST_ACKED_ID=25026\, XID = NULL WHERE
>> CONTAINER='topic://testTopic' AND CLIENT_ID='AP8DA26' AND SUB_NAME='test2'
>> Query,UPDATE ACTIVEMQ_ACKS SET LAST_ACKED_ID=25026\, XID = NULL WHERE
>> CONTAINER='topic://testTopic' AND CLIENT_ID='AP8DA29' AND SUB_NAME='test5'
>> Query,UPDATE ACTIVEMQ_ACKS SET LAST_ACKED_ID=25026\, XID = NULL WHERE
>> CONTAINER='topic://testTopic' AND CLIENT_ID='AP8DA28' AND SUB_NAME='test4'
>> Query,UPDATE ACTIVEMQ_ACKS SET LAST_ACKED_ID=25026\, XID = NULL WHERE
>> CONTAINER='topic://testTopic' AND CLIENT_ID='AP8DA23' AND SUB_NAME='test1'
>> Query,UPDATE ACTIVEMQ_ACKS SET LAST_ACKED_ID=25027\, XID = NULL WHERE
>> CONTAINER='topic://testTopic' AND CLIENT_ID='AP8DA27' AND SUB_NAME='test3'
>> Query,UPDATE ACTIVEMQ_ACKS SET LAST_ACKED_ID=25027\, XID = NULL WHERE
>> CONTAINER='topic://testTopic' AND CLIENT_ID='AP8DA26' AND SUB_NAME='test2'
>> Query,UPDATE ACTIVEMQ_ACKS SET LAST_ACKED_ID=25027\, XID = NULL WHERE
>> CONTAINER='topic://testTopic' AND CLIENT_ID='AP8DA29' AND SUB_NAME='test5'
>> Query,UPDATE ACTIVEMQ_ACKS SET LAST_ACKED_ID=25027\, XID = NULL WHERE
>> CONTAINER='topic://testTopic' AND CLIENT_ID='AP8DA28' AND SUB_NAME='test4'
>> Query,UPDATE ACTIVEMQ_ACKS SET LAST_ACKED_ID=25027\, XID = NULL WHERE
>> CONTAINER='topic://testTopic' AND CLIENT_ID='AP8DA23' AND SUB_NAME='test1'
>>
>> Thanks in advance
>> sreekumar
>>
>>
>>
>> --
>> View this message in context:
>> http://activemq.2283324.n4.nabble.com/Too-many-updates-in-MySQL-tp4700485.html
>> Sent from the ActiveMQ - Dev mailing list archive at Nabble.com.
>>
>
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message