@@ -110,16 +110,13 @@ class TCPServiceFrameParser(val vertx: Vertx, val socket: NetSocket) : Handler<A
110110 } else {
111111 if (body.fieldNames().size == 1 && body.containsKey(" value" )) {
112112 // todo: understand why can't just re-send body like below
113- vertx.eventBus()
114- .send(frame.getString(" address" ), body.getValue(" value" ))
113+ vertx.eventBus().send(frame.getString(" address" ), body.getValue(" value" ))
115114 } else {
116- vertx.eventBus()
117- .send(frame.getString(" address" ), body)
115+ vertx.eventBus().send(frame.getString(" address" ), body)
118116 }
119117 }
120118 } else {
121- vertx.eventBus()
122- .send(frame.getString(" address" ), body)
119+ vertx.eventBus().send(frame.getString(" address" ), body)
123120 }
124121 }
125122 } else if (" err" == frame.getString(" type" )) {
@@ -155,8 +152,7 @@ class TCPServiceFrameParser(val vertx: Vertx, val socket: NetSocket) : Handler<A
155152 )
156153 else -> TODO ()
157154 }
158- vertx.eventBus()
159- .send(frame.getString(" address" ), error)
155+ vertx.eventBus().send(frame.getString(" address" ), error)
160156 } else {
161157 // i think these are service exceptions
162158 val error = ReplyException (
@@ -200,8 +196,7 @@ class TCPServiceFrameParser(val vertx: Vertx, val socket: NetSocket) : Handler<A
200196 TODO ()
201197 }
202198 }
203- vertx.eventBus()
204- .send(frame.getString(" address" ), error)
199+ vertx.eventBus().send(frame.getString(" address" ), error)
205200 }
206201 }
207202}
0 commit comments