Package 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	Description
protected final DefaultPulsarClientConfiguration	pulsarClientConfiguration
protected final TopicResolver	topicResolver

Constructor Summary

Constructors

Constructor	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	Description
void	close()
boolean	consumerExists(@NonNull String id)
<T> @NonNull org.apache.pulsar.client.api.Consumer<T>	getConsumer(@NonNull String id)
@NonNull 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(@NonNull String id)
void	pause(@NonNull String id)
void	process(io.micronaut.inject.BeanDefinition<?> beanDefinition, io.micronaut.inject.ExecutableMethod<?,?> method)
void	resume(@NonNull String id)

Methods inherited from class java.lang.Object

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

Field Details

topicResolver

protected final TopicResolver topicResolver

pulsarClientConfiguration

protected final DefaultPulsarClientConfiguration pulsarClientConfiguration

Constructor Details

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 Details

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>
@NonNull org.apache.pulsar.client.api.Consumer<T> getConsumer(@NonNull
 @NonNull String id)

Specified by:

getConsumer in interface PulsarConsumerRegistry

consumerExists

public boolean consumerExists(@NonNull
 @NonNull String id)

Specified by:

consumerExists in interface PulsarConsumerRegistry

getConsumerIds

@NonNull
public @NonNull Set<String> getConsumerIds()

Specified by:

getConsumerIds in interface PulsarConsumerRegistry

isPaused

public boolean isPaused(@NonNull
 @NonNull String id)

Specified by:

isPaused in interface PulsarConsumerRegistry

pause

public void pause(@NonNull
 @NonNull String id)

Specified by:

pause in interface PulsarConsumerRegistry

resume

public void resume(@NonNull
 @NonNull String id)

Specified by:

resume in interface PulsarConsumerRegistry