Package io.micronaut.nats.connect

Class NatsConnectionFactoryConfig.JetStreamConfiguration.StreamConfiguration

java.lang.Object

io.micronaut.nats.connect.NatsConnectionFactoryConfig.JetStreamConfiguration.StreamConfiguration

Enclosing class:

NatsConnectionFactoryConfig.JetStreamConfiguration

@EachProperty("streams")
public static class NatsConnectionFactoryConfig.JetStreamConfiguration.StreamConfiguration
extends Object

Manages a single stream configuration.

Constructor Summary

Constructors

Constructor	Description
StreamConfiguration(String name)

Method Summary

Modifier and Type	Method	Description
io.nats.client.api.StreamConfiguration.Builder	getBuilder()	get the stream configuration builder.
List<String>	getSubjects()	get the subjects of the stream.
void	setSubjects(List<String> subjects)	set the subjects.
io.nats.client.api.StreamConfiguration	toStreamConfiguration()	return the configuration as StreamConfiguration.

Methods inherited from class java.lang.Object

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

Constructor Details

StreamConfiguration

public StreamConfiguration(@Parameter
 String name)

Method Details

getBuilder

public io.nats.client.api.StreamConfiguration.Builder getBuilder()

get the stream configuration builder.

Returns:

stream configuration builder

toStreamConfiguration

public io.nats.client.api.StreamConfiguration toStreamConfiguration()

return the configuration as StreamConfiguration.

Returns:

nats stream configuration

getSubjects

public List<String> getSubjects()

get the subjects of the stream.

Returns:

the subjects

setSubjects

public void setSubjects(List<String> subjects)

set the subjects.

Parameters:

subjects - list of subjects