Package org.redisson.api.stream

Class BaseReferencesParams<T>

java.lang.Object

org.redisson.api.stream.BaseReferencesParams<T>

All Implemented Interfaces:

StreamReferencesArgs<T>

Direct Known Subclasses:

StreamAckParams, StreamAddParams, StreamRemoveParams, StreamTrimParams

public abstract class BaseReferencesParams<T>
extends Object
implements StreamReferencesArgs<T>

Author:

seakider

Constructor Summary

Constructors

Constructor	Description
BaseReferencesParams()

Method Summary

Modifier and Type	Method	Description
RefPolicy	getRefPolicy()
T	keepReferences()	Defines KEEPREF reference policy for consumer groups when trimming.
T	removeAcknowledgedOnly()	Defines ACKED reference policy for consumer groups when trimming.
T	removeReferences()	Defines DELREF reference policy for consumer groups when trimming.

Methods inherited from class java.lang.Object

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

Constructor Details

BaseReferencesParams

public BaseReferencesParams()

Method Details

removeReferences

public T removeReferences()

Description copied from interface: StreamReferencesArgs

Defines DELREF reference policy for consumer groups when trimming. When trimming, removes all references from consumer groups’ PEL Requires Redis 8.2.0 and higher.

Specified by:

removeReferences in interface StreamReferencesArgs<T>

Returns:

arguments object

keepReferences

public T keepReferences()

Description copied from interface: StreamReferencesArgs

Defines KEEPREF reference policy for consumer groups when trimming. When trimming, preserves references in consumer groups’ PEL Requires Redis 8.2.0 and higher.

Specified by:

keepReferences in interface StreamReferencesArgs<T>

Returns:

arguments object

removeAcknowledgedOnly

public T removeAcknowledgedOnly()

Description copied from interface: StreamReferencesArgs

Defines ACKED reference policy for consumer groups when trimming. When trimming, only removes entries acknowledged by all consumer groups Requires Redis 8.2.0 and higher.

Specified by:

removeAcknowledgedOnly in interface StreamReferencesArgs<T>

Returns:

arguments object

getRefPolicy

public RefPolicy getRefPolicy()