X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fcommons%2Fprotocol-framework%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fprotocol%2Fframework%2FProtocolSessionPromise.java;h=494ccf8ec4cb5d305dad89d9cf54ed41ab3f3263;hp=b64c4828a4a7315524afc3370a6bca95c8711b29;hb=6ca44d2095f0887508dd32f0174058a627eff4f9;hpb=b696b4b6be5f669b204d2eac48d251b7fe8c00cc diff --git a/opendaylight/commons/protocol-framework/src/main/java/org/opendaylight/protocol/framework/ProtocolSessionPromise.java b/opendaylight/commons/protocol-framework/src/main/java/org/opendaylight/protocol/framework/ProtocolSessionPromise.java index b64c4828a4..494ccf8ec4 100644 --- a/opendaylight/commons/protocol-framework/src/main/java/org/opendaylight/protocol/framework/ProtocolSessionPromise.java +++ b/opendaylight/commons/protocol-framework/src/main/java/org/opendaylight/protocol/framework/ProtocolSessionPromise.java @@ -28,7 +28,7 @@ import org.slf4j.LoggerFactory; final class ProtocolSessionPromise> extends DefaultPromise { private static final Logger LOG = LoggerFactory.getLogger(ProtocolSessionPromise.class); private final ReconnectStrategy strategy; - private final InetSocketAddress address; + private InetSocketAddress address; private final Bootstrap b; @GuardedBy("this") @@ -50,6 +50,9 @@ final class ProtocolSessionPromise> extends Default LOG.debug("Promise {} attempting connect for {}ms", lock, timeout); + if(this.address.isUnresolved()) { + this.address = new InetSocketAddress(this.address.getHostName(), this.address.getPort()); + } this.b.option(ChannelOption.CONNECT_TIMEOUT_MILLIS, timeout); final ChannelFuture connectFuture = this.b.connect(this.address); // Add listener that attempts reconnect by invoking this method again.