io.micronaut.pulsar.processor

Class SchemaResolver

java.lang.Object

io.micronaut.pulsar.processor.SchemaResolver

@Singleton
public class SchemaResolver
extends java.lang.Object

Message type resolver for Pulsar schema. Uses customised Schema for JSON; otherwise falls back to the ones from Apache Pulsar Java library.

Since:

1.0

Author:

Haris Secic

Constructor Summary

Constructors

Constructor and Description
SchemaResolver(com.fasterxml.jackson.databind.ObjectMapper objectMapper)

Method Summary

Modifier and Type	Method and Description
org.apache.pulsar.client.api.Schema<?>	decideSchema(io.micronaut.core.annotation.AnnotationValue<?> topicAnnotation, java.lang.Class<?> messageBodyType) Resolve which schema to use.

Methods inherited from class java.lang.Object

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

Constructor Detail

SchemaResolver

public SchemaResolver(com.fasterxml.jackson.databind.ObjectMapper objectMapper)

Method Detail

decideSchema

public org.apache.pulsar.client.api.Schema<?> decideSchema(io.micronaut.core.annotation.AnnotationValue<?> topicAnnotation,
                                                           java.lang.Class<?> messageBodyType)

Resolve which schema to use.

Parameters:

topicAnnotation - either producer or consumer annotation

messageBodyType - type of message body used with Pulsar topic

Returns:

new Schema