Package io.micronaut.nats.intercept

Class StaticConsumerState

java.lang.Object

io.micronaut.nats.intercept.StaticConsumerState

@Internal
public final class StaticConsumerState
extends Object

Manages the consumer state for nats and jetstream.

Since:

4.0.0

Author:

Joachim Grimm

Constructor Summary

Constructors

Constructor	Description
StaticConsumerState(String clientId, Set<io.nats.client.Subscription> subscriptions, io.nats.client.Dispatcher dispatcher, io.nats.client.Connection connection)	default constructor.

Method Summary

Modifier and Type	Method	Description
void	close()
String	getClientId()
io.nats.client.Connection	getConnection()
io.nats.client.Dispatcher	getDispatcher()
Set<io.nats.client.Subscription>	getSubscriptions()

Methods inherited from class java.lang.Object

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

Constructor Details

StaticConsumerState

public StaticConsumerState(String clientId,
 Set<io.nats.client.Subscription> subscriptions,
 io.nats.client.Dispatcher dispatcher,
 io.nats.client.Connection connection)

default constructor.

Parameters:

clientId - the client id

subscriptions - the subscriptions of the consumer

dispatcher - the dispatcher of the consumer

connection - the connection of the consumer

Method Details

getClientId

public String getClientId()

getSubscriptions

public Set<io.nats.client.Subscription> getSubscriptions()

getDispatcher

public io.nats.client.Dispatcher getDispatcher()

getConnection

public io.nats.client.Connection getConnection()

close

public void close()