code: protected void sendSubscribe(String topic) {
      assert topic != null : "topic shouldn't be null";
      JsonObject msg = Json.createObject().set(TYPE, "register").set(TOPIC, topic);
      send(msg);
    }
docs: /*
  First handler for this topic so we should register the connection