Uses of Interface
co.cask.cdap.messaging.MessagingService

Packages that use MessagingService

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

Uses of MessagingService in co.cask.cdap.messaging

Methods in co.cask.cdap.messaging with parameters of type MessagingService

Modifier and Type	Method and Description
static void	MessagingServices.createTopicIfNotExists(MessagingService messagingService, co.cask.cdap.proto.id.TopicId topicId)
static void	MessagingServices.createTopicIfNotExists(MessagingService messagingService, TopicMetadata topicMetadata)
static void	MessagingServices.publishWithRetry(MessagingService messagingService, co.cask.cdap.proto.id.TopicId topicId, RetryStrategy retryStrategy, byte[]... payloads)

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

Classes in co.cask.cdap.messaging.client that implement MessagingService

Modifier and Type	Class and Description
class	ClientMessagingService The client implementation of MessagingService.

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

Classes in co.cask.cdap.messaging.distributed that implement MessagingService

Modifier and Type	Class and Description
class	LeaderElectionMessagingService A MessagingService that performs lead-election and only operates if it is currently a leader.

Uses of MessagingService in co.cask.cdap.messaging.server

Constructors in co.cask.cdap.messaging.server with parameters of type MessagingService

Constructor and Description
MessagingHttpService(CConfiguration cConf, DiscoveryService discoveryService, co.cask.cdap.api.metrics.MetricsCollectionService metricsCollectionService, MessagingService messagingService, Set<co.cask.http.HttpHandler> handlers)

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

Classes in co.cask.cdap.messaging.service that implement MessagingService

Modifier and Type	Class and Description
class	CoreMessagingService The core implementation of MessagingService.