Skip to content

Commit bb0dd19

Browse files
author
David R. MacIver
committed
lock on the session map in CreateInternal as well as Create
1 parent 9990059 commit bb0dd19

File tree

1 file changed

+7
-4
lines changed

1 file changed

+7
-4
lines changed

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

Lines changed: 7 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -135,10 +135,13 @@ public ISession Create(int channelNumber)
135135

136136
public ISession CreateInternal(int channelNumber)
137137
{
138-
ISession session = new Session(m_connection, channelNumber);
139-
session.SessionShutdown += new SessionShutdownEventHandler(HandleSessionShutdown);
140-
m_sessionMap[channelNumber] = session;
141-
return session;
138+
lock(m_sessionMap)
139+
{
140+
ISession session = new Session(m_connection, channelNumber);
141+
session.SessionShutdown += new SessionShutdownEventHandler(HandleSessionShutdown);
142+
m_sessionMap[channelNumber] = session;
143+
return session;
144+
}
142145
}
143146

144147
///<summary>Replace an active session slot with a new ISession

0 commit comments

Comments
 (0)