@@ -111,15 +111,15 @@ class TCPServiceFrameParser(val vertx: Vertx, val socket: NetSocket) : Handler<A
111111 if (body.fieldNames().size == 1 && body.containsKey(" value" )) {
112112 // todo: understand why can't just re-send body like below
113113 vertx.eventBus()
114- .send(" local. " + frame.getString(" address" ), body.getValue(" value" ))
114+ .send(frame.getString(" address" ), body.getValue(" value" ))
115115 } else {
116116 vertx.eventBus()
117- .send(" local. " + frame.getString(" address" ), body)
117+ .send(frame.getString(" address" ), body)
118118 }
119119 }
120120 } else {
121121 vertx.eventBus()
122- .send(" local. " + frame.getString(" address" ), body)
122+ .send(frame.getString(" address" ), body)
123123 }
124124 }
125125 } else if (" err" == frame.getString(" type" )) {
@@ -156,7 +156,7 @@ class TCPServiceFrameParser(val vertx: Vertx, val socket: NetSocket) : Handler<A
156156 else -> TODO ()
157157 }
158158 vertx.eventBus()
159- .send(" local. " + frame.getString(" address" ), error)
159+ .send(frame.getString(" address" ), error)
160160 } else {
161161 // i think these are service exceptions
162162 val error = ReplyException (
@@ -201,7 +201,7 @@ class TCPServiceFrameParser(val vertx: Vertx, val socket: NetSocket) : Handler<A
201201 }
202202 }
203203 vertx.eventBus()
204- .send(" local. " + frame.getString(" address" ), error)
204+ .send(frame.getString(" address" ), error)
205205 }
206206 }
207207}
0 commit comments