Skip to content

Commit af337ba

Browse files
committed
publish messages without reply addresses
1 parent 3da1dbb commit af337ba

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/jvmMain/kotlin/spp/protocol/extend/TCPServiceFrameParser.kt

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -83,7 +83,7 @@ class TCPServiceFrameParser(val vertx: Vertx, val socket: NetSocket) : Handler<A
8383
} else if (body is JsonObject && body.getString("message")?.startsWith("EventBusException:") == true) {
8484
handleErrorFrame(body.put("address", frame.getString("address")))
8585
} else {
86-
vertx.eventBus().send(frame.getString("address"), body)
86+
vertx.eventBus().publish(frame.getString("address"), body)
8787
}
8888
} else {
8989
//directly thrown event bus exceptions
@@ -116,7 +116,7 @@ class TCPServiceFrameParser(val vertx: Vertx, val socket: NetSocket) : Handler<A
116116
)
117117
else -> TODO()
118118
}
119-
vertx.eventBus().send(frame.getString("address"), error)
119+
vertx.eventBus().publish(frame.getString("address"), error)
120120
} else {
121121
throw UnsupportedOperationException(frame.toString())
122122
}

0 commit comments

Comments
 (0)