io.micronaut.pulsar.schemas.protobuf

Class ProtobufSchemaResolver

java.lang.Object

io.micronaut.pulsar.schemas.protobuf.ProtobufSchemaResolver

All Implemented Interfaces:

SchemaResolver

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

JSON_SCHEMA_NAME, PROTOBUF_SCHEMA_NAME

Constructor Summary

Constructors

Constructor and Description
ProtobufSchemaResolver(io.micronaut.protobuf.codec.ProtobufferCodec codec)

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

ProtobufSchemaResolver

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

Method Detail

forArgument

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

Specified by:

forArgument in interface SchemaResolver