Examples of toData()

Examples of com.hazelcast.nio.serialization.SerializationService.toData()

35
36
37
38
39
40
41
42
43
44
45
        List<Data> dataArrayList = new ArrayList<Data>(distributedObjects.size());
        for (DistributedObject distributedObject : distributedObjects) {
            DistributedObjectInfo distributedObjectInfo = new DistributedObjectInfo(
                    distributedObject.getServiceName(), distributedObject.getName());
            Data data = serializationService.toData(distributedObjectInfo);
            dataArrayList.add(data);
        }
        SerializableCollection collection = new SerializableCollection(dataArrayList);
        endpoint.sendResponse(collection, getCallId());
    }
View Full Code Here

Examples of com.hazelcast.nio.serialization.SerializationService.toData()

82
83
84
85
86
87
88
89
90
91
92
        final Collection<MemberImpl> memberList = service.getMemberList();
        final Collection<Data> response = new ArrayList<Data>(memberList.size());
        final SerializationService serializationService = getClientEngine().getSerializationService();
        for (MemberImpl member : memberList) {
            response.add(serializationService.toData(member));
        }
        return new SerializableCollection(response);
    }

    public String getServiceName() {
View Full Code Here

Examples of com.hazelcast.nio.serialization.SerializationService.toData()

532
533
534
535
536
537
538
539
540
541
542
        throw new AuthenticationException();
    }

    public Object sendAndReceive(ClientRequest request, ClientConnection connection) throws Exception {
        final SerializationService ss = client.getSerializationService();
        connection.write(ss.toData(request));
        final Data data = connection.read();
        ClientResponse clientResponse = ss.toObject(data);
        Object response = ss.toObject(clientResponse.getResponse());
        if (response instanceof Throwable) {
            Throwable t = (Throwable) response;
View Full Code Here

Examples of com.hazelcast.nio.serialization.SerializationService.toData()

168
169
170
171
172
173
174
175
176
177
178
    private void _send(ClientCallFuture future, ClientConnection connection) {
        connection.registerCallId(future);
        future.setConnection(connection);
        final SerializationService ss = client.getSerializationService();
        final Data data = ss.toData(future.getRequest());
        if (!connection.write(new DataAdapter(data))) {
            final int callId = future.getRequest().getCallId();
            connection.deRegisterCallId(callId);
            connection.deRegisterEventHandler(callId);
            future.notify(new TargetNotMemberException("Address : " + connection.getRemoteEndpoint()));
View Full Code Here

Examples of com.hazelcast.spi.NodeEngine.toData()

40
41
42
43
44
45
46
47
48
49
        response = input;
        //noinspection unchecked
        Object output = f.apply(input);
        shouldBackup = !isEquals(input, output);
        if (shouldBackup) {
            backup = nodeEngine.toData(output);
            reference.set(backup);
        }
    }
}
View Full Code Here

Examples of com.hazelcast.spi.NodeEngine.toData()

46
47
48
49
50
51
52
53
54
55
56
        ReferenceWrapper reference = getReference();

        Object input = nodeEngine.toObject(reference.get());
        //noinspection unchecked
        Object output = f.apply(input);
        returnValue = nodeEngine.toData(output);
    }

    @Override
    public Object getResponse() {
        return returnValue;
View Full Code Here

Examples of com.hazelcast.spi.NodeEngine.toData()

38
39
40
41
42
43
44
45
46
47
        Object input = nodeEngine.toObject(reference.get());
        //noinspection unchecked
        Object output = f.apply(input);
        shouldBackup = true;
        backup = nodeEngine.toData(output);
        reference.set(backup);
        response = output;
    }
}
View Full Code Here

Examples of com.hazelcast.spi.NodeEngine.toData()

39
40
41
42
43
44
45
46
47
48
49
        Object input = nodeEngine.toObject(reference.get());
        //noinspection unchecked
        Object output = f.apply(input);
        shouldBackup = !isEquals(input, output);
        if (shouldBackup) {
            backup = nodeEngine.toData(output);
            reference.set(backup);
        }
    }
}
View Full Code Here

Examples of com.hazelcast.spi.NodeEngine.toData()

60
61
62
63
64
65
66
67
68
69
70
        offer(e, -1, TimeUnit.MILLISECONDS);
    }

    public boolean offer(E e, long timeout, TimeUnit timeUnit) throws InterruptedException {
        final NodeEngine nodeEngine = getNodeEngine();
        final Data data = nodeEngine.toData(e);
        return offerInternal(data, timeUnit.toMillis(timeout));
    }

    public E take() throws InterruptedException {
        return poll(-1, TimeUnit.MILLISECONDS);
View Full Code Here

Examples of com.hazelcast.spi.NodeEngine.toData()

80
81
82
83
84
85
86
87
88
89
90
        return config.getMaxSize() - size();
    }

    public boolean remove(Object o) {
        final NodeEngine nodeEngine = getNodeEngine();
        final Data data = nodeEngine.toData(o);
        return removeInternal(data);
    }

    public boolean contains(Object o) {
        final NodeEngine nodeEngine = getNodeEngine();
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.