io.micronaut.pulsar

Class PulsarProducerFactory

java.lang.Object

io.micronaut.pulsar.PulsarProducerFactory

@Factory
public class PulsarProducerFactory
extends java.lang.Object

Pulsar Producer factory.

Since:

1.0

Author:

Haris Secic

Constructor Summary

Constructors

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

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, SchemaResolver schemaResolver, java.lang.String annotatedMethodName, java.lang.Class<T> bodyType) 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(io.micronaut.context.BeanContext beanContext,
                             SchemaResolver schemaResolver,
                             org.apache.pulsar.client.api.PulsarClient pulsarClient)

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
                                                                              SchemaResolver schemaResolver,
                                                                              @Parameter
                                                                              java.lang.String annotatedMethodName,
                                                                              @Parameter
                                                                              java.lang.Class<T> bodyType)
                                                                       throws org.apache.pulsar.client.api.PulsarClientException

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

schemaResolver - schema resolver bean

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

bodyType - class defining desired content type of a message passed to pulsar producer

Returns:

new Pulsar producer

Throws:

org.apache.pulsar.client.api.PulsarClientException - in case of not being able to create such Producer