io.micronaut.configuration.kafka.streams.registry

Class QueryableStoreRegistry

java.lang.Object

io.micronaut.configuration.kafka.streams.registry.QueryableStoreRegistry

public class QueryableStoreRegistry
extends Object

A factory that constructs a KafkaStreamsRegistry and QueryableStoreRegistry beans.

Since:

1.1

Author:

Christian Oestreich

Method Summary

Modifier and Type	Method and Description
<T> T	getQueryableStoreType(String storeName, QueryableStoreType<T> storeType) Retrieve and return a queryable store by name created in the application.

Methods inherited from class java.lang.Object

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

Method Detail

getQueryableStoreType

public <T> T getQueryableStoreType(String storeName,
                                   QueryableStoreType<T> storeType)

Retrieve and return a queryable store by name created in the application.

Type Parameters:

T - generic queryable store

Parameters:

storeName - name of the queryable store

storeType - type of the queryable store

Returns:

queryable store.