io.micronaut.pulsar.schemas.json

Class JacksonJsonReader<T>

java.lang.Object

io.micronaut.pulsar.schemas.json.JacksonJsonReader<T>

Type Parameters:

T - POJO type to process.

All Implemented Interfaces:

org.apache.pulsar.client.api.schema.SchemaReader<T>

public final class JacksonJsonReader<T>
extends java.lang.Object
implements org.apache.pulsar.client.api.schema.SchemaReader<T>

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

Since:

1.0

Author:

Haris Secic

Constructor Summary

Constructors

Constructor and Description
JacksonJsonReader(com.fasterxml.jackson.databind.ObjectMapper objectMapper, java.lang.Class<T> pojo)

Method Summary

Modifier and Type	Method and Description
T	read(byte[] bytes, int offset, int length)
T	read(java.io.InputStream inputStream)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.pulsar.client.api.schema.SchemaReader

getNativeSchema, read, read, read, setSchemaInfoProvider

Constructor Detail

JacksonJsonReader

public JacksonJsonReader(com.fasterxml.jackson.databind.ObjectMapper objectMapper,
                         java.lang.Class<T> pojo)

Method Detail

read

public T read(byte[] bytes,
              int offset,
              int length)

Specified by:

read in interface org.apache.pulsar.client.api.schema.SchemaReader<T>

read

public T read(java.io.InputStream inputStream)

Specified by:

read in interface org.apache.pulsar.client.api.schema.SchemaReader<T>