diff options
Diffstat (limited to 'qpid/java')
| -rw-r--r-- | qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/transport/ConnectionEndpoint.java | 11 |
1 files changed, 7 insertions, 4 deletions
diff --git a/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/transport/ConnectionEndpoint.java b/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/transport/ConnectionEndpoint.java index cac4e88178..5775eb4c2e 100644 --- a/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/transport/ConnectionEndpoint.java +++ b/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/transport/ConnectionEndpoint.java @@ -410,13 +410,16 @@ public class ConnectionEndpoint implements DescribedTypeConstructorRegistry.Sour default: } - for (int i = 0; i < _receivingSessions.length; i++) + if(_receivingSessions != null) { - if (_receivingSessions[i] != null) + for (int i = 0; i < _receivingSessions.length; i++) { - _receivingSessions[i].end(); - _receivingSessions[i] = null; + if (_receivingSessions[i] != null) + { + _receivingSessions[i].end(); + _receivingSessions[i] = null; + } } } } |