| Package | Description |
|---|---|
| co.cask.cdap.messaging.cache | |
| co.cask.cdap.messaging.store |
| Modifier and Type | Method and Description |
|---|---|
MessageCache.Scanner<T> |
MessageCache.scan(T startEntry,
boolean includeStart,
int limit,
MessageFilter<T> filter)
Creates a
MessageCache.Scanner for fetching cached entries in ascending order. |
| Modifier and Type | Class and Description |
|---|---|
class |
TransactionMessageFilter
A
MessageFilter that filter MessageTable.Entry based on a given transaction. |
| Modifier and Type | Method and Description |
|---|---|
static <T> MessageFilter<T> |
MessageFilter.alwaysAccept()
Creates a
MessageFilter that always accept. |
Copyright © 2017 Cask Data, Inc. Licensed under the Apache License, Version 2.0.