Add Protocol to HubConnection ctor

Author: wtgodbe

src/SignalR/clients/java/signalr/src/main/java/com/microsoft/signalr/HttpHubConnectionBuilder.java

@@ -16,6 +16,7 @@ public class HttpHubConnectionBuilder {
     private final String url;
     private Transport transport;
     private HttpClient httpClient;
+    private HubProtocol protocol;
     private boolean skipNegotiate;
     private Single<String> accessTokenProvider;
     private long handshakeResponseTimeout = 0;
@@ -54,6 +55,17 @@ HttpHubConnectionBuilder withHttpClient(HttpClient httpClient) {
         this.httpClient = httpClient;
         return this;
     }
+    
+    /**
+     * Sets the {@link HubProtocol} to be used by the {@link HubConnection}.
+     *
+     * @param protocol The {@link HubProtocol} to be used by the {@link HubConnection}.
+     * @return This instance of the HttpHubConnectionBuilder.
+     */
+    HttpHubConnectionBuilder withProtocol(HubProtocol protocol) {
+        this.protocol = protocol;
+        return this;
+    }
 
     /**
      * Indicates to the {@link HubConnection} that it should skip the negotiate process.
@@ -133,7 +145,7 @@ public HttpHubConnectionBuilder setHttpClientBuilderCallback(Action1<OkHttpClien
      * @return A new instance of {@link HubConnection}.
      */
     public HubConnection build() {
-        return new HubConnection(url, transport, skipNegotiate, httpClient, accessTokenProvider,
+        return new HubConnection(url, transport, skipNegotiate, httpClient, protocol, accessTokenProvider,
             handshakeResponseTimeout, headers, transportEnum, configureBuilder);
     }
 }

src/SignalR/clients/java/signalr/src/main/java/com/microsoft/signalr/HubConnection.java

@@ -128,15 +128,15 @@ Transport getTransport() {
         return transport;
     }
 
-    HubConnection(String url, Transport transport, boolean skipNegotiate, HttpClient httpClient,
+    HubConnection(String url, Transport transport, boolean skipNegotiate, HttpClient httpClient, HubProtocol protocol,
                   Single<String> accessTokenProvider, long handshakeResponseTimeout, Map<String, String> headers, TransportEnum transportEnum,
                   Action1<OkHttpClient.Builder> configureBuilder) {
         if (url == null || url.isEmpty()) {
             throw new IllegalArgumentException("A valid url is required.");
         }
 
         this.baseUrl = url;
-        this.protocol = new JsonHubProtocol();
+        this.protocol = protocol;
 
         if (accessTokenProvider != null) {
             this.accessTokenProvider = accessTokenProvider;