Package io.micronaut.pulsar.schemas.json

Class JsonSchemaResolver

java.lang.Object

io.micronaut.pulsar.schemas.json.JsonSchemaResolver

All Implemented Interfaces:

SchemaResolver

@Singleton
@Named("JSON_SCHEMA_RESOLVER")
@Requires(classes=io.micronaut.json.JsonMapper.class)
public class JsonSchemaResolver
extends Object
implements SchemaResolver

JSON schema resolver.

Since:

1.1.0

Author:

Haris Secic

Field Summary

Fields inherited from interface io.micronaut.pulsar.schemas.SchemaResolver

AVRO_SCHEMA_NAME, JSON_SCHEMA_NAME, PROTOBUF_SCHEMA_NAME

Constructor Summary

Constructors

Constructor	Description
JsonSchemaResolver(io.micronaut.json.JsonMapper mapper)

Method Summary

Modifier and Type	Method	Description
<T> org.apache.pulsar.client.api.Schema<T>	forArgument(Class<T> pojo)

Methods inherited from class java.lang.Object

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

Constructor Details

JsonSchemaResolver

public JsonSchemaResolver(io.micronaut.json.JsonMapper mapper)

Method Details

forArgument

public <T> org.apache.pulsar.client.api.Schema<T> forArgument(Class<T> pojo)

Specified by:

forArgument in interface SchemaResolver