Websocket Client - Making ServiceConfiguration extendable (apache#700)

iEverX · Aug 17, 2017 · d7e9fba · d7e9fba
1 parent 59bb252
commit d7e9fba
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/pulsar-websocket/src/main/java/org/apache/pulsar/websocket/WebSocketService.java b/pulsar-websocket/src/main/java/org/apache/pulsar/websocket/WebSocketService.java
@@ -212,6 +212,7 @@ private static ClusterData createClusterData(WebSocketProxyConfiguration config)
 
     private static ServiceConfiguration createServiceConfiguration(WebSocketProxyConfiguration config) {
         ServiceConfiguration serviceConfig = new ServiceConfiguration();
+        serviceConfig.setProperties(config.getProperties());
         serviceConfig.setClusterName(config.getClusterName());
         serviceConfig.setWebServicePort(config.getWebServicePort());
         serviceConfig.setWebServicePortTls(config.getWebServicePortTls());