Package eu.vstoyanov.natsy.jetstream
Object PublishExpectations.Companion
-
- All Implemented Interfaces:
public class PublishExpectations.Companion
-
-
Field Summary
Fields Modifier and Type Field Description public final static PublishExpectations.CompanionINSTANCE
-
Method Summary
Modifier and Type Method Description final PublishExpectationsexpectedStream(String name)Create expectations for a specific stream final PublishExpectationsexpectedLastSequence(Long seq)Create expectations for sequence number final PublishExpectationsexpectedLastSubjectSequence(Long seq)Create expectations for last subject sequence final PublishExpectationsexpectedLastMsgId(String id)Create expectations for last message ID final PublishExpectationsmessageId(String id)Set message ID for the current message (deduplication) -
-
Method Detail
-
expectedStream
final PublishExpectations expectedStream(String name)
Create expectations for a specific stream
-
expectedLastSequence
final PublishExpectations expectedLastSequence(Long seq)
Create expectations for sequence number
-
expectedLastSubjectSequence
final PublishExpectations expectedLastSubjectSequence(Long seq)
Create expectations for last subject sequence
-
expectedLastMsgId
final PublishExpectations expectedLastMsgId(String id)
Create expectations for last message ID
-
messageId
final PublishExpectations messageId(String id)
Set message ID for the current message (deduplication)
-
-
-
-