Examples of org.jredis.ClientRuntimeException

org.jredis.ClientRuntimeException
Base class for all non-Redis exceptions relating to client runtime. Implementations must only throw this type of exception when the problem(s) encountered are neither Redis usage errors, nor unexpected code segment execution.
For example, failure to establish a connection, or losing the connection, should raise this type of exception. But encountering parse errors in Redis responses streams is a bug and should be noted by raising a {@link ProviderException}. @author Joubin Houshyar (alphazero@sensesay.net) @version alpha.0, 04/02/09 @since alpha.0

        Response response = null;
        try {
                  response = JRedisPipeline.this.queueRequest(cmd, args).get(timeout, unit);
                }
                catch (InterruptedException e) {
                  throw new ClientRuntimeException("Interrupted!", e);
                }
                catch (TimeoutException e) {
                  throw new ClientRuntimeException("timedout waiting for response");
                }
                catch (ExecutionException e) {
                  Throwable cause = e.getCause();
                  if(cause instanceof RedisException)
                    throw (RedisException) cause;
                  else if(cause instanceof ProviderException)
                    throw (ProviderException) cause;
                  else if(cause instanceof ClientRuntimeException) 
                    throw (ClientRuntimeException)cause;
                  else throw new ClientRuntimeException("Exception in pipeline exec of requested command", cause);
                }
                return response;
            }
    };
  }

View Full Code Here

          // This will block.
          response = pendingResponse.get();
        }
        catch (InterruptedException e) {
          e.printStackTrace();
          throw new ClientRuntimeException("on pendingResponse.get()", e);
        }
        catch (ExecutionException e) {
          if(e.getCause() instanceof RedisException) {
            throw (RedisException) e.getCause();
          }

View Full Code Here

        // on connection reset
        throw new ConnectionReset("SocketException in readLine.  Command: " + cmd.code, e);
      }
      catch (IOException e) {
        e.printStackTrace();
        throw new ClientRuntimeException ("IOException in readLine.  Command: " + cmd.code, e);
      }
    }

View Full Code Here

      InetAddress address;
        try {
          address = InetAddress.getByName(host);
        }
        catch (UnknownHostException e) {
          throw new ClientRuntimeException("unknown host: " + host, e);
        }
    
    return newSpec(address, port, database, credentials);
  }

View Full Code Here

          }
        }
      }
      catch (IOException e) {
        e.printStackTrace();
        throw new ClientRuntimeException ("IOEx while reading line for command " + cmd.code, e);
      }
      
      if(c==-1) throw new ClientRuntimeException ("in.read returned -1");
    }

View Full Code Here

      
      int readcnt = -1;
      int offset = 0;


      while(offset < length){
        if((readcnt = in.read (data, offset, length-offset)) ==-1 ) throw new ClientRuntimeException("IO - read returned -1 -- problem");
        offset += readcnt;
      }
      // FIX: http://github.com/alphazero/jredis/issues#issue/5 -- BEGIN
      for(int i=0; i<CRLF_LEN; i++){
        if (in.read() == -1){

View Full Code Here

    return this;
  }
  
  public Sort LIMIT(long from, long count) {
    if(from < 0) {
      throw new ClientRuntimeException("from in LIMIT clause: " + from);
    }
    
    if(count <= 0) {
      throw new ClientRuntimeException("count in LIMIT clause: " + from);
    }
    
//    String limitSpecName = Command.Option.LIMIT.name();
      String fromString = new Long(from).toString();
      String countString = new Long(count).toString();

View Full Code Here

      Log.bug ("serviceRequest() -- *unexpected* RuntimeException: " + e.getLocalizedMessage());


      Log.log ("serviceRequest() -- closing connection ...");
      disconnect();


      throw new ClientRuntimeException("unexpected runtime exeption: " + e.getLocalizedMessage(), e);
    }
    // 3 - Status
    //
    status = Assert.notNull (response.getStatus(), "status from response object", ProviderException.class);
    if(status.isError()) {

View Full Code Here

      Log.bug ("serviceRequest() -- *unexpected* RuntimeException: " + e.getLocalizedMessage());


      Log.log ("serviceRequest() -- closing connection ...");
      disconnect();


      throw new ClientRuntimeException("unexpected runtime exeption: " + e.getLocalizedMessage(), e);
    }
    
    // 3 - Status
    //
    status = Assert.notNull (response.getStatus(), "status from response object", ProviderException.class);

View Full Code Here

        }
        catch (IllegalArgumentException bug){ 
          throw new ProviderException ("Bug: in converting the bulk data length bytes", bug);
        }
        catch (IOException problem) {
          throw new ClientRuntimeException ("Problem: reading the bulk data bytes", problem);
        }
        catch (RuntimeException bug) {
          throw new ProviderException ("Bug: reading the bulk data bytes.  expecting " + size + " bytes.", bug);
        }
      }

View Full Code Here

0 1 2 3 4

TOP

Related Classes of org.jredis.ClientRuntimeException

org.jredis.connector.FaultedConnection

org.jredis.ri.alphazero.connection.ChunkedPipelineConnection

org.jredis.ri.alphazero.connection.ChunkedPipelineConnection$ResponseHandler

org.jredis.ri.alphazero.connection.ConnectionBase

org.jredis.ri.alphazero.connection.DefaultConnectionSpec

org.jredis.ri.alphazero.connection.HeartbeatJinn

org.jredis.ri.alphazero.connection.PipelineConnectionBase

org.jredis.ri.alphazero.connection.PipelineConnectionBase$ResponseHandler

org.jredis.ri.alphazero.connection.SocketConnection

org.jredis.ri.alphazero.connection.SyncConnection

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.