public class RequestMuxer extends Object implements AutoCloseable
Constructor and Description |
---|
RequestMuxer(com.typesafe.config.Config config,
io.netty.channel.EventLoopGroup workerLoop,
ConnectionPool connectionPool) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
start() |
Request |
write(Object payload) |
Request |
write(Object payload,
com.google.common.util.concurrent.SettableFuture<UUID> writeFuture) |
Request |
writeExpectResponse(Object payload) |
Request |
writeExpectResponse(Object payload,
com.google.common.util.concurrent.SettableFuture<UUID> writeFuture,
com.google.common.util.concurrent.SettableFuture<Response> responseFuture) |
public RequestMuxer(com.typesafe.config.Config config, io.netty.channel.EventLoopGroup workerLoop, ConnectionPool connectionPool)
public void close()
close
in interface AutoCloseable
public Request write(Object payload, com.google.common.util.concurrent.SettableFuture<UUID> writeFuture)
Copyright © 2016. All Rights Reserved.