Package io.micronaut.gcp.pubsub.serdes

Class DefaultPubSubMessageSerDesRegistry

java.lang.Object

io.micronaut.gcp.pubsub.serdes.DefaultPubSubMessageSerDesRegistry

All Implemented Interfaces:

PubSubMessageSerDesRegistry

@Singleton
public class DefaultPubSubMessageSerDesRegistry
extends Object
implements PubSubMessageSerDesRegistry

Default implementation of a PubSubMessageSerDesRegistry.

Since:

2.0.0

Author:

Vinicius Carvalho

Constructor Summary

Constructors

Constructor	Description
DefaultPubSubMessageSerDesRegistry(PubSubMessageSerDes[] serDes)

Method Summary

Modifier and Type	Method	Description
Optional<PubSubMessageSerDes>	find(String contentType)	Retrieves the appropriate PubSubMessageSerDes for the provided contentType.

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.micronaut.gcp.pubsub.serdes.PubSubMessageSerDesRegistry

find

Constructor Details

DefaultPubSubMessageSerDesRegistry

public DefaultPubSubMessageSerDesRegistry(PubSubMessageSerDes[] serDes)

Parameters:

serDes - list of PubSubMessageSerDes to be injected

Method Details

find

public Optional<PubSubMessageSerDes> find(String contentType)

Description copied from interface: PubSubMessageSerDesRegistry

Retrieves the appropriate PubSubMessageSerDes for the provided contentType.

Specified by:

find in interface PubSubMessageSerDesRegistry

Parameters:

contentType - The MIME type to search for a SerDes

Returns:

the registered SerDes