[集群] 修复BUG
This commit is contained in:
@@ -74,7 +74,7 @@ public class RedisRpcPlatformController extends RpcController {
|
|||||||
Platform platform = jsonObject.getObject("platform", Platform.class);
|
Platform platform = jsonObject.getObject("platform", Platform.class);
|
||||||
List<CommonGBChannel> channels = jsonObject.getJSONArray("channels").toJavaList(CommonGBChannel.class);
|
List<CommonGBChannel> channels = jsonObject.getJSONArray("channels").toJavaList(CommonGBChannel.class);
|
||||||
String type = jsonObject.getString("type");
|
String type = jsonObject.getString("type");
|
||||||
eventPublisher.catalogEventPublish(platform, channels, type);
|
eventPublisher.catalogEventPublish(platform, channels, type, false);
|
||||||
RedisRpcResponse response = request.getResponse();
|
RedisRpcResponse response = request.getResponse();
|
||||||
response.setStatusCode(ErrorCode.SUCCESS.getCode());
|
response.setStatusCode(ErrorCode.SUCCESS.getCode());
|
||||||
return response;
|
return response;
|
||||||
|
|||||||
Reference in New Issue
Block a user