You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@servicecomb.apache.org by wu...@apache.org on 2019/01/31 03:34:49 UTC
[servicecomb-java-chassis] branch master updated:
[SCB-1143]Servicecomb support watch service center with auth headers
This is an automated email from the ASF dual-hosted git repository.
wujimin pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/servicecomb-java-chassis.git
The following commit(s) were added to refs/heads/master by this push:
new ed82471 [SCB-1143]Servicecomb support watch service center with auth headers
ed82471 is described below
commit ed82471064e1c076a78fea6c601edbcfdcf9dab9
Author: heyile <25...@qq.com>
AuthorDate: Wed Jan 30 19:03:30 2019 +0800
[SCB-1143]Servicecomb support watch service center with auth headers
---
.../servicecomb/serviceregistry/client/http/WebsocketUtils.java | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
diff --git a/service-registry/src/main/java/org/apache/servicecomb/serviceregistry/client/http/WebsocketUtils.java b/service-registry/src/main/java/org/apache/servicecomb/serviceregistry/client/http/WebsocketUtils.java
index 70625da..39db844 100644
--- a/service-registry/src/main/java/org/apache/servicecomb/serviceregistry/client/http/WebsocketUtils.java
+++ b/service-registry/src/main/java/org/apache/servicecomb/serviceregistry/client/http/WebsocketUtils.java
@@ -26,6 +26,7 @@ import org.slf4j.LoggerFactory;
import io.vertx.core.Handler;
import io.vertx.core.buffer.Buffer;
+import io.vertx.core.http.HttpMethod;
/**
* Created by on 2017/4/28.
@@ -44,8 +45,8 @@ public final class WebsocketUtils {
client.websocket(ipPort.getPort(),
ipPort.getHostOrIp(),
url,
- RestUtils.getDefaultHeaders().addAll(RestUtils
- .getSignAuthHeaders(RestUtils.createSignRequest(null, ipPort, new RequestParam(), url, new HashMap<>()))),
+ RestUtils.getDefaultHeaders().addAll(RestUtils.getSignAuthHeaders(
+ RestUtils.createSignRequest(HttpMethod.GET.name(), ipPort, new RequestParam(), url, new HashMap<>()))),
ws -> {
onOpen.handle(null);