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 PositionSubscriber.Channel.EmptyChannel. getFirstPolled()PositionSubscriber.Channel. getFirstPolled()Returns the first position polled by this subscriber.PositionSubscriber.Channel.EmptyChannel. getHead()PositionSubscriber.Channel. getHead()Returns the current head position for the channel.PositionSubscriber.Channel.EmptyChannel. getLastCommit()PositionSubscriber.Channel. getLastCommit()Returns the last position committed by this subscriber.PositionSubscriber.Channel.EmptyChannel. getLastPolled()PositionSubscriber.Channel. getLastPolled()Returns the last position polled by this subscriber.PositionSubscriber.Channel.EmptyChannel. getLastReceived()PositionSubscriber.Channel. getLastReceived()Returns the last position received by this subscriber.PositionPublisher.Status. getPosition()Returns thePositionin the channel that the element was published to.PositionSubscriber.Element. getPosition()Returns the position of this element within the channel in a topic.PositionSubscriber. seek(int nChannel, Position position)Seek to the specified position in a channel.PositionSubscriber. seek(int nChannel, Instant timestamp)Seek to a position in a channel based the published timestamp of the elements in the topic.default PositionSubscriber. seekAndCommit(int nChannel, Position position)Seek to the specified position in a channel and set the commit point to the newPosition.default PositionSubscriber. 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 thePositionthat is currently the tail for the specified channel, orOptional.empty()if the channel is not owned by thisSubscriber.Map<Integer,Position>Subscriber. getHeads()Returns aMapof thePositionsthat are currently the head for each channel owned by thisSubscriber.Map<Integer,Position>Subscriber. getLastCommitted()Returns aMapof channels to the latestPositioncommitted for that channel; the map will only contain channels owned by thisSubscriber.default Optional<Position>Subscriber. getLastCommitted(int nChannel)Returns anOptionalcontaining the latest position committed for a channel, orOptional.empty()if the channel is not owned by thisSubscriberOptional<Position>Subscriber.CommitResult. getPosition()Returns the requested commitPosition.default Optional<Position>Subscriber. getTail(int nChannel)Returns thePositionthat is currently the tail for the specified channel orOptional.empty()if the channel is not owned by thisSubscriber.Map<Integer,Position>Subscriber. getTails()Returns aMapof thePositionsthat 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.CommitResultSubscriber. 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.PositionSubscriber. seek(int nChannel, Position position)Seek to the specified position in a channel.default PositionSubscriber. 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.
-