Reactor questions

Gateway.java

public class Gateway {
  TcpClient<String, String> client = null;
  NetChannel<String, String> channel;

  public Gateway(String host, int port) {
    client = new TcpClientSpec<String, String>(NettyTcpClient.class)
        .env(env)
        .codec(StandardCodecs.STRING_CODEC)
        .connect(host, port)
        .get();
    channel = client.open().await();
  }

  public String send(String message) throws Exception {
    return channel.sendAndReceive(message).await(100, TimeUnit.MILLISECONDS);
  }
}

GatewayResource.java

@RestController
@RequestMapping("/api")
public class GatewayResource {
    @Autowired
    private Gateway gateway;

    @RequestMapping(value = "/gateway/{message}", method = RequestMethod.GET, produces = "application/json")
    public Map<?, ?> gateway(@PathVariable String message) throws Exception {
      return new ImmutableMap.Builder<String, Object>()
          .put("result", gateway.send(message))
          .build();
    }

}