[
https://issues.apache.org/jira/browse/ARTEMIS-3416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17396591#comment-17396591
]
Amit Herlekar edited comment on ARTEMIS-3416 at 8/10/21, 10:22 AM:
-------------------------------------------------------------------
Here is the debug log file of the recent run which includes all messages and
ACKs.
The reported issue is happening on queue: {{fe_unsupervised}} and
{{analysis_status}}.
[^artemis.zip]
Here is the glimpse of code how we are processing the message:
{code:java}
class processCallback(aMQ.Listener):
# Actual function that process the message in a separate thread
def process_message(self, headers, body):
res_dict = json.loads(body)
job_id = res_dict['job_id']
vm_uuid = res_dict['vm_uuid']
print('Processing the request with message body: ',body)
print('To Be implemented!')
self.send_ack(headers['ack'])
self.send_message_to_model(job_id,vm_uuid)
##:TODO Finish implementation
{code}
!image-2021-08-10-15-49-59-960.png|width=434,height=381!
!image-2021-08-10-15-52-23-921.png|width=523,height=461!
was (Author: amitherlekar):
Here is the debug log file of the recent run which includes all messages and
ACKs.
The reported issue is happening on queue: {{fe_unsupervised}} and
{{analysis_status}}.
[^artemis.zip]
Here is the glimpse of code how we are processing the message:
{code:java}
class processCallback(aMQ.Listener):
# Actual function that process the message in a separate thread
def process_message(self, headers, body):
res_dict = json.loads(body)
job_id = res_dict['job_id']
vm_uuid = res_dict['vm_uuid']
print('Processing the request with message body: ',body)
print('To Be implemented!')
self.send_ack(headers['ack'])
self.send_message_to_model(job_id,vm_uuid)
##:TODO Finish implementation
{code}
> Message count is not zero even after all messages are consumed and
> acknowledged
> -------------------------------------------------------------------------------
>
> Key: ARTEMIS-3416
> URL: https://issues.apache.org/jira/browse/ARTEMIS-3416
> Project: ActiveMQ Artemis
> Issue Type: Bug
> Components: Broker
> Affects Versions: 2.16.0
> Environment: Single artemis instance running as a K8s deployment with
> single replica on CentOS 7.9
> Reporter: Amit Herlekar
> Priority: Minor
> Attachments: artemis.zip, artemis.zip, artemis.zip,
> image-2021-08-06-17-19-37-446.png, image-2021-08-06-17-20-45-445.png,
> image-2021-08-06-17-24-45-732.png, image-2021-08-09-23-27-22-180.png,
> image-2021-08-09-23-29-38-568.png, image-2021-08-09-23-31-51-213.png,
> image-2021-08-10-15-49-59-960.png, image-2021-08-10-15-52-23-921.png
>
>
> We have switched from ActiveMQ Classic to ActiveMQ Artemis. Thanks to the
> nice documentation on github that we are able to containerize it and deploy
> it as a K8s deployment for [KEDA|https://keda.sh/docs/2.4/scalers/artemis/].
> Coming to the issue, we are using STOMP using stomp.py python module. The
> ACK-mode is set as client-individual and consumerWindowSize = 0 on the
> connection. We are promptly acknowledging the message as soon as we read it.
> The problem is, sometimes, the message count in the web console does not
> become zero even after all the messages are actually consumed and
> acknowledged. When I browse the queue, I don't see any messages in it. This
> is causing KEDA to spin up pods unnecessarily.
> Please refer to the screenshots attached.
> As a temporary arrangement, can you let me now how to make the delivery
> message count = 0.
> !image-2021-08-06-17-24-45-732.png|width=638,height=571!
> !image-2021-08-06-17-19-37-446.png|width=811,height=674!
> !image-2021-08-06-17-20-45-445.png|width=671,height=300!
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
