code: public void start() {
      input.messageHandler(new Handler<Object>() {
        @Override
        public void handle(Object message) {
          output.send(message);
          pumped++;
        }
      });
    }
docs: Starts the pump.