Uses of Class
co.cask.cdap.messaging.MessageFetcher

Packages that use MessageFetcher

Package	Description
co.cask.cdap.messaging
co.cask.cdap.messaging.client
co.cask.cdap.messaging.distributed
co.cask.cdap.messaging.service

Uses of MessageFetcher in co.cask.cdap.messaging

Methods in co.cask.cdap.messaging that return MessageFetcher

Modifier and Type	Method and Description
MessageFetcher	MessagingService.prepareFetch(co.cask.cdap.proto.id.TopicId topicId) Prepares to fetch messages from the given topic.
MessageFetcher	MessageFetcher.setLimit(int limit) Sets the maximum limit on number of messages to be fetched.
MessageFetcher	MessageFetcher.setStartMessage(byte[] startOffset, boolean inclusive) Setup the message fetching starting point based on the given message id.
MessageFetcher	MessageFetcher.setStartTime(long startTime) Setup the message fetching start time (publish time).
MessageFetcher	MessageFetcher.setTransaction(org.apache.tephra.Transaction transaction) Sets the transaction to use for fetching.

Uses of MessageFetcher in co.cask.cdap.messaging.client

Methods in co.cask.cdap.messaging.client that return MessageFetcher

Modifier and Type	Method and Description
MessageFetcher	ClientMessagingService.prepareFetch(co.cask.cdap.proto.id.TopicId topicId)

Uses of MessageFetcher in co.cask.cdap.messaging.distributed

Methods in co.cask.cdap.messaging.distributed that return MessageFetcher

Modifier and Type	Method and Description
MessageFetcher	LeaderElectionMessagingService.prepareFetch(co.cask.cdap.proto.id.TopicId topicId)

Uses of MessageFetcher in co.cask.cdap.messaging.service

Methods in co.cask.cdap.messaging.service that return MessageFetcher

Modifier and Type	Method and Description
MessageFetcher	CoreMessagingService.prepareFetch(co.cask.cdap.proto.id.TopicId topicId)