org.jredis.ri.alphazero.connection

Class AsyncConnection.RequestProcessor

java.lang.Object

org.jredis.ri.alphazero.connection.AsyncConnection.RequestProcessor

All Implemented Interfaces:

java.lang.Runnable

Enclosing class:

AsyncConnection

public final class AsyncConnection.RequestProcessor
extends java.lang.Object
implements java.lang.Runnable

Constructor Summary

Constructors

Constructor and Description
RequestProcessor()

Method Summary

Modifier and Type	Method and Description
void	run() Keeps processing the PendingRequests in the pending Queue until a QUIT is encountered in the pending queue.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RequestProcessor

public RequestProcessor()

Method Detail

run

public void run()

Keeps processing the PendingRequests 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.

Specified by:

run in interface java.lang.Runnable