Skip to content

Commit 464da89

Browse files
committed
chore: handle err frame
1 parent ae18299 commit 464da89

File tree

1 file changed

+9
-0
lines changed

1 file changed

+9
-0
lines changed

src/main/kotlin/spp/protocol/service/extend/TCPServiceFrameParser.kt

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -77,6 +77,8 @@ class TCPServiceFrameParser(
7777
handleErrorFrame(frame)
7878
} else if (body is JsonObject && body.getString("message")?.startsWith("EventBusException:") == true) {
7979
handleErrorFrame(body.put("address", frame.getString("address")))
80+
} else if (frame.getString("type") == "err") {
81+
handleErrorFrame(frame)
8082
} else {
8183
vertx.eventBus().publish(frame.getString("address"), body)
8284
}
@@ -119,6 +121,13 @@ class TCPServiceFrameParser(
119121
)
120122
}
121123
vertx.eventBus().publish(frame.getString("address"), error)
124+
} else if (frame.getString("type") == "err") {
125+
val error = ReplyException(
126+
ReplyFailure.valueOf(frame.getString("failureType")),
127+
frame.getInteger("failureCode") ?: 500,
128+
frame.getString("message")
129+
)
130+
vertx.eventBus().publish(frame.getString("address"), error)
122131
} else {
123132
throw UnsupportedOperationException(frame.toString())
124133
}

0 commit comments

Comments
 (0)