io.micronaut.pulsar.intercept

Class PulsarProducerAdvice

java.lang.Object

io.micronaut.pulsar.intercept.PulsarProducerAdvice

All Implemented Interfaces:

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

@Singleton
 @InterceptorBean(value=PulsarProducerClient.class)
public final class PulsarProducerAdvice
extends java.lang.Object
implements io.micronaut.aop.MethodInterceptor<java.lang.Object,java.lang.Object>, java.lang.AutoCloseable, PulsarProducerRegistry

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 interface io.micronaut.aop.Interceptor

ARGUMENT, HOTSWAP, LAZY, PROXY_TARGET

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

HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE

Constructor Summary

Constructors

Constructor and Description
PulsarProducerAdvice(org.apache.pulsar.client.api.PulsarClient pulsarClient, SchemaResolver schemaResolver, io.micronaut.context.BeanContext beanContext, io.micronaut.context.event.ApplicationEventPublisher applicationEventPublisher)

Method Summary

Modifier and Type	Method and Description
void	close()
org.apache.pulsar.client.api.Producer<?>	getProducer(java.lang.String id) Get single managed producer by its name.
java.util.Set<java.lang.String>	getProducerIds() Get all managed producer identifiers.
java.util.Map<java.lang.String,org.apache.pulsar.client.api.Producer<?>>	getProducers() Get all managed producers.
java.lang.Object	intercept(io.micronaut.aop.MethodInvocationContext<java.lang.Object,java.lang.Object> context)

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

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

getOrder

Constructor Detail

PulsarProducerAdvice

public PulsarProducerAdvice(org.apache.pulsar.client.api.PulsarClient pulsarClient,
                            SchemaResolver schemaResolver,
                            io.micronaut.context.BeanContext beanContext,
                            io.micronaut.context.event.ApplicationEventPublisher applicationEventPublisher)

Method Detail

intercept

public java.lang.Object intercept(io.micronaut.aop.MethodInvocationContext<java.lang.Object,java.lang.Object> context)

Specified by:

intercept in interface io.micronaut.aop.MethodInterceptor<java.lang.Object,java.lang.Object>

close

@PreDestroy
public void close()
                       throws java.lang.Exception

Specified by:

close in interface java.lang.AutoCloseable

Throws:

java.lang.Exception

getProducers

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

Description copied from interface: PulsarProducerRegistry

Get all managed producers.

Specified by:

getProducers in interface PulsarProducerRegistry

Returns:

List of managed producers.

getProducer

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

Description copied from interface: PulsarProducerRegistry

Get single managed producer by its name.

Specified by:

getProducer in interface PulsarProducerRegistry

Parameters:

id - unique identifier

Returns:

Pulsar producer by given name

getProducerIds

public java.util.Set<java.lang.String> getProducerIds()

Description copied from interface: PulsarProducerRegistry

Get all managed producer identifiers.

Specified by:

getProducerIds in interface PulsarProducerRegistry

Returns:

List of producer names representing their identifiers in registry.