File tree Expand file tree Collapse file tree 2 files changed +2
-2
lines changed
src/main/kotlin/spp/cli/commands Expand file tree Collapse file tree 2 files changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -88,7 +88,7 @@ class SubscribeEvents : CliktCommand(
8888 ).await()
8989 socket!! .handler(FrameParser (TCPServiceFrameParser (vertx, socket)))
9090
91- vertx.eventBus().consumer<JsonObject >(" local. " + SourceServices .Provide .LIVE_INSTRUMENT_SUBSCRIBER ) {
91+ vertx.eventBus().consumer<JsonObject >(SourceServices .Provide .LIVE_INSTRUMENT_SUBSCRIBER ) {
9292 val liveEvent = Json .decodeValue(it.body().toString(), LiveInstrumentEvent ::class .java)
9393
9494 // todo: impl filter on platform
Original file line number Diff line number Diff line change @@ -91,7 +91,7 @@ class SubscribeView : CliktCommand(
9191 ).await()
9292 socket!! .handler(FrameParser (TCPServiceFrameParser (vertx, socket)))
9393
94- vertx.eventBus().consumer<JsonObject >(" local. $LIVE_VIEW_SUBSCRIBER .${PlatformCLI .developer.id} " ) {
94+ vertx.eventBus().consumer<JsonObject >(" $LIVE_VIEW_SUBSCRIBER .${PlatformCLI .developer.id} " ) {
9595 val event = Json .decodeValue(it.body().toString(), LiveViewEvent ::class .java)
9696 if (outputFullEvent) {
9797 println (event.metricsData)
You can’t perform that action at this time.
0 commit comments