io.micronaut.pulsar

Class PulsarClientFactory

java.lang.Object

io.micronaut.pulsar.PulsarClientFactory

@Factory
 @Requires(beans=PulsarClientConfiguration.class)
public final class PulsarClientFactory
extends Object

Create bean of PulsarClient type which is required by consumers and producers.

Since:

1.0

Author:

Haris Secic

Constructor Summary

Constructors

Constructor and Description
PulsarClientFactory()

Method Summary

Modifier and Type	Method and Description
org.apache.pulsar.client.api.PulsarClient	pulsarClient(PulsarClientConfiguration pulsarClientConfiguration) Simple factory method for building main PulsarClient that serves as a connection to Pulsar cluster.

Methods inherited from class java.lang.Object

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

Constructor Detail

PulsarClientFactory

public PulsarClientFactory()

Method Detail

pulsarClient

@Singleton
public org.apache.pulsar.client.api.PulsarClient pulsarClient(PulsarClientConfiguration pulsarClientConfiguration)
                                                                  throws org.apache.pulsar.client.api.PulsarClientException

Simple factory method for building main PulsarClient that serves as a connection to Pulsar cluster.

Parameters:

pulsarClientConfiguration - Main configuration for building PulsarClient

Returns:

Instance of PulsarClient

Throws:

org.apache.pulsar.client.api.PulsarClientException - in case any of the required options are missing or malformed