Skip to content

Commit b7a93fb

Browse files
Ensure we don't create duplicates
1 parent aaee0cf commit b7a93fb

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

projects/client/RabbitMQ.Client/src/client/impl/ModelBase.cs

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1285,7 +1285,10 @@ public void BasicPublish(string exchange,
12851285
if (m_nextPubSeqNo > 0) {
12861286
lock(m_unconfirmedSet.SyncRoot)
12871287
{
1288-
m_unconfirmedSet.Add(m_nextPubSeqNo);
1288+
if(!m_unconfirmedSet.Contains(m_nextPubSeqNo))
1289+
{
1290+
m_unconfirmedSet.Add(m_nextPubSeqNo);
1291+
}
12891292
m_nextPubSeqNo++;
12901293
}
12911294
}

0 commit comments

Comments
 (0)