How to Register Marshaller and Schema for pojo containing LinkedHashMap<String,Object>
Hello Team,
I am using infinispan server 8.2.4.
I need to store the data into RemoteCache<String, Employee> where Employee class contains one instance variable i.e LinkedHashMap<String, InnerEmployee > pair = new LinkedHashMap<String,InnerEmployee>();
I have created .proto file for the same and registered using ctx.registerProtoFiles().
But I am facing difficulty while registering marshallers for linkedHashMap I can not use writer.writeCollection().
How to register this marshaller containing LinkedHashMap ?
1] createRemoteCacheManager :
public RemoteCacheManager createRemoteCacheManager(String remoteAddress) throws TransportException{
RemoteCacheManager remoteCacheManager = null;
try {
ConfigurationBuilder clientBuilder = new ConfigurationBuilder();
Properties properties = getConfigurationProperties();
properties.put("infinispan.client.hotrod.server_list", remoteAddress + ":11222");
clientBuilder.connectionPool().withProperties(properties);
clientBuilder.marshaller(new ProtoStreamMarshaller());
remoteCacheManager = new RemoteCacheManager(clientBuilder.build());
registerSchemasAndMarshallers(remoteCacheManager);
}catch (TransportException exception) {
LOG.error("TransportException in createRemoteCacheManager : " + exception.getMessage());
throw new TransportException("TransportException",new InetSocketAddress(11222));
}catch (Exception exception) {
LOG.error("Exception in createRemoteCacheManager : " + exception.getMessage());
}
return remoteCacheManager;
}
2] registerSchemasAndMarshallers :
private void registerSchemasAndMarshallers(RemoteCacheManager remoteCacheManager) throws IOException {
SerializationContext ctx = ProtoStreamMarshaller.getSerializationContext(remoteCacheManager);
ctx.registerProtoFiles(FileDescriptorSource.fromResources(InfinispanConstant.EMPLOYEE_RESOURCE));
ctx.registerMarshaller(new EmployeeMarshaller());
ctx.registerMarshaller(new InnerEmployeeMarshaller());
// Register the schemas with the server too
RemoteCache<String, String> metadataCache = remoteCacheManager.getCache(ProtobufMetadataManagerConstants.PROTOBUF_METADATA_CACHE_NAME);
metadataCache.put(InfinispanConstant.EMPLOYEE_RESOURCE, readResource(InfinispanConstant.EMPLOYEE_RESOURCE));
String errors = metadataCache.get(ProtobufMetadataManagerConstants.ERRORS_KEY_SUFFIX);
if (errors != null) {
throw new IllegalStateException("Some Protobuf schema files contain errors:\n" + errors);
}
}
3] Employee.java
import java.util.LinkedHashMap;
public class Employee {
private LinkedHashMap<String, InnerEmployee> pair;
public Employee() {
this.pair = new LinkedHashMap<String, Employee.InnerEmployee>();
}
public LinkedHashMap<String, InnerEmployee> getPair() {
return pair;
}
public void setPair(LinkedHashMap<String, InnerEmployee> pair) {
this.pair = pair;
}
public class InnerEmployee {
private String empNo;
private String name;
private String dateOfBirth;
public String getEmpNo() {
return empNo;
}
public void setEmpNo(String empNo) {
this.empNo = empNo;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public String getDateOfBirth() {
return dateOfBirth;
}
public void setDateOfBirth(String dateOfBirth) {
this.dateOfBirth = dateOfBirth;
}
@Override
public String toString() {
return "Employee [empNo=" + empNo + ", name=" + name
+ ", dateOfBirth=" + dateOfBirth + "]";
}
}
}
4] EMPLOYEE_RESOURCE.proto
option java_package = "com.auruspay.infinispan.pojo";
option java_outer_classname = "Employee";
/*
@Indexed(true)
*/
message Employee {
repeated MapFieldEntry pairs = 1;
}
message MapFieldEntry {
optional string key = 1;
optional InnerEmployee value = 2;
}
message InnerEmployee {
optional string empNo = 1;
optional string name = 2;
optional string dateOfBirth = 3;
}
5] InnerEmployeeMarshaller.java
package com.auruspay.infinispan.marshaller;
import java.io.IOException;
import org.infinispan.protostream.MessageMarshaller;
import com.auruspay.infinispan.pojo.Employee;
public class InnerEmployeeMarshaller implements MessageMarshaller<Employee.InnerEmployee> {
@Override
public Class<? extends Employee.InnerEmployee> getJavaClass() {
return Employee.InnerEmployee.class;
}
@Override
public String getTypeName() {
return "com.auruspay.infinispan.proto.InnerEmployee";
}
@Override
public Employee.InnerEmployee readFrom(ProtoStreamReader reader) throws IOException {
Employee employee = new Employee();
Employee.InnerEmployee emp = employee. new InnerEmployee();
emp.setEmpNo(reader.readString("empNo"));
emp.setName(reader.readString("name"));
emp.setDateOfBirth(reader.readString("dateOfBirth"));
return emp;
}
@Override
public void writeTo(ProtoStreamWriter writer,Employee.InnerEmployee emp) throws IOException {
writer.writeString("empNo", emp.getEmpNo());
writer.writeString("name", emp.getName());
writer.writeString("dateOfBirth", emp.getDateOfBirth());
}
}
6] How EmployeeMarshaller should be designed ?
Thanks In Advance !!!
