io.micronaut.pulsar

Class PulsarProducerFactory

java.lang.Object

io.micronaut.pulsar.PulsarProducerFactory

@Factory
public class PulsarProducerFactory
extends Object

Pulsar Producer factory.

Since:

1.0

Author:

Haris Secic

Constructor Summary

Constructors

Constructor and Description
PulsarProducerFactory(PulsarClientConfiguration configuration, TopicResolver topicResolver)

Method Summary

Modifier and Type	Method and Description
<T> org.apache.pulsar.client.api.Producer<T>	createProducer(org.apache.pulsar.client.api.PulsarClient pulsarClient, io.micronaut.core.annotation.AnnotationValue<PulsarProducer> annotationValue, io.micronaut.core.type.Argument<?>[] methodArguments, DefaultSchemaHandler simpleSchemaResolver, String annotatedMethodName) Simple factory method for producing Pulsar Producer beans.

Methods inherited from class java.lang.Object

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

Constructor Detail

PulsarProducerFactory

public PulsarProducerFactory(PulsarClientConfiguration configuration,
                             TopicResolver topicResolver)

Method Detail

createProducer

@Prototype
public <T> org.apache.pulsar.client.api.Producer<T> createProducer(@Parameter
                                                                              org.apache.pulsar.client.api.PulsarClient pulsarClient,
                                                                              @Parameter
                                                                              io.micronaut.core.annotation.AnnotationValue<PulsarProducer> annotationValue,
                                                                              @Parameter
                                                                              io.micronaut.core.type.Argument<?>[] methodArguments,
                                                                              @Parameter
                                                                              DefaultSchemaHandler simpleSchemaResolver,
                                                                              @Parameter
                                                                              String annotatedMethodName)
                                                                       throws io.micronaut.messaging.exceptions.MessagingClientException

Simple factory method for producing Pulsar Producer beans.

Type Parameters:

T - type of message body for pulsar producer

Parameters:

pulsarClient - main Pulsar Client bean

annotationValue - method annotation to read properties from

methodArguments - arguments passed to method annotated with @PulsarProducer

simpleSchemaResolver - schema resolver bean

annotatedMethodName - method name on which annotation for Pulsar Producer was set

Returns:

new Pulsar producer

Throws:

io.micronaut.messaging.exceptions.MessagingClientException