Package io.quarkus.pulsar.schema

Class BufferSchema

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

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    static final BufferSchema
    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
    BufferSchema()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    io.vertx.core.buffer.Buffer
    decode(io.netty.buffer.ByteBuf byteBuf)
     
    byte[]
    encode(io.vertx.core.buffer.Buffer 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

    • BufferSchema

      public BufferSchema()

  • Method Details

    • decode

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

    • encode

      public byte[] encode(io.vertx.core.buffer.Buffer message)

    • getSchemaInfo

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