Package 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	Description
PulsarProducerFactory(TopicResolver topicResolver)

Method Summary

Modifier and Type	Method	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 Details

PulsarProducerFactory

public PulsarProducerFactory(TopicResolver topicResolver)

Method Details

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