io.micronaut.pulsar.config

Class AbstractPulsarConfiguration<K,V>

java.lang.Object

io.micronaut.pulsar.config.AbstractPulsarConfiguration<K,V>

Type Parameters:

K - key

V - value

Direct Known Subclasses:

DefaultPulsarClientConfiguration

public abstract class AbstractPulsarConfiguration<K,V>
extends Object

Base template class for configuring pulsar.

Since:

1.0

Author:

Haris Secic

Field Summary

Fields

Modifier and Type	Field and Description
static String	DEFAULT_BOOTSTRAP_SERVER The default bootstrap server address for messaging.
static org.apache.pulsar.client.api.Authentication	DEFAULT_PULSAR_AUTHENTICATION By default Pulsar doesn't have any authentication.
static int	DEFAULT_PULSAR_MESSAGING_PORT The default Apache Pulsar messaging port.
static String	DEFAULT_SERVER_HOST_ADDRESS The default server hostname or IP address.
static String	PREFIX The default prefix used for Pulsar configuration.
static String	TENANT_NAME_VALIDATOR
static String	TOPIC_NAME_PATTERN_VALIDATOR Regex for validating topic pattern.
static String	TOPIC_NAME_VALIDATOR Regex for validating topic name.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractPulsarConfiguration(Properties config)

Method Summary

Modifier and Type	Method and Description
Properties	getConfig()

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_PULSAR_MESSAGING_PORT

public static final int DEFAULT_PULSAR_MESSAGING_PORT

The default Apache Pulsar messaging port.

See Also:

Constant Field Values

PREFIX

public static final String PREFIX

The default prefix used for Pulsar configuration.

See Also:

Constant Field Values

DEFAULT_SERVER_HOST_ADDRESS

public static final String DEFAULT_SERVER_HOST_ADDRESS

The default server hostname or IP address.

See Also:

Constant Field Values

DEFAULT_BOOTSTRAP_SERVER

public static final String DEFAULT_BOOTSTRAP_SERVER

The default bootstrap server address for messaging.

See Also:

Constant Field Values

DEFAULT_PULSAR_AUTHENTICATION

public static final org.apache.pulsar.client.api.Authentication DEFAULT_PULSAR_AUTHENTICATION

By default Pulsar doesn't have any authentication.

TOPIC_NAME_VALIDATOR

public static final String TOPIC_NAME_VALIDATOR

Regex for validating topic name.

See Also:

Constant Field Values

TOPIC_NAME_PATTERN_VALIDATOR

public static final String TOPIC_NAME_PATTERN_VALIDATOR

Regex for validating topic pattern.

See Also:

Constant Field Values

TENANT_NAME_VALIDATOR

public static final String TENANT_NAME_VALIDATOR

See Also:

Constant Field Values

Constructor Detail

AbstractPulsarConfiguration

protected AbstractPulsarConfiguration(Properties config)

Method Detail

getConfig

@NonNull
public Properties getConfig()

Returns:

The Pulsar configuration