Skip to content

Commit 728dc62

Browse files
committed
use protocol marshaller
1 parent 29cc10a commit 728dc62

1 file changed

Lines changed: 2 additions & 2 deletions

File tree

src/main/kotlin/spp/cli/commands/developer/instrument/SubscribeEvents.kt

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -38,10 +38,10 @@ import spp.cli.PlatformCLI
3838
import spp.protocol.marshall.ProtocolMarshaller.deserializeLiveInstrumentRemoved
3939
import spp.protocol.SourceServices.Provide.toLiveInstrumentSubscriberAddress
4040
import spp.protocol.extend.TCPServiceFrameParser
41-
import spp.protocol.instrument.event.LiveBreakpointHit
4241
import spp.protocol.instrument.event.LiveInstrumentEvent
4342
import spp.protocol.instrument.event.LiveInstrumentEventType
4443
import spp.protocol.instrument.event.LiveLogHit
44+
import spp.protocol.marshall.ProtocolMarshaller
4545

4646
class SubscribeEvents : CliktCommand(
4747
help = "Listens for and outputs live events. Subscribes to all events by default"
@@ -101,7 +101,7 @@ class SubscribeEvents : CliktCommand(
101101
}
102102
}
103103
LiveInstrumentEventType.BREAKPOINT_HIT -> {
104-
val breakpointHit = Json.decodeValue(liveEvent.data, LiveBreakpointHit::class.java)
104+
val breakpointHit = ProtocolMarshaller.deserializeLiveBreakpointHit(JsonObject(liveEvent.data))
105105
if (breakpointHit.breakpointId !in instrumentIds) {
106106
return@consumer
107107
}

0 commit comments

Comments
 (0)