Package io.quarkus.pulsar.schema

Class JsonObjectSchema

java.lang.Object
org.apache.pulsar.client.impl.schema.AbstractSchema<io.vertx.core.json.JsonObject>
io.quarkus.pulsar.schema.JsonObjectSchema
All Implemented Interfaces:
Cloneable, org.apache.pulsar.client.api.Schema<io.vertx.core.json.JsonObject>
public class JsonObjectSchema extends org.apache.pulsar.client.impl.schema.AbstractSchema<io.vertx.core.json.JsonObject>

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    static final JsonObjectSchema
    INSTANCE
     

    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
    JsonObjectSchema()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    io.vertx.core.json.JsonObject
    decode(io.netty.buffer.ByteBuf byteBuf)
     
    byte[]
    encode(io.vertx.core.json.JsonObject message)
     
    org.apache.pulsar.common.schema.SchemaInfo
    getSchemaInfo()
     

    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

  • Field Details

  • Constructor Details

    • JsonObjectSchema

      public JsonObjectSchema()

  • Method Details

    • decode

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

    • encode

      public byte[] encode(io.vertx.core.json.JsonObject message)

    • getSchemaInfo

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