X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fcommons%2Fprotocol-framework%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fprotocol%2Fframework%2FProtocolSessionPromise.java;h=494ccf8ec4cb5d305dad89d9cf54ed41ab3f3263;hb=e45d1455db403b1177a131f7a06307b57008a782;hp=b64c4828a4a7315524afc3370a6bca95c8711b29;hpb=769a4060e445ef39ed1c125bdc2c48ce59d1fbf9;p=controller.git 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.