File tree Expand file tree Collapse file tree 5 files changed +13
-76
lines changed
control/src/test/kotlin/integration Expand file tree Collapse file tree 5 files changed +13
-76
lines changed Original file line number Diff line number Diff line change @@ -25,12 +25,12 @@ class LiveBreakpointTest : ProbeIntegrationTest() {
2525 val testContext = VertxTestContext ()
2626 val consumer = vertx.eventBus().localConsumer<JsonObject >(" local." + Provide .LIVE_INSTRUMENT_SUBSCRIBER )
2727 consumer.handler {
28- val event = Json .decodeValue(it.body().toString(), LiveInstrumentEvent ::class .java)
29- log.trace(" Received event: $event " )
28+ testContext.verify {
29+ val event = Json .decodeValue(it.body().toString(), LiveInstrumentEvent ::class .java)
30+ log.trace(" Received event: $event " )
3031
31- if (event.eventType == LiveInstrumentEventType .BREAKPOINT_HIT ) {
32- val item = Json .decodeValue(event.data, LiveBreakpointHit ::class .java)
33- testContext.verify {
32+ if (event.eventType == LiveInstrumentEventType .BREAKPOINT_HIT ) {
33+ val item = Json .decodeValue(event.data, LiveBreakpointHit ::class .java)
3434 val vars = item.stackTrace.first().variables
3535 assertEquals(9 , vars.size)
3636 }
Original file line number Diff line number Diff line change @@ -25,12 +25,12 @@ class LiveLogTest : ProbeIntegrationTest() {
2525 val testContext = VertxTestContext ()
2626 val consumer = vertx.eventBus().localConsumer<JsonObject >(" local." + Provide .LIVE_INSTRUMENT_SUBSCRIBER )
2727 consumer.handler {
28- val event = Json .decodeValue(it.body().toString(), LiveInstrumentEvent ::class .java)
29- log.trace(" Received event: $event " )
28+ testContext.verify {
29+ val event = Json .decodeValue(it.body().toString(), LiveInstrumentEvent ::class .java)
30+ log.trace(" Received event: $event " )
3031
31- if (event.eventType == LiveInstrumentEventType .LOG_HIT ) {
32- val item = Json .decodeValue(event.data, LiveLogHit ::class .java)
33- testContext.verify {
32+ if (event.eventType == LiveInstrumentEventType .LOG_HIT ) {
33+ val item = Json .decodeValue(event.data, LiveLogHit ::class .java)
3434 assertEquals(" 1 a a" , item.logResult.logs.first().getFormattedMessage())
3535 }
3636 consumer.unregister()
Load Diff This file was deleted.
Load Diff This file was deleted.
Original file line number Diff line number Diff line change @@ -23,11 +23,12 @@ services:
2323 - " 5445:5445"
2424 - " 5450:5450"
2525 - " 5455:5455"
26+ environment :
27+ - SPP_LOGGING_LEVEL=trace
28+ - SPP_OAP_HOST=skywalking-oap
2629 volumes :
27- - ./config/logback.xml:/opt/sourceplusplus/config/logback.xml
2830 - ./config/spp-platform.crt:/opt/sourceplusplus/config/spp-platform.crt
2931 - ./config/spp-platform.key:/opt/sourceplusplus/config/spp-platform.key
30- - ./config/spp-platform.yml:/opt/sourceplusplus/config/spp-platform.yml
3132 skywalking-oap :
3233 image : sourceplusplus/spp-oap-server:latest
3334 container_name : skywalking-oap
You can’t perform that action at this time.
0 commit comments