io.micronaut.pulsar.processor

Class PulsarConsumerProcessor

java.lang.Object

io.micronaut.pulsar.processor.PulsarConsumerProcessor

All Implemented Interfaces:

io.micronaut.context.processor.AnnotationProcessor<PulsarConsumer,io.micronaut.inject.ExecutableMethod<?,?>>, io.micronaut.context.processor.ExecutableMethodProcessor<PulsarConsumer>, PulsarConsumerRegistry, AutoCloseable

@Singleton
 @Internal
public class PulsarConsumerProcessor
extends Object
implements io.micronaut.context.processor.ExecutableMethodProcessor<PulsarConsumer>, AutoCloseable, PulsarConsumerRegistry

Processes beans containing methods annotated with @PulsarConsumer.

Since:

1.0

Author:

Haris Secic

Field Summary

Fields

Modifier and Type	Field and Description
protected TopicResolver	topicResolver

Constructor Summary

Constructors

Constructor and Description
PulsarConsumerProcessor(io.micronaut.context.event.ApplicationEventPublisher<Object> applicationEventPublisher, io.micronaut.context.BeanContext beanContext, org.apache.pulsar.client.api.PulsarClient pulsarClient, DefaultSchemaHandler simpleSchemaResolver, DefaultPulsarClientConfiguration pulsarClientConfiguration, TopicResolver topicResolver)

Method Summary

Modifier and Type	Method and Description
void	close()
boolean	consumerExists(String id)
<T> org.apache.pulsar.client.api.Consumer<T>	getConsumer(String id)
Set<String>	getConsumerIds()
protected @NotNull String	getConsumerName(io.micronaut.core.annotation.AnnotationValue<PulsarConsumer> topic) Resolve topic name from the PulsarConsumer annotation.
Map<String,org.apache.pulsar.client.api.Consumer<?>>	getConsumers()
boolean	isPaused(String id)
void	pause(String id)
void	process(io.micronaut.inject.BeanDefinition<?> beanDefinition, io.micronaut.inject.ExecutableMethod<?,?> method)
void	resume(String id)

Methods inherited from class java.lang.Object

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

Field Detail

topicResolver

protected final TopicResolver topicResolver

Constructor Detail

PulsarConsumerProcessor

public PulsarConsumerProcessor(io.micronaut.context.event.ApplicationEventPublisher<Object> applicationEventPublisher,
                               io.micronaut.context.BeanContext beanContext,
                               org.apache.pulsar.client.api.PulsarClient pulsarClient,
                               DefaultSchemaHandler simpleSchemaResolver,
                               DefaultPulsarClientConfiguration pulsarClientConfiguration,
                               TopicResolver topicResolver)

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<PulsarConsumer,io.micronaut.inject.ExecutableMethod<?,?>>

Specified by:

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

getConsumerName

@NotNull
protected @NotNull String getConsumerName(io.micronaut.core.annotation.AnnotationValue<PulsarConsumer> topic)

Resolve topic name from the PulsarConsumer annotation.

Parameters:

topic - value of PulsarConsumer annotation

Returns:

defined consumer name if set; otherwise generate a new one.

close

public void close()

Specified by:

close in interface AutoCloseable

getConsumers

public Map<String,org.apache.pulsar.client.api.Consumer<?>> getConsumers()

Specified by:

getConsumers in interface PulsarConsumerRegistry

getConsumer

@NonNull
public <T> org.apache.pulsar.client.api.Consumer<T> getConsumer(@NonNull
                                                                         String id)

Specified by:

getConsumer in interface PulsarConsumerRegistry

consumerExists

public boolean consumerExists(@NonNull
                              String id)

Specified by:

consumerExists in interface PulsarConsumerRegistry

getConsumerIds

@NonNull
public Set<String> getConsumerIds()

Specified by:

getConsumerIds in interface PulsarConsumerRegistry

isPaused

public boolean isPaused(@NonNull
                        String id)

Specified by:

isPaused in interface PulsarConsumerRegistry

pause

public void pause(@NonNull
                  String id)

Specified by:

pause in interface PulsarConsumerRegistry

resume

public void resume(@NonNull
                   String id)

Specified by:

resume in interface PulsarConsumerRegistry