Package io.micronaut.pulsar.schemas.protobuf

Class ProtobufSchemaResolver

java.lang.Object

io.micronaut.pulsar.schemas.protobuf.ProtobufSchemaResolver

All Implemented Interfaces:

SchemaResolver

@Singleton
@Named("PROTOBUF_SCHEMA_RESOLVER")
@Requires(classes=io.micronaut.protobuf.codec.ProtobufferCodec.class)
public class ProtobufSchemaResolver
extends Object
implements SchemaResolver

Protobuf 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
ProtobufSchemaResolver(io.micronaut.protobuf.codec.ProtobufferCodec codec)

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

ProtobufSchemaResolver

public ProtobufSchemaResolver(io.micronaut.protobuf.codec.ProtobufferCodec codec)

Method Details

forArgument

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

Specified by:

forArgument in interface SchemaResolver