co.cask.cdap.messaging.store.cache

Interface MessageTableCacheProvider

All Known Implementing Classes:

DefaultMessageTableCacheProvider

public interface MessageTableCacheProvider

A provider to provide MessageCache over MessageTable.Entry based on TopicId.

Method Summary

Modifier and Type	Method and Description
void	clear() Resets all MessageCache created by this cache provider.
MessageCache<MessageTable.Entry>	getMessageCache(co.cask.cdap.proto.id.TopicId topicId) Returns a MessageCache for the given topic.

Method Detail

getMessageCache

@Nullable
MessageCache<MessageTable.Entry> getMessageCache(co.cask.cdap.proto.id.TopicId topicId)

Returns a MessageCache for the given topic.

Parameters:

topicId - the topic id

Returns:

a MessageCache or null if caching is not enabled for the given topic.

clear

void clear()

Resets all MessageCache created by this cache provider.