Handle the case where the remote doesn't set any properties resulting in

a null instance being returned from the properties getter.
This commit is contained in:
Timothy Bish 2016-06-15 18:55:00 -04:00
parent 36237cb30f
commit f595f3c20d
1 changed files with 2 additions and 1 deletions

View File

@ -532,7 +532,8 @@ public class AmqpConnection extends AmqpAbstractResource<Connection> implements
@Override
protected void doOpenCompletion() {
// If the remote indicates that a close is pending, don't open.
if (!getEndpoint().getRemoteProperties().containsKey(CONNECTION_OPEN_FAILED)) {
if (getEndpoint().getRemoteProperties() == null ||
!getEndpoint().getRemoteProperties().containsKey(CONNECTION_OPEN_FAILED)) {
if (!isIdleProcessingDisabled()) {
// Using nano time since it is not related to the wall clock, which may change