Add port to Host header. It is mandatory if not the default port is u…

…sed.

src/main/java/mousio/etcd4j/transport/EtcdNettyClient.java

@@ -202,7 +202,7 @@ public void operationComplete(Future<?> future) throws Exception {
 
         modifyPipeLine(etcdRequest, f.channel().pipeline());
 
-        createAndSendHttpRequest(uri.getHost(), etcdRequest.getUrl(), etcdRequest, channel)
+        createAndSendHttpRequest(uri, etcdRequest.getUrl(), etcdRequest, channel)
             .addListener(new ChannelFutureListener() {
               @Override
               public void operationComplete(ChannelFuture future) throws Exception {
@@ -267,19 +267,19 @@ public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws E
   /**
    * Get HttpRequest belonging to etcdRequest
    *
-   * @param hostName    host name for http request
+   * @param server      server for http request
    * @param uri         to send request to
    * @param etcdRequest to send
    * @param channel     to send request on
    * @param <R>         Response type
    * @return HttpRequest
    * @throws Exception when creating or sending HTTP request fails
    */
-  private <R> ChannelFuture createAndSendHttpRequest(String hostName, String uri, EtcdRequest<R> etcdRequest, Channel channel) throws Exception {
+  private <R> ChannelFuture createAndSendHttpRequest(URI server, String uri, EtcdRequest<R> etcdRequest, Channel channel) throws Exception {
     HttpRequest httpRequest = new DefaultHttpRequest(HttpVersion.HTTP_1_1, etcdRequest.getMethod(), uri);
     httpRequest.headers().add("Connection", "keep-alive");
     if(this.hostName == null) {
-      httpRequest.headers().add("Host", hostName);
+      httpRequest.headers().add("Host", server.getHost() + ":" + server.getPort());
     } else {
       httpRequest.headers().add("Host", this.hostName);
     }