io.micronaut.nats.intercept

Class NatsConsumerAdvice

java.lang.Object

io.micronaut.nats.intercept.NatsConsumerAdvice

All Implemented Interfaces:

io.micronaut.context.processor.AnnotationProcessor<Subject,io.micronaut.inject.ExecutableMethod<?,?>>, io.micronaut.context.processor.ExecutableMethodProcessor<Subject>, ConsumerRegistry, java.lang.AutoCloseable

@Singleton
public class NatsConsumerAdvice
extends java.lang.Object
implements io.micronaut.context.processor.ExecutableMethodProcessor<Subject>, java.lang.AutoCloseable, ConsumerRegistry

An ExecutableMethodProcessor that will process all beans annotated with NatsListener. It creates and subscribes the relevant methods as consumers to Nats subjects.

Since:

1.0.0

Author:

Joachim Grimm

Constructor Summary

Constructors

Constructor and Description
NatsConsumerAdvice(io.micronaut.context.BeanContext beanContext, NatsBinderRegistry binderRegistry, NatsMessageSerDesRegistry serDesRegistry, NatsListenerExceptionHandler exceptionHandler, io.micronaut.runtime.ApplicationConfiguration applicationConfiguration) Default constructor.

Method Summary

Modifier and Type	Method and Description
void	close()
io.nats.client.Consumer	getConsumer(java.lang.String id) Returns the subscription by given id.
java.util.Set<java.lang.String>	getConsumerIds() The IDs of the available consumers.
java.util.Set<io.nats.client.Subscription>	getConsumerSubscription(java.lang.String id) Returns a managed Consumer's subscriptions.
io.nats.client.Subscription	newSubscription(java.lang.String subject, java.lang.String queue) Create a new subscription with the default connection.
io.nats.client.Subscription	newSubscription(java.lang.String connectionName, java.lang.String subject, java.lang.String queue) Create a new subscription from the given connection name.
void	process(io.micronaut.inject.BeanDefinition<?> beanDefinition, io.micronaut.inject.ExecutableMethod<?,?> method)

Methods inherited from class java.lang.Object

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

Constructor Detail

NatsConsumerAdvice

public NatsConsumerAdvice(io.micronaut.context.BeanContext beanContext,
                          NatsBinderRegistry binderRegistry,
                          NatsMessageSerDesRegistry serDesRegistry,
                          NatsListenerExceptionHandler exceptionHandler,
                          io.micronaut.runtime.ApplicationConfiguration applicationConfiguration)

Default constructor.

Parameters:

beanContext - The bean context

binderRegistry - The registry to bind arguments to the method

serDesRegistry - The serialization/deserialization registry

exceptionHandler - The exception handler to use if the consumer isn't a handler

applicationConfiguration - The application configuration

Method Detail

process

public void process(io.micronaut.inject.BeanDefinition<?> beanDefinition,
                    io.micronaut.inject.ExecutableMethod<?,?> method)

Specified by:

process in interface io.micronaut.context.processor.AnnotationProcessor<Subject,io.micronaut.inject.ExecutableMethod<?,?>>

Specified by:

process in interface io.micronaut.context.processor.ExecutableMethodProcessor<Subject>

close

@PreDestroy
public void close()

Specified by:

close in interface java.lang.AutoCloseable

getConsumer

@NonNull
public io.nats.client.Consumer getConsumer(@NonNull
                                                    java.lang.String id)

Description copied from interface: ConsumerRegistry

Returns the subscription by given id.

Specified by:

getConsumer in interface ConsumerRegistry

Parameters:

id - String The id of the listener

Returns:

The consumer

getConsumerIds

@NonNull
public java.util.Set<java.lang.String> getConsumerIds()

Description copied from interface: ConsumerRegistry

The IDs of the available consumers.

Specified by:

getConsumerIds in interface ConsumerRegistry

Returns:

The consumers

getConsumerSubscription

@NonNull
public java.util.Set<io.nats.client.Subscription> getConsumerSubscription(@NonNull
                                                                                   java.lang.String id)

Description copied from interface: ConsumerRegistry

Returns a managed Consumer's subscriptions.

Specified by:

getConsumerSubscription in interface ConsumerRegistry

Parameters:

id - The id of the producer.

Returns:

The consumer subscription

newSubscription

public io.nats.client.Subscription newSubscription(@NonNull
                                                   java.lang.String subject,
                                                   @Nullable
                                                   java.lang.String queue)

Description copied from interface: ConsumerRegistry

Create a new subscription with the default connection.

Specified by:

newSubscription in interface ConsumerRegistry

Parameters:

subject - String

queue - String optional

Returns:

subscription Subscription

newSubscription

public io.nats.client.Subscription newSubscription(@NonNull
                                                   java.lang.String connectionName,
                                                   @NonNull
                                                   java.lang.String subject,
                                                   @Nullable
                                                   java.lang.String queue)

Description copied from interface: ConsumerRegistry

Create a new subscription from the given connection name.

Specified by:

newSubscription in interface ConsumerRegistry

Parameters:

connectionName - String

subject - String

queue - String optional

Returns:

subscription Subscription