Browse Source
Merge pull request #5132 from volodymyr-babak/edge-grpc-gzip
[3.3.1] EdgeGrpcClient: added GZIP compression
pull/5137/head
Igor Kulikov
5 years ago
committed by
GitHub
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with
1 additions and
1 deletions
-
common/edge-api/src/main/java/org/thingsboard/edge/rpc/EdgeGrpcClient.java
|
|
|
@ -92,7 +92,7 @@ public class EdgeGrpcClient implements EdgeRpcClient { |
|
|
|
channel = builder.build(); |
|
|
|
EdgeRpcServiceGrpc.EdgeRpcServiceStub stub = EdgeRpcServiceGrpc.newStub(channel); |
|
|
|
log.info("[{}] Sending a connect request to the TB!", edgeKey); |
|
|
|
this.inputStream = stub.handleMsgs(initOutputStream(edgeKey, onUplinkResponse, onEdgeUpdate, onDownlink, onError)); |
|
|
|
this.inputStream = stub.withCompression("gzip").handleMsgs(initOutputStream(edgeKey, onUplinkResponse, onEdgeUpdate, onDownlink, onError)); |
|
|
|
this.inputStream.onNext(RequestMsg.newBuilder() |
|
|
|
.setMsgType(RequestMsgType.CONNECT_RPC_MESSAGE) |
|
|
|
.setConnectRequestMsg(ConnectRequestMsg.newBuilder().setEdgeRoutingKey(edgeKey).setEdgeSecret(edgeSecret).build()) |
|
|
|
|
