[
https://issues.apache.org/jira/browse/AMQNET-727?focusedWorklogId=914497&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-914497
]
ASF GitHub Bot logged work on AMQNET-727:
-----------------------------------------
Author: ASF GitHub Bot
Created on: 13/Apr/24 13:27
Start Date: 13/Apr/24 13:27
Worklog Time Spent: 10m
Work Description: AndyDeMauriceGEDigital commented on PR #34:
URL:
https://github.com/apache/activemq-nms-openwire/pull/34#issuecomment-2053646553
Replace with https://github.com/apache/activemq-nms-openwire/pull/37
Issue Time Tracking
-------------------
Worklog Id: (was: 914497)
Time Spent: 40m (was: 0.5h)
> Thread sync error with MessageConsumer.pendingAck
> -------------------------------------------------
>
> Key: AMQNET-727
> URL: https://issues.apache.org/jira/browse/AMQNET-727
> Project: ActiveMQ .Net
> Issue Type: Bug
> Components: OpenWire
> Affects Versions: 1.8.0
> Reporter: Andy DeMaurice
> Priority: Major
> Time Spent: 40m
> Remaining Estimate: 0h
>
> pendingAck is accessed by multiple threads; in most places where it is
> written, it is done along with accessing *deliveredMessages*, so it is
> written within a *lock(this.deliveredMessages)* block.
> However, this call stack shows where pendingAck gets assigned to a new
> MessageAck object, NOT within the lock... and it is subject to being
> overwritten by another thread (usually the other thread is in
> MessageConsumer.Acknowledge() :
>
> Apache.NMS.ActiveMQ.MessageConsumer.AckLater(Apache.NMS.ActiveMQ.Commands.MessageDispatch,
> Apache.NMS.ActiveMQ.AckType)
> Apache.NMS.ActiveMQ.MessageConsumer.AfterMessageIsConsumed(Apache.NMS.ActiveMQ.Commands.MessageDispatch,
> Boolean)
> Apache.NMS.ActiveMQ.MessageConsumer.Dispatch(Apache.NMS.ActiveMQ.Commands.MessageDispatch)
> Apache.NMS.ActiveMQ.SessionExecutor.Dispatch(Apache.NMS.ActiveMQ.Commands.MessageDispatch)
> Apache.NMS.ActiveMQ.SessionExecutor.Iterate()
> Apache.NMS.ActiveMQ.Threads.DedicatedTaskRunner.Run()
>
> The usual symptom I see is a NullReferenceException in this section of code
> within AckLater; because pendingAck has been set to null by another thread:
>
> if(oldPendingAck == null)
> {
> pendingAck.FirstMessageId = pendingAck.LastMessageId;
> }
> else if(oldPendingAck.AckType == pendingAck.AckType)
> {
> pendingAck.FirstMessageId = oldPendingAck.FirstMessageId;
> }
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
