fixing tcp to send single event
@@ -75,8 +75,12 @@ public class TCPOutputTransport extends OutputTransport {
TCPNettyClient.connect(host, port);
}
String streamId = streamIdOption.getValue(dynamicOptions);
+ if (payload instanceof Event) {
+ TCPNettyClient.send(streamId, new Event[]{(Event) payload});
+ } else {
TCPNettyClient.send(streamId, (Event[]) payload);
}
+ }
@Override
public void disconnect() {
