remote-query/remote-query-client/src/main/java/org/infinispan/query/remote/client/MarshallerRegistration.java
/**
    * Registers proto files and marshallers.
    *
    * @param ctx the serialization context
    * @throws org.infinispan.protostream.DescriptorParserException if a proto definition file fails to parse correctly
    * @throws IOException if proto file registration fails
    */
Registers proto files and marshallers.
@param ctx the serialization context
@throws org.infinispan.protostream.DescriptorParserException if a proto definition file fails to parse correctly
@throws IOException if proto file registration fails
Registers proto files and marshallers . @param ctx the serialization context @throws org . infinispan . protostream . DescriptorParserException if a proto definition file fails to parse correctly @throws IOException if proto file registration fails
public static void registerMarshallers(SerializationContext ctx) throws IOException {
      FileDescriptorSource fileDescriptorSource = new FileDescriptorSource();
      fileDescriptorSource.addProtoFile(QUERY_PROTO_RES, MarshallerRegistration.class.getResourceAsStream(QUERY_PROTO_RES));
      fileDescriptorSource.addProtoFile(MESSAGE_PROTO_RES, MarshallerRegistration.class.getResourceAsStream(MESSAGE_PROTO_RES));
      ctx.registerProtoFiles(fileDescriptorSource);
      ctx.registerMarshaller(new QueryRequest.NamedParameter.Marshaller());
      ctx.registerMarshaller(new QueryRequest.Marshaller());
      ctx.registerMarshaller(new QueryResponse.Marshaller());
      ctx.registerMarshaller(new FilterResult.Marshaller());
      ctx.registerMarshaller(new ContinuousQueryResult.ResultType.Marshaller());
      ctx.registerMarshaller(new ContinuousQueryResult.Marshaller());
   }
public static void registerMarshallers ( SerializationContext ctx ) throws IOException { FileDescriptorSource fileDescriptorSource = new FileDescriptorSource ( ) ; fileDescriptorSource . addProtoFile ( QUERY_PROTO_RES , MarshallerRegistration . class . getResourceAsStream ( QUERY_PROTO_RES ) ) ; fileDescriptorSource . addProtoFile ( MESSAGE_PROTO_RES , MarshallerRegistration . class . getResourceAsStream ( MESSAGE_PROTO_RES ) ) ; ctx . registerProtoFiles ( fileDescriptorSource ) ; ctx . registerMarshaller ( new QueryRequest . NamedParameter . Marshaller ( ) ) ; ctx . registerMarshaller ( new QueryRequest . Marshaller ( ) ) ; ctx . registerMarshaller ( new QueryResponse . Marshaller ( ) ) ; ctx . registerMarshaller ( new FilterResult . Marshaller ( ) ) ; ctx . registerMarshaller ( new ContinuousQueryResult . ResultType . Marshaller ( ) ) ; ctx . registerMarshaller ( new ContinuousQueryResult . Marshaller ( ) ) ; }
Registers proto files and marshallers.
Registers proto files and marshallers .