Bump odlparent 2.0.2 to 2.0.4

[controller.git] / opendaylight / commons / protocol-framework / src / main / java / org / opendaylight / protocol / framework / ProtocolSessionPromise.java

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 b64c4828a4a7315524afc3370a6bca95c8711b29..494ccf8ec4cb5d305dad89d9cf54ed41ab3f3263 100644 (file)
--- 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<S extends ProtocolSession<?>> extends DefaultPromise<S> {
     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<S extends ProtocolSession<?>> 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.