Examples of readData()

Examples of org.apache.helix.manager.zk.ZkClient.readData()

250
251
252
253
254
255
256
257
258
259
260
    }
    catch (HelixException e)
    {
      // OK
    }
    ZNRecord recordNew = zkClient.readData(path1);
    byte[] arr = serializer.serialize(record);
    byte[] arrNew = serializer.serialize(recordNew);
    Assert.assertTrue(Arrays.equals(arr, arrNew));

    // test ZkDataAccessor
View Full Code Here

Examples of org.apache.helix.manager.zk.ZkClient.readData()

43
44
45
46
47
48
49
50
51
52
53
    String zkAddr = "localhost:2187";
    ZkServer zkServer = TestHelper.startZkSever(zkAddr);
    ZkClient zkClient = ZKClientPool.getZkClient(zkAddr);
   
    zkClient.createPersistent("/" + testName, new ZNRecord(testName));
    ZNRecord record = zkClient.readData("/" + testName);
    Assert.assertEquals(record.getId(), testName);
   
    TestHelper.stopZkServer(zkServer);
   
    // restart zk
View Full Code Here

Examples of org.apache.helix.manager.zk.ZkClient.readData()

53
54
55
56
57
58
59
60
61
62
63
    // restart zk
    zkServer = TestHelper.startZkSever(zkAddr);
    try
    {
      zkClient = ZKClientPool.getZkClient(zkAddr);
      record = zkClient.readData("/" + testName);
      Assert.fail("should fail on zk no node exception");
    } catch (ZkNoNodeException e)
    {
      // OK
    } catch (Exception e)
View Full Code Here

Examples of org.apache.helix.manager.zk.ZkClient.readData()

64
65
66
67
68
69
70
71
72
73
74
    {
      Assert.fail("should not fail on exception other than ZkNoNodeException");
    }
   
    zkClient.createPersistent("/" + testName, new ZNRecord(testName));
    record = zkClient.readData("/" + testName);
    Assert.assertEquals(record.getId(), testName);
   
    zkClient.close();
    TestHelper.stopZkServer(zkServer);
    System.out.println("END " + testName + " at " + new Date(System.currentTimeMillis()));
View Full Code Here

Examples of org.apache.qpidity.api.Message.readData()

38
39
40
41
42
43
44
45
46
47
48
    @Override
    public InputStream getInputStream(Object message)
    {
        Message msg = (Message)message;
        try{
            final ByteBuffer buf = msg.readData();
            return new InputStream() {
                public synchronized int read() throws IOException {
                    if (!buf.hasRemaining()) {
                        return -1;
                    }
View Full Code Here

Examples of org.apache.s4.comm.topology.ZkClient.readData()

72
73
74
75
76
77
78
79
80
81
82
        TestAutomaticDeployment.assertDeployment("http://localhost:8080/s4/" + s4rToDeploy.getName(), zkClient, false);

        // check resource loading (we use a zkclient without custom serializer)
        ZkClient client2 = new ZkClient("localhost:" + CommTestUtils.ZK_PORT);
        Assert.assertEquals("Salut!", client2.readData("/resourceData"));

    }

    @After
    public void cleanup() throws IOException, InterruptedException {
View Full Code Here

Examples of org.apache.sanselan.formats.psd.datareaders.DataReader.readData()

754
755
756
757
758
759
760
761
762
763
764
            InputStream is = null;

            try
            {
                is = getInputStream(byteSource, PSD_SECTION_IMAGE_DATA);
                fDataReader.readData(is, result, imageContents, this);

                fDataReader.dump();
                // is.
                // ImageContents imageContents = readImageContents(is);
                // return imageContents;
View Full Code Here

Examples of org.gephi.graph.dhns.utils.DataSerializer.readData()

48
49
50
51
52
53
54
55
56
57
58
    public void readXML(XMLStreamReader reader, Workspace workspace) {
        Dhns dhns = workspace.getLookup().lookup(Dhns.class);
        DataSerializer serializer = new DataSerializer();
        try {
            serializer.readData(reader, dhns);
        } catch (XMLStreamException ex) {
            throw new RuntimeException(ex);
        }
    }
View Full Code Here

Examples of org.glassfish.jersey.media.sse.InboundEvent.readData()

125
126
127
128
129
130
131
132
133
134
135
            public void run() {
                while (!eventInput.isClosed() && !res.isDone()) {
                    final InboundEvent inboundEvent = eventInput.read();
                    if (inboundEvent == null)
                        break;
                    res.set(inboundEvent.readData(String.class));
                }
            }
        }).start();
        client.target("http://localhost:8080/ssepublish").request().cookie(session).post(Entity.text("test it"));
        assertEquals("test it", res.get());
View Full Code Here

Examples of org.jboss.serial.persister.Persister.readData()

407
408
409
410
411
412
413
414
415
416
417
        /*ObjectDescription description = new ObjectDescription();
        description.setMetaData(ClassMetamodelFactory.getClassMetaData(reference.getClassName(),cache.getLoader(),false));
        cache.putObjectInCache(reference,description); */


        Object value = persister.readData(cache.getLoader(), streamingClass, metaData, reference, cache, cache.getInput(), cache.getSubstitution());

        if (!(persister instanceof ClassReferencePersister)) //JBSER-83
        {
          if (cache.getSubstitution()!=null)
          {
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. 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.