io.micronaut.pulsar.intercept

Class PulsarMultitenantProducerAdvice

java.lang.Object

io.micronaut.pulsar.intercept.PulsarProducerAdvice

io.micronaut.pulsar.intercept.PulsarMultitenantProducerAdvice

All Implemented Interfaces:

io.micronaut.aop.Interceptor<Object,Object>, io.micronaut.aop.MethodInterceptor<Object,Object>, io.micronaut.core.order.Ordered, PulsarProducerRegistry, AutoCloseable

@InterceptorBean(value=PulsarProducerClient.class)
 @Replaces(value=PulsarProducerAdvice.class)
public final class PulsarMultitenantProducerAdvice
extends PulsarProducerAdvice
implements io.micronaut.aop.MethodInterceptor<Object,Object>, AutoCloseable

Intercepting pulsar Producer methods. It can be used for creating implementation of interface methods or just to add producer behaviour to existing methods.

Since:

1.0

Author:

Haris Secic

Field Summary

Fields inherited from class io.micronaut.pulsar.intercept.PulsarProducerAdvice

applicationEventPublisher, beanContext, producers, pulsarClient, simpleSchemaResolver

Fields inherited from interface io.micronaut.aop.Interceptor

ARGUMENT, CACHEABLE_LAZY_TARGET, HOTSWAP, LAZY, PROXY_TARGET

Fields inherited from interface io.micronaut.core.order.Ordered

HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE

Constructor Summary

Constructors

Constructor and Description
PulsarMultitenantProducerAdvice(org.apache.pulsar.client.api.PulsarClient pulsarClient, DefaultSchemaHandler simpleSchemaResolver, io.micronaut.context.BeanContext beanContext, io.micronaut.context.event.ApplicationEventPublisher<ProducerSubscriptionFailedEvent> applicationEventPublisher, TenantNameResolver tenantNameResolver, TopicResolver topicResolver)

Method Summary

Modifier and Type	Method and Description
void	close()
protected org.apache.pulsar.client.api.Producer<?>	getOrCreateProducer(io.micronaut.inject.ExecutableMethod<?,?> method, io.micronaut.core.annotation.AnnotationValue<PulsarProducer> annotationValue) Fetch existing producer or generate a new one via factory if missing.
org.apache.pulsar.client.api.Producer<?>	getProducer(String id) Get single managed producer by its name.
Set<String>	getProducerIds() Get all managed producer identifiers.
Map<String,org.apache.pulsar.client.api.Producer<?>>	getProducers() Get all managed producers.

Methods inherited from class io.micronaut.pulsar.intercept.PulsarProducerAdvice

intercept

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.micronaut.aop.MethodInterceptor

intercept, intercept

Methods inherited from interface io.micronaut.core.order.Ordered

getOrder

Constructor Detail

PulsarMultitenantProducerAdvice

public PulsarMultitenantProducerAdvice(org.apache.pulsar.client.api.PulsarClient pulsarClient,
                                       DefaultSchemaHandler simpleSchemaResolver,
                                       io.micronaut.context.BeanContext beanContext,
                                       io.micronaut.context.event.ApplicationEventPublisher<ProducerSubscriptionFailedEvent> applicationEventPublisher,
                                       TenantNameResolver tenantNameResolver,
                                       TopicResolver topicResolver)

Method Detail

getOrCreateProducer

protected org.apache.pulsar.client.api.Producer<?> getOrCreateProducer(io.micronaut.inject.ExecutableMethod<?,?> method,
                                                                       io.micronaut.core.annotation.AnnotationValue<PulsarProducer> annotationValue)

Description copied from class: PulsarProducerAdvice

Fetch existing producer or generate a new one via factory if missing.

Overrides:

getOrCreateProducer in class PulsarProducerAdvice

Parameters:

method - method annotated with PulsarProducer

annotationValue - PulsarProducer value

Returns:

existing producer if exists; otherwise create a new one

close

@PreDestroy
public void close()

Specified by:

close in interface AutoCloseable

Overrides:

close in class PulsarProducerAdvice

getProducers

public Map<String,org.apache.pulsar.client.api.Producer<?>> getProducers()

Description copied from interface: PulsarProducerRegistry

Get all managed producers.

Specified by:

getProducers in interface PulsarProducerRegistry

Overrides:

getProducers in class PulsarProducerAdvice

Returns:

List of managed producers.

getProducer

public org.apache.pulsar.client.api.Producer<?> getProducer(@NonNull
                                                            String id)

Description copied from interface: PulsarProducerRegistry

Get single managed producer by its name.

Specified by:

getProducer in interface PulsarProducerRegistry

Overrides:

getProducer in class PulsarProducerAdvice

Parameters:

id - unique identifier

Returns:

Pulsar producer by given name

getProducerIds

public Set<String> getProducerIds()

Description copied from interface: PulsarProducerRegistry

Get all managed producer identifiers.

Specified by:

getProducerIds in interface PulsarProducerRegistry

Overrides:

getProducerIds in class PulsarProducerAdvice

Returns:

List of producer names representing their identifiers in registry.