Package com.caringo.client

Examples of com.caringo.client.ScspHeaders


          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)
        {
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

        }
       
        public InetSocketAddress[] discoverNodes() {
            StaticLocator subLocator = new StaticLocator();
            HttpClient httpCli = new HttpClient();
            ScspHeaders metaData = new ScspHeaders();
           
            subLocator.addAddress(proxyAddr, proxyPort);
           
            if (0 < clusterName.length()) {
                metaData.addValue("Scsp-Proxy-Cluster", clusterName);
            }

            ScspRequestHandler client = new ScspRequestHandler(httpCli, new LocatorRedirectHandler(subLocator), 3, 300, null);
            BasicScspResponseOutputStream output = new BasicScspResponseOutputStream(null);
View Full Code Here

          this.startScspQueryArgs.setValue(EnumeratorQueryArgs.TYPE.getName(), this.enumType.getName());
        }
      }
     
        // Empty headers for POST (write) method
        ScspHeaders headers = new ScspHeaders();
        // InputStream - this can be empty but the write method does not accept a null argument
        String emptyString = "";
        ByteArrayInputStream bais = new ByteArrayInputStream(emptyString.getBytes());
       
View Full Code Here

TOP

Related Classes of com.caringo.client.ScspHeaders

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.