Package org.springframework.pulsar.core

Class JSONSchemaUtil.CustomJacksonJsonReader<T>

java.lang.Object

org.springframework.pulsar.core.JSONSchemaUtil.CustomJacksonJsonReader<T>

Type Parameters:

T - object type to read

All Implemented Interfaces:

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

Enclosing interface:

JSONSchemaUtil

public static class JSONSchemaUtil.CustomJacksonJsonReader<T>
extends Object
implements org.apache.pulsar.client.api.schema.SchemaReader<T>

Reader implementation for reading objects from JSON using a custom ObjectMapper.

Method Summary

Modifier and Type	Method	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

Method Details

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>