Package io.micronaut.nats.connect

Class NatsConnectionFactoryConfig.JetStreamConfiguration

java.lang.Object

io.micronaut.nats.connect.NatsConnectionFactoryConfig.JetStreamConfiguration

Enclosing class:

NatsConnectionFactoryConfig

@ConfigurationProperties("jetstream")
public static class NatsConnectionFactoryConfig.JetStreamConfiguration
extends Object

Manages the jetstream configuration.

Since:

4.0.0

Author:

Joachim Grimm

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	NatsConnectionFactoryConfig.JetStreamConfiguration.KeyValueConfiguration	Manages a single key value configuration.
static class	NatsConnectionFactoryConfig.JetStreamConfiguration.ObjectStoreConfiguration	Manages a single object store configuration.
static class	NatsConnectionFactoryConfig.JetStreamConfiguration.StreamConfiguration	Manages a single stream configuration.

Constructor Summary

Constructors

Constructor	Description
JetStreamConfiguration()

Method Summary

Modifier and Type	Method	Description
io.nats.client.JetStreamOptions.Builder	getBuilder()	get the jetstream options builder.
List<NatsConnectionFactoryConfig.JetStreamConfiguration.KeyValueConfiguration>	getKeyvalue()	get the key value configurations.
List<NatsConnectionFactoryConfig.JetStreamConfiguration.ObjectStoreConfiguration>	getObjectstore()	get the object store configurations.
List<NatsConnectionFactoryConfig.JetStreamConfiguration.StreamConfiguration>	getStreams()	get the stream configurations.
void	setKeyvalue(List<NatsConnectionFactoryConfig.JetStreamConfiguration.KeyValueConfiguration> keyvalue)	set the keyvalue configurations.
void	setObjectstore(List<NatsConnectionFactoryConfig.JetStreamConfiguration.ObjectStoreConfiguration> objectstore)	set the object store configurations.
void	setStreams(List<NatsConnectionFactoryConfig.JetStreamConfiguration.StreamConfiguration> streams)	set the stream configurations for the jetstream.
io.nats.client.JetStreamOptions	toJetStreamOptions()	return the configuration as JetStreamOptions.

Methods inherited from class java.lang.Object

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

Constructor Details

JetStreamConfiguration

public JetStreamConfiguration()

Method Details

getBuilder

public io.nats.client.JetStreamOptions.Builder getBuilder()

get the jetstream options builder.

Returns:

options builder

toJetStreamOptions

public io.nats.client.JetStreamOptions toJetStreamOptions()

return the configuration as JetStreamOptions.

Returns:

jetstream options

getStreams

public List<NatsConnectionFactoryConfig.JetStreamConfiguration.StreamConfiguration> getStreams()

get the stream configurations.

Returns:

list of streamConfigurations

setStreams

public void setStreams(List<NatsConnectionFactoryConfig.JetStreamConfiguration.StreamConfiguration> streams)

set the stream configurations for the jetstream.

Parameters:

streams - the stream configurations

getKeyvalue

public List<NatsConnectionFactoryConfig.JetStreamConfiguration.KeyValueConfiguration> getKeyvalue()

get the key value configurations.

Returns:

list of key value configurations

setKeyvalue

public void setKeyvalue(List<NatsConnectionFactoryConfig.JetStreamConfiguration.KeyValueConfiguration> keyvalue)

set the keyvalue configurations.

Parameters:

keyvalue - list of key value configurations

getObjectstore

public List<NatsConnectionFactoryConfig.JetStreamConfiguration.ObjectStoreConfiguration> getObjectstore()

get the object store configurations.

Returns:

list of object store configurations

setObjectstore

public void setObjectstore(List<NatsConnectionFactoryConfig.JetStreamConfiguration.ObjectStoreConfiguration> objectstore)

set the object store configurations.

Parameters:

objectstore - list of object store configurations