Package com.caringo.client

Examples of com.caringo.client.ScspResponse


          String checkPoint = "";
            ScspQueryArgs args = new ScspQueryArgs();
            System.out.println(">>>>>> Write Non-Mutable Streams <<<<<<<<");
            for (int i = 0; i < 4; i++) {
              inputStream.reset();
              ScspResponse wcResponse = client.write("", inputStream, testData.getBytes().length, args, new ScspHeaders());
              String uuid = wcResponse.getResponseHeaders().getHeaderValues("Content-UUID").get(0);
              checkPoint = checkPoint + uuid + "\r\n";
            }
            System.out.println("Writing checkpoint: " + checkPoint);
            ByteArrayInputStream cpStream = new ByteArrayInputStream(checkPoint.getBytes());
            // Note that checkpoint goes to the local cluster
            ScspResponse wcResponse = client.write("", cpStream, checkPoint.getBytes().length, args, new ScspHeaders());
            String uuid = wcResponse.getResponseHeaders().getHeaderValues("Content-UUID").get(0);
           
            System.out.println(">>>>>> Aggregate Info <<<<<<<<");
            ScspResponse aiResponse = client.aggregateInfo("", uuid, outputStream, args, new ScspHeaders());
            System.out.println(aiResponse.toString());
            System.out.println(outputStream.toString());

        }
        catch (Exception ex)
        {
View Full Code Here


          String checkPoint = "";
            ScspQueryArgs args = new ScspQueryArgs();
            System.out.println(">>>>>> Write Immutable Streams <<<<<<<<");
            for (int i = 1; i < 4; i++) {
              inputStream.reset();
              ScspResponse wcResponse = client.write(rcn, inputStream, testData.getBytes().length, args, new ScspHeaders());
              String uuid = wcResponse.getResponseHeaders().getHeaderValues("Content-UUID").get(0);
              checkPoint = checkPoint + uuid + "\r\n";
            }
            System.out.println("Writing checkpoint: " + checkPoint);
            ByteArrayInputStream cpStream = new ByteArrayInputStream(checkPoint.getBytes());
            // Note that this is a local checkpoint stream
            ScspResponse wcResponse = client.write("", cpStream, checkPoint.getBytes().length, args, new ScspHeaders());
            String uuid = wcResponse.getResponseHeaders().getHeaderValues("Content-UUID").get(0);
           
            System.out.println(">>>>>> Aggregate Info <<<<<<<<");
            ScspResponse aiResponse = client.aggregateInfo("", rcn + "/" + uuid, outputStream, args, new ScspHeaders());
            System.out.println(aiResponse.toString());
            System.out.println(outputStream.toString());

        }
        catch (Exception ex)
        {
View Full Code Here

          String checkPoint = "";
            ScspQueryArgs args = new ScspQueryArgs();
            System.out.println(">>>>>> Write Mutable Streams <<<<<<<<");
            for (int i = 0; i < 4; i++) {
              inputStream.reset();
              ScspResponse wcResponse = client.writeMutable("", inputStream, testData.getBytes().length, args, new ScspHeaders());
              String uuid = wcResponse.getResponseHeaders().getHeaderValues("Content-UUID").get(0);
              checkPoint = checkPoint + uuid + " mutable\r\n";
            }
            System.out.println("Writing checkpoint: " + checkPoint);
            ByteArrayInputStream cpStream = new ByteArrayInputStream(checkPoint.getBytes());
            // Note that checkpoint goes to the local cluster
            ScspResponse wcResponse = client.write("", cpStream, checkPoint.getBytes().length, args, new ScspHeaders());
            String uuid = wcResponse.getResponseHeaders().getHeaderValues("Content-UUID").get(0);
           
            System.out.println(">>>>>> Aggregate Info <<<<<<<<");
            ScspResponse aiResponse = client.aggregateInfo("", uuid, outputStream, args, new ScspHeaders());
            System.out.println(aiResponse.toString());
            System.out.println(outputStream.toString());

        }
        catch (Exception ex)
        {
View Full Code Here

          String checkPoint = "";
            ScspQueryArgs args = new ScspQueryArgs();
            System.out.println(">>>>>> Write Mutable Streams <<<<<<<<");
            for (int i = 1; i < 4; i++) {
              inputStream.reset();
              ScspResponse wcResponse = client.writeMutable(rcn, inputStream, testData.getBytes().length, args, new ScspHeaders());
              String uuid = wcResponse.getResponseHeaders().getHeaderValues("Content-UUID").get(0);
              checkPoint = checkPoint + uuid + " mutable\r\n";
            }
            System.out.println("Writing checkpoint: " + checkPoint);
            ByteArrayInputStream cpStream = new ByteArrayInputStream(checkPoint.getBytes());
            // Note that this is a local checkpoint stream
            ScspResponse wcResponse = client.write("", cpStream, checkPoint.getBytes().length, args, new ScspHeaders());
            String uuid = wcResponse.getResponseHeaders().getHeaderValues("Content-UUID").get(0);
           
            System.out.println(">>>>>> Aggregate Info <<<<<<<<");
            ScspResponse aiResponse = client.aggregateInfo("", rcn + "/" + uuid, outputStream, args, new ScspHeaders());
            System.out.println(aiResponse.toString());
            System.out.println(outputStream.toString());

        }
        catch (Exception ex)
        {
View Full Code Here

                ScspQueryArgs args = new ScspQueryArgs();
              inputStream.reset();
              String mutable = "";
              String uuid = "";
              if (i % 2 == 0) {
                ScspResponse wcResponse = client.writeMutable("", inputStream, testData.getBytes().length, args, new ScspHeaders());
                  uuid = wcResponse.getResponseHeaders().getHeaderValues("Content-UUID").get(0);
                mutable = " mutable";
              }
              else {
                ScspResponse wcResponse = client.write("", inputStream, testData.getBytes().length, args, new ScspHeaders());
                  uuid = wcResponse.getResponseHeaders().getHeaderValues("Content-UUID").get(0);               
              }
              checkPoint = checkPoint + uuid + mutable + "\r\n";
            }
            ScspQueryArgs args = new ScspQueryArgs();
            System.out.println("Writing checkpoint: " + checkPoint);
            ByteArrayInputStream cpStream = new ByteArrayInputStream(checkPoint.getBytes());
            // Note that this is a local checkpoint stream
            ScspResponse wcResponse = client.write("", cpStream, checkPoint.getBytes().length, args, new ScspHeaders());
            String uuid = wcResponse.getResponseHeaders().getHeaderValues("Content-UUID").get(0);
           
            System.out.println(">>>>>> Aggregate Info <<<<<<<<");
            ScspResponse aiResponse = client.aggregateInfo("", uuid, outputStream, args, new ScspHeaders());
            System.out.println(aiResponse.toString());
            System.out.println(outputStream.toString());

        }
        catch (Exception ex)
        {
View Full Code Here

                ScspQueryArgs args = new ScspQueryArgs();
              inputStream.reset();
              String mutable = "";
              String uuid = "";
              if (i % 2 == 0) {
                ScspResponse wcResponse = client.writeMutable(rcn, inputStream, testData.getBytes().length, args, new ScspHeaders());
                  uuid = wcResponse.getResponseHeaders().getHeaderValues("Content-UUID").get(0);
                mutable = " mutable";
              }
              else {
                ScspResponse wcResponse = client.write(rcn, inputStream, testData.getBytes().length, args, new ScspHeaders());
                  uuid = wcResponse.getResponseHeaders().getHeaderValues("Content-UUID").get(0);               
              }
              checkPoint = checkPoint + uuid + mutable + "\r\n";
            }
            System.out.println("Writing checkpoint: " + checkPoint);
            ScspQueryArgs args = new ScspQueryArgs();
            ByteArrayInputStream cpStream = new ByteArrayInputStream(checkPoint.getBytes());
            // Note that this is a local checkpoint stream
            ScspResponse wcResponse = client.write("", cpStream, checkPoint.getBytes().length, args, new ScspHeaders());
            String uuid = wcResponse.getResponseHeaders().getHeaderValues("Content-UUID").get(0);
           
            System.out.println(">>>>>> Aggregate Info <<<<<<<<");
            ScspResponse aiResponse = client.aggregateInfo("", rcn + "/" + uuid, outputStream, args, new ScspHeaders());
            System.out.println(aiResponse.toString());
            System.out.println(outputStream.toString());
        }
        catch (Exception ex)
        {
            ex.printStackTrace();
View Full Code Here

        {
            System.out.println(">>>>>> Write <<<<<<<<");
            ScspQueryArgs rswArgs = new ScspQueryArgs();
            rswArgs.setValue("replicate","immediate"); //adds the required '?replicate=immediate' query argument
            ScspQueryArgs args = new ScspQueryArgs();
            ScspResponse wcResponse = client.writeMutable(rcn, inputStream, testData.getBytes().length, rswArgs, new ScspHeaders()); //writes a mutable object to the local and remote clusters
            String uuid = wcResponse.getResponseHeaders().getHeaderValues("Content-UUID").get(0);
            System.out.println(wcResponse.toString());

            //Updates the mutable object in the remote cluster
            System.out.println(">>>>>> Update <<<<<<<<");
            ScspResponse ucResponse = client.updateMutable("", rcn + "/" + uuid, updateStream, testUpdateData.getBytes().length, rswArgs, new ScspHeaders());
            uuid = ucResponse.getResponseHeaders().getHeaderValues("Content-UUID").get(0);
            System.out.println(ucResponse.toString());

            //Copies metadata to the mutable object in the remote cluster
            System.out.println(">>>>>> Copy (Remote) <<<<<<<<");
            ScspHeaders headers = new ScspHeaders();
            headers.addValue("Castor-color", "blue");
            ScspResponse ccResponse = client.copyMutable("", rcn + "/" + uuid, rswArgs, headers);
            uuid = ccResponse.getResponseHeaders().getHeaderValues("Content-UUID").get(0);
            System.out.println(ccResponse.toString());

            //Reads the mutable object directly from the remote cluster
            System.out.println(">>>>>> Read Remote <<<<<<<<");
            ScspResponse rcResponse = client.readMutable("", rcn + "/" + uuid, outputStream, args, new ScspHeaders());
            System.out.println(rcResponse.toString());
            System.out.println("Body Received");
            System.out.println(outputStream.toString());

            //Reads the mutable object directly from the local cluster
            System.out.println(">>>>>> Read Local<<<<<<<<");
            outputStream.reset();
            ScspResponse lrcResponse = localClient.readMutable("", uuid, outputStream, args, new ScspHeaders());
            System.out.println(lrcResponse.toString());
            System.out.println("Body Received");
            System.out.println(outputStream.toString());

            //Reads the mutable object from the local cluster using the Proxy
            System.out.println(">>>>>> Read Proxy Local<<<<<<<<");
            outputStream.reset();
            ScspResponse prcResponse = client.readMutable("", uuid, outputStream, args, new ScspHeaders());
            System.out.println(prcResponse.toString());
            System.out.println("Body Received");
            System.out.println(outputStream.toString());

            //Infos the mutable object in the remote cluster
            System.out.println(">>>>>> Info (Remote) <<<<<<<<");
            ScspResponse icResponse = client.infoMutable("", uuid, args, new ScspHeaders());
            System.out.println(icResponse.toString());

            //Deletes the object in the remote cluster
            System.out.println(">>>>>> Delete <<<<<<<<");
            ScspResponse dcResponse = client.deleteMutable("", uuid, args, new ScspHeaders());
            System.out.println(dcResponse.toString());
        }
        catch (Exception ex)
        {
            ex.printStackTrace();
        }
View Full Code Here

      String rcn = "_proxy/drcluster";
        String testData = "Hello world";
        ByteArrayInputStream inputStream = new ByteArrayInputStream(testData.getBytes());
        try
        {
            ScspResponse wcResponse = proxyClient.write("", inputStream, testData.getBytes().length, new ScspQueryArgs(), new ScspHeaders());
            if (wcResponse.getResultCode() == ScspResponse.ScspResultCode.ScspRCFailure) {
              System.out.println("Unabled to write to proxy.");
              res = false;
            }
            else {
              wcResponse = proxyClient.write(rcn, inputStream, testData.getBytes().length, new ScspQueryArgs(), new ScspHeaders());
              if (wcResponse.getResultCode() == ScspResponse.ScspResultCode.ScspRCFailure) {
                  System.out.println("Unabled to write to remote cluster.");
                res = false;
              }
            }
        }
View Full Code Here

        // InputStream - this can be empty but the write method does not accept a null argument
        String emptyString = "";
        ByteArrayInputStream bais = new ByteArrayInputStream(emptyString.getBytes());
       
        // Do the POST
        ScspResponse response = this.scspClient.write(this.channelName, bais, 0L, startScspQueryArgs, headers);
       
        // Check the response code
        if (response.getHttpStatusCode() != 201) {
          throw new ObjectEnumeratorException("Object Enumerator start returned unexpected response code: " + response.getHttpStatusCode()
              + "\nResponse body: " + response.getResponseBody());
        }
       
        // Set the UUID of this Object Enumerator
        if (response.getResponseHeaders().getHeaderValues(ObjectEnumerator.CONTENT_UUID).get(0).toString().length() > 0) {
          this.enumUuid = response.getResponseHeaders().getHeaderValues(ObjectEnumerator.CONTENT_UUID).get(0).toString();
        }
        else {
          throw new ObjectEnumeratorException("Object enumerator start did not return a UUID for the enumerator."
              + "\nResponse headers: " + response.getResponseHeaders().getHeaderMap().toString());
        }
       
        return new EnumeratorResponse(response, this.enumType, EnumeratorAction.ENUM_ACTION_START);
     
    }
View Full Code Here

      // Empty ScspHeaders object for GET (read) method
      ScspHeaders headers = new ScspHeaders();
     
      // Do the GET
      // According to Pat the null arguments should work here.
      ScspResponse response = this.scspClient.read(this.enumUuid.toString(), null, null, nextScspQueryArgs, headers);
     
      if (response.getHttpStatusCode() != 200){       
        if (response.getHttpStatusCode() == 404) {        
          throw new ObjectEnumeratorException("Object Enumerator next did not find enumerator with this UUID: " + this.enumUuid.toString());
        }
        else {         
          throw new ObjectEnumeratorException("Object Enumerator next returned an unexpected response code: " + response.getHttpStatusCode()
              + "\nResponse body: " + response.getResponseBody());
        }
      }
     
      return new EnumeratorResponse(response, this.getType(), EnumeratorAction.ENUM_ACTION_NEXT);
   
View Full Code Here

TOP

Related Classes of com.caringo.client.ScspResponse

Copyright © 2018 www.massapicom. All rights reserved.
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.