Examples of readObject()

Examples of com.google.gwt.rpc.server.CommandServerSerializationStreamReader.readObject()

44
45
46
47
48
49
50
51
52
53
54
    }
    CommandServerSerializationStreamReader reader = new CommandServerSerializationStreamReader();
    if (decoder.getThrownValue() != null) {
      reader.prepareToRead(Collections.singletonList(decoder.getThrownValue()));
      try {
        throw new RemoteException((Throwable) reader.readObject());
      } catch (ClassCastException e) {
        throw new RemoteException(
            "The remote end threw something other than a Throwable", e);
      } catch (SerializationException e) {
        throw new RemoteException(
View Full Code Here

Examples of com.google.gwt.user.client.rpc.SerializationStreamReader.readObject()

94
95
96
97
98
99
100
101
102
103
104
      }
    }
    else if (getMode() == SerialMode.DE_RPC) {
      try {
        SerializationStreamReader reader = ClientWriterFactory.createReader(message);
        return (T) reader.readObject();
      }
      catch (RuntimeException e) {
        throw new SerializationException(e);
      }
    } else if (getMode() == SerialMode.PLAIN) {
View Full Code Here

Examples of com.google.gwt.user.client.rpc.impl.ClientSerializationStreamReader.readObject()

85
86
87
88
89
90
91
92
93
94
95
    if (getMode() == SerialMode.RPC) {
      try {
        Serializer serializer = getSerializer();
        ClientSerializationStreamReader reader = new ClientSerializationStreamReader(serializer);
        reader.prepareToRead(message);
        return (T) reader.readObject();
      }
      catch (RuntimeException e) {
        throw new SerializationException(e);
      }
    }
View Full Code Here

Examples of com.google.gwt.user.server.rpc.impl.ServerSerializationStreamReader.readObject()

276
277
278
279
280
281
282
283
284
285
286
    protected Serializable deserialize(String data) {
        try {
            ServerSerializationStreamReader reader = new ServerSerializationStreamReader(getClass().getClassLoader(), cometSerializationPolicyProvider);
            reader.prepareToRead(data);
            return (Serializable) reader.readObject();
        } catch (SerializationException ex) {
            logger.error("Failed to deserialize message", ex);
            return null;
        }
    }
View Full Code Here

Examples of com.hazelcast.nio.BufferObjectDataInput.readObject()

151
152
153
154
155
156
157
158
159
160
161
                            + Packet.VERSION + ", Incoming -> " + packetVersion
                            + ", Sender -> " + datagramPacketReceive.getAddress());
                    return null;
                }
                try {
                    return input.readObject();
                } finally {
                    input.close();
                }
            } catch (Exception e) {
                if (e instanceof EOFException || e instanceof HazelcastSerializationException) {
View Full Code Here

Examples of com.hazelcast.nio.ObjectDataInput.readObject()

113
114
115
116
117
118
119
120
121
122
123
        for (int i = 0; i < size; i++) {
            Data key = new Data();
            key.readData(input);
            keys.add(key);
        }
        processor = input.readObject();
    }

    @Override
    public Permission getRequiredPermission() {
        return new MapPermission(name, ActionConstants.ACTION_PUT, ActionConstants.ACTION_REMOVE);
View Full Code Here

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

70
71
72
73
74
75
76
77
78
79
80
                logApplyReplicaSync(partitionId, replicaIndex);
                byte[] taskData = compressed ? IOUtil.decompress(data) : data;
                in = serializationService.createObjectDataInput(taskData);
                int size = in.readInt();
                for (int i = 0; i < size; i++) {
                    Operation op = (Operation) serializationService.readObject(in);
                    try {
                        ErrorLoggingResponseHandler responseHandler
                                = new ErrorLoggingResponseHandler(nodeEngine.getLogger(op.getClass()));
                        op.setNodeEngine(nodeEngine)
                                .setPartitionId(partitionId)
View Full Code Here

Examples of com.higherfrequencytrading.chronicle.Excerpt.readObject()

293
294
295
296
297
298
299
300
301
302
303
            excerpt.writeObject(BigDecimal.valueOf(i % 1000));
            excerpt.finish();
        }
        for (int i = 0; i < objects; i++) {
            assertTrue(excerpt.index(i));
            BigDecimal bd = (BigDecimal) excerpt.readObject();
            assertEquals(i % 1000, bd.longValue());
            excerpt.finish();
        }
//        System.out.println("waiting");
//        Thread.sleep(20000);
View Full Code Here

Examples of com.impossibl.postgres.api.jdbc.PGSQLInput.readObject()

70
71
72
73
74
75
76
77
78
79
80
    @Override
    public void readSQL(SQLInput stream, String typeName) throws SQLException {
      PGSQLInput in = (PGSQLInput) stream;
      str = in.readString();
      str2 = in.readString();
      id = (UUID) in.readObject();
      num = in.readDouble();
    }

    @Override
    public void writeSQL(SQLOutput stream) throws SQLException {
View Full Code Here

Examples of com.liferay.portal.kernel.util.ClassLoaderObjectInputStream.readObject()

279
280
281
282
283
284
285
286
287
288
289
        ClassLoader contextClassLoader = currentThread.getContextClassLoader();

        ObjectInputStream objectInputStream = new ClassLoaderObjectInputStream(unsyncByteArrayInputStream,
            contextClassLoader);

        throwable = (Throwable)objectInputStream.readObject();

        objectInputStream.close();

        return throwable;
      }
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.