co.cask.cdap.messaging.store.cache

Class DefaultMessageTableCacheProvider

java.lang.Object

co.cask.cdap.messaging.store.cache.DefaultMessageTableCacheProvider

All Implemented Interfaces:

MessageTableCacheProvider

public class DefaultMessageTableCacheProvider
extends Object
implements MessageTableCacheProvider

The default implementation of MessageTableCacheProvider.

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.

Methods inherited from class java.lang.Object

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

Method Detail

getMessageCache

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

Description copied from interface: MessageTableCacheProvider

Returns a MessageCache for the given topic.

Specified by:

getMessageCache in interface MessageTableCacheProvider

Parameters:

topicId - the topic id

Returns:

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

clear

public void clear()

Description copied from interface: MessageTableCacheProvider

Resets all MessageCache created by this cache provider.

Specified by:

clear in interface MessageTableCacheProvider