Şöyle yaparız
-Dhazelcast.socket.receive.buffer.size=10240 -Dhazelcast.socket.send.buffer.size=10240
import com.hazelcast.client.impl.clientside.ClientSchemaService;
replicateSchemaInCluster:140, ClientSchemaService (com.hazelcast.client.impl.clientside) put:85, ClientSchemaService (com.hazelcast.client.impl.clientside) putToSchemaService:137, CompactStreamSerializer (com.hazelcast.internal.serialization.impl.compact) writeObject:148, CompactStreamSerializer (com.hazelcast.internal.serialization.impl.compact) write:116, CompactStreamSerializer (com.hazelcast.internal.serialization.impl.compact) write:109, CompactStreamSerializer (com.hazelcast.internal.serialization.impl.compact) write:39, StreamSerializerAdapter (com.hazelcast.internal.serialization.impl) toBytes:238, AbstractSerializationService (com.hazelcast.internal.serialization.impl) toBytes:217, AbstractSerializationService (com.hazelcast.internal.serialization.impl) toData:202, AbstractSerializationService (com.hazelcast.internal.serialization.impl) toData:157, AbstractSerializationService (com.hazelcast.internal.serialization.impl) toData:76, ClientProxy (com.hazelcast.client.impl.spi) putInternal:553, ClientMapProxy (com.hazelcast.client.impl.proxy) put:275, ClientMapProxy (com.hazelcast.client.impl.proxy)
import com.hazelcast.internal.serialization.impl.compact.SchemaService;
import com.hazelcast.nio.serialization.compact.CompactSerializer; import com.hazelcast.nio.serialization.compact.CompactReader; import com.hazelcast.nio.serialization.compact.CompactWriter;
public class Employee {...}public class EmployeeSerializer implements CompactSerializer<Employee> {@Overridepublic Employee read(CompactReader reader) {long id = reader.readInt64("id");String name = reader.readString("name");return new Employee(id, name);}@Overridepublic void write(CompactWriter writer, Employee employee) {writer.writeInt64("id", employee.getId());writer.writeString("name", employee.getName());}@Overridepublic Class<Employee> getCompactClass() {return Employee.class;}@Overridepublic String getTypeName() {return "employee";}}Config config = new Config();config.getSerializationConfig().getCompactSerializationConfig().addSerializer(new EmployeeSerializer());
write:16, MyWorkerSerializer (com.colak.serilization.compact.serializerconfiguration) write:7, MyWorkerSerializer (com.colak.serilization.compact.serializerconfiguration) buildSchema:396, CompactStreamSerializer (com.hazelcast.internal.serialization.impl.compact) writeObject:147, CompactStreamSerializer (com.hazelcast.internal.serialization.impl.compact) write:116, CompactStreamSerializer (com.hazelcast.internal.serialization.impl.compact) write:109, CompactStreamSerializer (com.hazelcast.internal.serialization.impl.compact) write:39, StreamSerializerAdapter (com.hazelcast.internal.serialization.impl) toBytes:238, AbstractSerializationService (com.hazelcast.internal.serialization.impl) toBytes:217, AbstractSerializationService (com.hazelcast.internal.serialization.impl) toData:202, AbstractSerializationService (com.hazelcast.internal.serialization.impl) toData:157, AbstractSerializationService (com.hazelcast.internal.serialization.impl) toData:76, ClientProxy (com.hazelcast.client.impl.spi) putInternal:553, ClientMapProxy (com.hazelcast.client.impl.proxy) put:275, ClientMapProxy (com.hazelcast.client.impl.proxy)
Kullanılan harici kütüphanelerin sürümleri bu dosyada Dosyanın yolu şöyle hazelcast/licenses/THIRD-PARTY.txt