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

    try {
      socketAddress = new InetSocketAddress(address, port);
      connect ();
    }
    catch (IOException e) { 
      throw new ClientRuntimeException 
      ("Failed to open connection due to io error => " + e.getLocalizedMessage(), e);
    }
  }

View Full Code Here

        // on connection reset
        throw new ConnectionResetException("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

        // on connection reset
        throw new ConnectionResetException("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

          }
        }
      }
      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

        }
        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

        }
        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 multibulk data bytes.", bug);
        }
      }

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

      this.spec = notNull(spec, "ConnectionSpec init parameter", ClientRuntimeException.class);
      socketAddress = new InetSocketAddress(spec.getAddress(), spec.getPort());
      initializeComponents();
    }
    catch (IllegalArgumentException e) { 
      throw new ClientRuntimeException 
        ("invalid connection spec parameters: " + e.getLocalizedMessage(), e);
    }
    catch (Exception e) {
      throw new ProviderException("Unexpected error on initialize -- BUG", e);
    }

View Full Code Here

    notifyFaulted(fault);
    Log.problem("Shutting down due to connection FAULT: %s - %s", fault, this);
//    notifyShuttingDown();
    shutdown(); // REVU: best to add a pending shutdown flag ..
     if(raiseEx) 
       throw new ClientRuntimeException(fault);
  }

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.