co.cask.cdap.messaging

Class MessagingServices

java.lang.Object

co.cask.cdap.messaging.MessagingServices

public final class MessagingServices
extends Object

Utility class to help interact with messaging service.

Method Summary

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

createTopicIfNotExists

public static void createTopicIfNotExists(MessagingService messagingService,
                                          co.cask.cdap.proto.id.TopicId topicId)
                                   throws IOException

Throws:

IOException

createTopicIfNotExists

public static void createTopicIfNotExists(MessagingService messagingService,
                                          TopicMetadata topicMetadata)
                                   throws IOException

Throws:

IOException

publishWithRetry

public static void publishWithRetry(MessagingService messagingService,
                                    co.cask.cdap.proto.id.TopicId topicId,
                                    RetryStrategy retryStrategy,
                                    byte[]... payloads)
                             throws co.cask.cdap.api.messaging.TopicNotFoundException,
                                    IOException,
                                    InterruptedException

Throws:

co.cask.cdap.api.messaging.TopicNotFoundException

IOException

InterruptedException