Package io.quarkus.pulsar.schema

Class ObjectMapperSchema<T>

java.lang.Object
org.apache.pulsar.client.impl.schema.AbstractSchema<T>
io.quarkus.pulsar.schema.ObjectMapperSchema<T>
All Implemented Interfaces:
Cloneable, org.apache.pulsar.client.api.Schema<T>
public class ObjectMapperSchema<T> extends org.apache.pulsar.client.impl.schema.AbstractSchema<T>

  • Field Summary

    Fields inherited from interface org.apache.pulsar.client.api.Schema

    BOOL, BYTEBUFFER, BYTES, DATE, DOUBLE, FLOAT, INSTANT, INT16, INT32, INT64, INT8, LOCAL_DATE, LOCAL_DATE_TIME, LOCAL_TIME, STRING, TIME, TIMESTAMP

  • Constructor Summary

    Constructors
    Constructor
    Description
    ObjectMapperSchema(com.fasterxml.jackson.core.type.TypeReference<T> typeReference, com.fasterxml.jackson.databind.ObjectMapper objectMapper)
     
    ObjectMapperSchema(com.fasterxml.jackson.core.type.TypeReference<T> typeReference, com.fasterxml.jackson.databind.ObjectMapper objectMapper, boolean nullAsNull)
     
    ObjectMapperSchema(com.fasterxml.jackson.databind.JavaType javaType, com.fasterxml.jackson.databind.ObjectMapper objectMapper, boolean nullAsNull)
     
    ObjectMapperSchema(Class<T> type)
     
    ObjectMapperSchema(Class<T> type, boolean nullAsNull)
     
    ObjectMapperSchema(Class<T> type, com.fasterxml.jackson.databind.ObjectMapper objectMapper)
     
    ObjectMapperSchema(Class<T> type, com.fasterxml.jackson.databind.ObjectMapper objectMapper, boolean nullAsNull)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    T
    decode(io.netty.buffer.ByteBuf byteBuf)
     
    byte[]
    encode(T message)
     
    org.apache.pulsar.common.schema.SchemaInfo
    getSchemaInfo()
     
    static <T> ObjectMapperSchema<T>
    of(Class<T> type)
     

    Methods inherited from class org.apache.pulsar.client.impl.schema.AbstractSchema

    atSchemaVersion, clone, decode

    Methods inherited from class java.lang.Object

    equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    Methods inherited from interface org.apache.pulsar.client.api.Schema

    configureSchemaInfo, decode, decode, decode, decode, getNativeSchema, requireFetchingSchemaInfo, setSchemaInfoProvider, supportSchemaVersioning, validate

  • Constructor Details

    • ObjectMapperSchema

      public ObjectMapperSchema(Class<T> type)

    • ObjectMapperSchema

      public ObjectMapperSchema(Class<T> type, boolean nullAsNull)

    • ObjectMapperSchema

      public ObjectMapperSchema(Class<T> type, com.fasterxml.jackson.databind.ObjectMapper objectMapper)

    • ObjectMapperSchema

      public ObjectMapperSchema(Class<T> type, com.fasterxml.jackson.databind.ObjectMapper objectMapper, boolean nullAsNull)

    • ObjectMapperSchema

      public ObjectMapperSchema(com.fasterxml.jackson.core.type.TypeReference<T> typeReference, com.fasterxml.jackson.databind.ObjectMapper objectMapper)

    • ObjectMapperSchema

      public ObjectMapperSchema(com.fasterxml.jackson.core.type.TypeReference<T> typeReference, com.fasterxml.jackson.databind.ObjectMapper objectMapper, boolean nullAsNull)

    • ObjectMapperSchema

      public ObjectMapperSchema(com.fasterxml.jackson.databind.JavaType javaType, com.fasterxml.jackson.databind.ObjectMapper objectMapper, boolean nullAsNull)

  • Method Details

    • of

      public static <T> ObjectMapperSchema<T> of(Class<T> type)

    • decode

      public T decode(io.netty.buffer.ByteBuf byteBuf)
      Specified by:
      decode in class org.apache.pulsar.client.impl.schema.AbstractSchema<T>

    • encode

      public byte[] encode(T message)

    • getSchemaInfo

      public org.apache.pulsar.common.schema.SchemaInfo getSchemaInfo()