Package io.micronaut.pulsar.schemas.avro

Class AvroSchemaResolver

java.lang.Object

io.micronaut.pulsar.schemas.avro.AvroSchemaResolver

All Implemented Interfaces:

SchemaResolver

@Singleton
@Named("AVRO_SCHEMA_RESOLVER")
public final class AvroSchemaResolver
extends Object
implements SchemaResolver

AVRO schema resolver.

Since:

1.2.1

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
AvroSchemaResolver()

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

AvroSchemaResolver

public AvroSchemaResolver()

Method Details

forArgument

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

Specified by:

forArgument in interface SchemaResolver