File tree Expand file tree Collapse file tree 1 file changed +5
-3
lines changed
src/NServiceBus.Transport.RabbitMQ/Connection Expand file tree Collapse file tree 1 file changed +5
-3
lines changed Original file line number Diff line number Diff line change
1
+ #nullable enable
2
+
1
3
namespace NServiceBus . Transport . RabbitMQ
2
4
{
3
5
using System ;
@@ -28,9 +30,9 @@ IConnection CreateWiredUpConnection()
28
30
return newConnection ;
29
31
}
30
32
31
- void Connection_ConnectionShutdown ( object sender , ShutdownEventArgs e )
33
+ void Connection_ConnectionShutdown ( object ? sender , ShutdownEventArgs e )
32
34
{
33
- if ( e . Initiator == ShutdownInitiator . Application )
35
+ if ( e . Initiator == ShutdownInitiator . Application || sender is null )
34
36
{
35
37
return ;
36
38
}
@@ -129,7 +131,7 @@ public void Dispose()
129
131
readonly IRoutingTopology routingTopology ;
130
132
readonly ConcurrentQueue < ConfirmsAwareChannel > channels ;
131
133
readonly CancellationTokenSource stoppingTokenSource = new ( ) ;
132
- volatile IConnection connection ;
134
+ volatile IConnection ? connection ;
133
135
bool disposed ;
134
136
135
137
static readonly ILog Logger = LogManager . GetLogger ( typeof ( ChannelProvider ) ) ;
You can’t perform that action at this time.
0 commit comments