Package io.quarkus.pulsar

Class SchemaProviderRecorder

java.lang.Object

io.quarkus.pulsar.SchemaProviderRecorder

public class SchemaProviderRecorder
extends Object

Constructor Summary

Constructors

Constructor	Description
SchemaProviderRecorder()

Method Summary

Modifier and Type	Method	Description
<T> Supplier<org.apache.pulsar.client.api.Schema<T>>	createAvroSchema(Class<T> type)
io.quarkus.runtime.RuntimeValue<org.apache.pulsar.client.api.Schema<io.vertx.core.buffer.Buffer>>	createBufferSchema()
io.quarkus.runtime.RuntimeValue<org.apache.pulsar.client.api.Schema<ByteBuffer>>	createByteBufferSchema()
io.quarkus.runtime.RuntimeValue<org.apache.pulsar.client.api.Schema<io.vertx.core.json.JsonArray>>	createJsonArraySchema()
io.quarkus.runtime.RuntimeValue<org.apache.pulsar.client.api.Schema<io.vertx.core.json.JsonObject>>	createJsonObjectSchema()
<T> Supplier<org.apache.pulsar.client.api.Schema<T>>	createJsonSchema(Class<T> type)
<T> io.quarkus.runtime.RuntimeValue<org.apache.pulsar.client.api.Schema<T>>	createObjectMapperSchema(Class<T> type)
Supplier<org.apache.pulsar.client.api.Schema<?>>	createProtoBufSchema(Class<?> type)

Methods inherited from class java.lang.Object

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

Constructor Details

SchemaProviderRecorder

public SchemaProviderRecorder()

Method Details

createJsonSchema

public <T>
Supplier<org.apache.pulsar.client.api.Schema<T>> createJsonSchema(Class<T> type)

createAvroSchema

public <T>
Supplier<org.apache.pulsar.client.api.Schema<T>> createAvroSchema(Class<T> type)

createProtoBufSchema

public Supplier<org.apache.pulsar.client.api.Schema<?>> createProtoBufSchema(Class<?> type)

createObjectMapperSchema

public <T>
io.quarkus.runtime.RuntimeValue<org.apache.pulsar.client.api.Schema<T>> createObjectMapperSchema(Class<T> type)

createBufferSchema

public io.quarkus.runtime.RuntimeValue<org.apache.pulsar.client.api.Schema<io.vertx.core.buffer.Buffer>> createBufferSchema()

createJsonObjectSchema

public io.quarkus.runtime.RuntimeValue<org.apache.pulsar.client.api.Schema<io.vertx.core.json.JsonObject>> createJsonObjectSchema()

createJsonArraySchema

public io.quarkus.runtime.RuntimeValue<org.apache.pulsar.client.api.Schema<io.vertx.core.json.JsonArray>> createJsonArraySchema()

createByteBufferSchema

public io.quarkus.runtime.RuntimeValue<org.apache.pulsar.client.api.Schema<ByteBuffer>> createByteBufferSchema()