public final class AsyncConnection.RequestProcessor extends Object implements Runnable
Constructor and Description |
---|
RequestProcessor() |
Modifier and Type | Method and Description |
---|---|
void |
run()
Keeps processing the
PendingRequest s in the pending Queue
until a QUIT is encountered in the pending queue. |
public void run()
PendingRequest
s in the pending Queue
until a QUIT is encountered in the pending queue. Thread will stop after
processing the QUIT response (which is expected to be a VirtualResponse
.
TODO: not entirely clear what is the best way to handle exceptions.
TODO: socket Reconnect in the context of pipelining is non-trivial, and maybe not even practically possible. (e.g. request n is sent but pipe breaks on some m (m!=n) response. non trivial.
Copyright © 2009–2016. All rights reserved.