package reactmann;

import io.vertx.core.AbstractVerticle;
import rx.Observable;

/**
 * @author blake
 */
public abstract class RiemannVerticle extends AbstractVerticle {
    @Override
    public void start() {
        vertx.deployVerticle("java:reactmann.TcpMessageVerticle", event -> observeStream(Riemann.getEvents(vertx)));
    }

    public abstract void observeStream(Observable<Event> events);
}

@@ -244,44 +244,167 @@
 ava:
-reactmann.TcpMessageVerticle%22, event
+%22 + WebSocketVerticle.class.getName(), webSocketCallback -%3E %7B%0A            vertx.deployVerticle(%22java:%22 + TcpMessageVerticle.class.getName(), tcpMessageCallback
  -%3E 
@@ -445,16 +445,28 @@
 rtx)));%0A
+        %7D);%0A
     %7D%0A%0A 

Make sure to deploy the websocket verticle by default as well.