Uses of Interface
com.tangosol.net.topic.Position
Package
Description
Contains classes that providing topic entities for publish/subscribe messaging.
-
Uses of Position in com.tangosol.net.topic
Modifier and TypeMethodDescriptionSubscriber.Channel.EmptyChannel.getFirstPolled()
Subscriber.Channel.getFirstPolled()
Returns the first position polled by this subscriber.Subscriber.Channel.EmptyChannel.getHead()
Subscriber.Channel.getHead()
Returns the current head position for the channel.Subscriber.Channel.EmptyChannel.getLastCommit()
Subscriber.Channel.getLastCommit()
Returns the last position committed by this subscriber.Subscriber.Channel.EmptyChannel.getLastPolled()
Subscriber.Channel.getLastPolled()
Returns the last position polled by this subscriber.Subscriber.Channel.EmptyChannel.getLastReceived()
Subscriber.Channel.getLastReceived()
Returns the last position received by this subscriber.Publisher.Status.getPosition()
Returns thePosition
in the channel that the element was published to.Subscriber.Element.getPosition()
Returns the position of this element within the channel in a topic.Seek to the specified position in a channel.Seek to a position in a channel based the published timestamp of the elements in the topic.default Position
Subscriber.seekAndCommit
(int nChannel, Position position) Seek to the specified position in a channel and set the commit point to the newPosition
.default Position
Subscriber.seekAndCommit
(int nChannel, Instant timestamp) Seek to a position in a channel based the published timestamp of the elements in the topic and set the commit point to the new position.Modifier and TypeMethodDescriptionSubscriber.getHead
(int nChannel) Returns thePosition
that is currently the tail for the specified channel, orOptional.empty()
if the channel is not owned by thisSubscriber
.Subscriber.getHeads()
Returns aMap
of thePositions
that are currently the head for each channel owned by thisSubscriber
.Subscriber.getLastCommitted()
Returns aMap
of channels to the latestPosition
committed for that channel; the map will only contain channels owned by thisSubscriber
.Subscriber.getLastCommitted
(int nChannel) Returns anOptional
containing the latest position committed for a channel, orOptional.empty()
if the channel is not owned by thisSubscriber
Subscriber.CommitResult.getPosition()
Returns the requested commitPosition
.Subscriber.getTail
(int nChannel) Returns thePosition
that is currently the tail for the specified channel orOptional.empty()
if the channel is not owned by thisSubscriber
.Subscriber.getTails()
Returns aMap
of thePositions
that are currently the tail for each channel owned by thisSubscriber
; that is the last message in the channel.Seek to the specified position in a set of channels.Subscriber.seekAndCommit
(Map<Integer, Position> mapPosition) Seek to the specified position in a set of channels and sets the commit position for the channels.Subscriber.seekToHead
(int... anChannel) Reposition one or more channels to their respective head positions.Subscriber.seekToTail
(int... anChannel) Reposition one or more channels to their respective tail positions.Subscriber.seekToTailAndCommit
(int... anChannel) Reposition one or more channels to their respective tail positions and set the commit point to the newPosition
.Modifier and TypeMethodDescriptiondefault Subscriber.CommitResult
Commit the specified channel and position.Subscriber.commitAsync
(int nChannel, Position position) Asynchronously commit the specified channel and position.Seek to the specified position in a channel.default Position
Subscriber.seekAndCommit
(int nChannel, Position position) Seek to the specified position in a channel and set the commit point to the newPosition
.Modifier and TypeMethodDescriptiondefault Map
<Integer, Subscriber.CommitResult> Commit the specified channels and positions.Subscriber.commitAsync
(Map<Integer, Position> mapPositions) Asynchronously commit the specified channels and positions.Seek to the specified position in a set of channels.Subscriber.seekAndCommit
(Map<Integer, Position> mapPosition) Seek to the specified position in a set of channels and sets the commit position for the channels.ModifierConstructorDescriptionCommitResult
(int nChannel, Position position, Subscriber.CommitResultStatus status) Create aSubscriber.CommitResult
.CommitResult
(int nChannel, Position position, Subscriber.CommitResultStatus status, Throwable throwable) Create a rejectedSubscriber.CommitResult
.CommitResult
(int nChannel, Position position, Throwable throwable) Create a rejectedSubscriber.CommitResult
.