io.micronaut.pulsar.schemas.json

Class JsonSchemaResolver

java.lang.Object

io.micronaut.pulsar.schemas.json.JsonSchemaResolver

All Implemented Interfaces:

SchemaResolver

@Singleton
 @Named(value="JSON_SCHEMA_RESOLVER")
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

JSON_SCHEMA_NAME, PROTOBUF_SCHEMA_NAME

Constructor Summary

Constructors

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

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

JsonSchemaResolver

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

Method Detail

forArgument

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

Specified by:

forArgument in interface SchemaResolver