io.micronaut.pulsar.schemas

Class JsonSchema<T>

java.lang.Object

org.apache.pulsar.client.impl.schema.AbstractSchema<T>

org.apache.pulsar.client.impl.schema.AbstractStructSchema<T>

org.apache.pulsar.client.impl.schema.AvroBaseStructSchema<T>

io.micronaut.pulsar.schemas.JsonSchema<T>

Type Parameters:

T - POJO type to send and receive via Pulsar.

All Implemented Interfaces:

Cloneable, org.apache.pulsar.client.api.Schema<T>

public class JsonSchema<T>
extends org.apache.pulsar.client.impl.schema.AvroBaseStructSchema<T>

JSON Schema to allow using ObjectMapper from Micronaut instead of shaded one in Pulsar library.

Since:

1.0

Author:

Haris Secic

Field Summary

Fields inherited from class org.apache.pulsar.client.impl.schema.AvroBaseStructSchema

schema

Fields inherited from class org.apache.pulsar.client.impl.schema.AbstractStructSchema

LOG, reader, schemaInfo, schemaInfoProvider, writer

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 and Description
JsonSchema(org.apache.pulsar.common.schema.SchemaInfo schemaInfo, org.apache.pulsar.client.api.schema.SchemaReader<T> reader, org.apache.pulsar.client.api.schema.SchemaWriter<T> writer)

Method Summary

Modifier and Type	Method and Description
static <T> JsonSchema<T>	of(Class<T> pojo, io.micronaut.json.JsonMapper jsonMapper)
static <T> JsonSchema<T>	of(Class<T> pojo, com.fasterxml.jackson.databind.ObjectMapper objectMapper) Deprecated. Use of(Class, JsonMapper) instead

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

getAvroSchema, getNativeSchema

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

atSchemaVersion, decode, decode, decode, decode, encode, getReader, getSchemaInfo, setReader, setSchemaInfoProvider, setWriter

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

clone

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

AUTO_CONSUME, AUTO_PRODUCE_BYTES, AUTO_PRODUCE_BYTES, AUTO, AVRO, AVRO, configureSchemaInfo, decode, generic, getSchema, JSON, JSON, KeyValue, KeyValue, KeyValue, KeyValue, KV_BYTES, NATIVE_AVRO, PROTOBUF_NATIVE, PROTOBUF_NATIVE, PROTOBUF, PROTOBUF, requireFetchingSchemaInfo, supportSchemaVersioning, validate

Constructor Detail

JsonSchema

public JsonSchema(org.apache.pulsar.common.schema.SchemaInfo schemaInfo,
                  org.apache.pulsar.client.api.schema.SchemaReader<T> reader,
                  org.apache.pulsar.client.api.schema.SchemaWriter<T> writer)

Method Detail

of

@Deprecated
public static <T> JsonSchema<T> of(Class<T> pojo,
                                               com.fasterxml.jackson.databind.ObjectMapper objectMapper)

Deprecated. Use of(Class, JsonMapper) instead

Type Parameters:

T - The pojo class to map

Parameters:

pojo - The pojo class to map

objectMapper - The jackson object mapper to use for mapping

Returns:

The parsed json schema

of

public static <T> JsonSchema<T> of(Class<T> pojo,
                                   io.micronaut.json.JsonMapper jsonMapper)

Type Parameters:

T - The pojo class to map

Parameters:

pojo - The pojo class to map

jsonMapper - The json mapper to use for mapping

Returns:

The parsed json schema

Since:

1.1.0