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 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(io.micronaut.json.JsonMapper jsonMapper, Class<T> pojo)
JacksonJsonReader(com.fasterxml.jackson.databind.ObjectMapper objectMapper, Class<T> pojo) Deprecated. Use JacksonJsonReader(JsonMapper, Class) instead

Method Summary

Modifier and Type	Method and Description
T	read(byte[] bytes, int offset, int length)
T	read(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

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

Deprecated. Use JacksonJsonReader(JsonMapper, Class) instead

Parameters:

objectMapper - The jackson object mapper to use for reading

pojo - The pojo type to read

JacksonJsonReader

public JacksonJsonReader(io.micronaut.json.JsonMapper jsonMapper,
                         Class<T> pojo)

Parameters:

jsonMapper - The json mapper to use for reading

pojo - The pojo type to read

Since:

1.1.0

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(InputStream inputStream)

Specified by:

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