Uses of Interface
com.tangosol.net.topic.Position
-
Packages that use Position Package Description com.tangosol.net.topic Contains classes that providing topic entities for publish/subscribe messaging. -
-
Uses of Position in com.tangosol.net.topic
Methods in com.tangosol.net.topic that return Position Modifier and Type Method Description Position
Subscriber.Channel.EmptyChannel. getFirstPolled()
Position
Subscriber.Channel. getFirstPolled()
Returns the first position polled by this subscriber.Position
Subscriber.Channel.EmptyChannel. getHead()
Position
Subscriber.Channel. getHead()
Returns the current head position for the channel.Position
Subscriber.Channel.EmptyChannel. getLastCommit()
Position
Subscriber.Channel. getLastCommit()
Returns the last position committed by this subscriber.Position
Subscriber.Channel.EmptyChannel. getLastPolled()
Position
Subscriber.Channel. getLastPolled()
Returns the last position polled by this subscriber.Position
Subscriber.Channel.EmptyChannel. getLastReceived()
Position
Subscriber.Channel. getLastReceived()
Returns the last position received by this subscriber.Position
Publisher.Status. getPosition()
Returns thePosition
in the channel that the element was published to.Position
Subscriber.Element. getPosition()
Returns the position of this element within the channel in a topic.Position
Subscriber. seek(int nChannel, Position position)
Seek to the specified position in a channel.Position
Subscriber. seek(int nChannel, Instant timestamp)
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.Methods in com.tangosol.net.topic that return types with arguments of type Position Modifier and Type Method Description default Optional<Position>
Subscriber. getHead(int nChannel)
Returns thePosition
that is currently the tail for the specified channel, orOptional.empty()
if the channel is not owned by thisSubscriber
.Map<Integer,Position>
Subscriber. getHeads()
Returns aMap
of thePositions
that are currently the head for each channel owned by thisSubscriber
.Map<Integer,Position>
Subscriber. getLastCommitted()
Returns aMap
of channels to the latestPosition
committed for that channel; the map will only contain channels owned by thisSubscriber
.default Optional<Position>
Subscriber. getLastCommitted(int nChannel)
Returns anOptional
containing the latest position committed for a channel, orOptional.empty()
if the channel is not owned by thisSubscriber
Optional<Position>
Subscriber.CommitResult. getPosition()
Returns the requested commitPosition
.default Optional<Position>
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
.Map<Integer,Position>
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.Map<Integer,Position>
Subscriber. seek(Map<Integer,Position> mapPosition)
Seek to the specified position in a set of channels.default Map<Integer,Position>
Subscriber. seekAndCommit(Map<Integer,Position> mapPosition)
Seek to the specified position in a set of channels and sets the commit position for the channels.Map<Integer,Position>
Subscriber. seekToHead(int... anChannel)
Reposition one or more channels to their respective head positions.Map<Integer,Position>
Subscriber. seekToTail(int... anChannel)
Reposition one or more channels to their respective tail positions.default Map<Integer,Position>
Subscriber. seekToTailAndCommit(int... anChannel)
Reposition one or more channels to their respective tail positions and set the commit point to the newPosition
.Methods in com.tangosol.net.topic with parameters of type Position Modifier and Type Method Description default Subscriber.CommitResult
Subscriber. commit(int nChannel, Position position)
Commit the specified channel and position.CompletableFuture<Subscriber.CommitResult>
Subscriber. commitAsync(int nChannel, Position position)
Asynchronously commit the specified channel and position.Position
Subscriber. seek(int nChannel, Position 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
.Method parameters in com.tangosol.net.topic with type arguments of type Position Modifier and Type Method Description default Map<Integer,Subscriber.CommitResult>
Subscriber. commit(Map<Integer,Position> mapPositions)
Commit the specified channels and positions.CompletableFuture<Map<Integer,Subscriber.CommitResult>>
Subscriber. commitAsync(Map<Integer,Position> mapPositions)
Asynchronously commit the specified channels and positions.Map<Integer,Position>
Subscriber. seek(Map<Integer,Position> mapPosition)
Seek to the specified position in a set of channels.default Map<Integer,Position>
Subscriber. seekAndCommit(Map<Integer,Position> mapPosition)
Seek to the specified position in a set of channels and sets the commit position for the channels.Constructors in com.tangosol.net.topic with parameters of type Position Constructor Description CommitResult(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
.
-