Known Indirect Subclasses
AbstractListeningMessageProcessor<O>,
CreateBucketMessageProcessor,
DeleteMessageProcessor,
FetchBinIndexMessageProcessor,
FetchBucketMessageProcessor,
FetchIntIndexMessageProcessor,
FetchKeysMessageProcessor,
FetchMessageProcessor,
GetStatisticsMessageProcessor,
ListBucketNamesMessageProcessor,
MapReduceBinIndexMessageProcessor,
MapReduceBucketKeyMessageProcessor,
MapReduceBucketMessageProcessor,
MapReduceIntIndexMessageProcessor,
MapReduceSearchMessageProcessor,
StoreMessageProcessor,
UpdateBucketMessageProcessor,
WalkMessageProcessor
| AbstractListeningMessageProcessor<O> |
|
| CreateBucketMessageProcessor |
CreateBucketMessageProcessor invokes the createBucket(java.lang.String, boolean, java.lang.String, boolean, java.lang.Boolean, java.lang.Boolean, int, java.lang.Integer, java.lang.Integer, java.lang.Long, java.lang.Long, java.util.List, java.util.List, org.mule.modules.riak.config.FunctionConfiguration, org.mule.modules.riak.config.FunctionConfiguration, org.mule.modules.riak.config.QuorumConfiguration) method in RiakConnector. |
| DeleteMessageProcessor |
DeleteMessageProcessor invokes the delete(java.lang.String, java.lang.String, java.lang.Object, java.lang.Boolean, org.mule.modules.riak.config.QuorumConfiguration, org.mule.api.MuleEvent) method in RiakConnector. |
| FetchBinIndexMessageProcessor |
FetchBinIndexMessageProcessor invokes the fetchBinIndex(java.lang.String, java.lang.String, java.lang.String, java.lang.String, java.lang.String) method in RiakConnector. |
| FetchBucketMessageProcessor |
FetchBucketMessageProcessor invokes the fetchBucket(java.lang.String) method in RiakConnector. |
| FetchIntIndexMessageProcessor |
FetchIntIndexMessageProcessor invokes the fetchIntIndex(java.lang.String, java.lang.String, java.lang.Integer, java.lang.Integer, java.lang.Integer) method in RiakConnector. |
| FetchKeysMessageProcessor |
FetchKeysMessageProcessor invokes the fetchKeys(java.lang.String) method in RiakConnector. |
| FetchMessageProcessor |
FetchMessageProcessor invokes the fetch(java.lang.String, java.lang.String, java.lang.Object, java.util.Date, java.lang.Boolean, java.lang.Boolean, org.mule.modules.riak.config.QuorumConfiguration, com.basho.riak.client.cap.ConflictResolver, org.mule.api.MuleEvent) method in RiakConnector. |
| GetStatisticsMessageProcessor |
GetStatisticsMessageProcessor invokes the getStatistics() method in RiakConnector. |
| ListBucketNamesMessageProcessor |
ListBucketNamesMessageProcessor invokes the listBucketNames() method in RiakConnector. |
| MapReduceBinIndexMessageProcessor |
MapReduceBinIndexMessageProcessor invokes the mapReduceBinIndex(java.lang.String, java.lang.String, java.lang.String, java.lang.String, java.lang.String, java.util.List, java.lang.Long) method in RiakConnector. |
| MapReduceBucketKeyMessageProcessor |
MapReduceBucketKeyMessageProcessor invokes the mapReduceBucketKey(java.util.List, java.util.List, java.lang.Long) method in RiakConnector. |
| MapReduceBucketMessageProcessor |
MapReduceBucketMessageProcessor invokes the mapReduceBucket(java.lang.String, java.util.List, java.util.List, java.lang.Long) method in RiakConnector. |
| MapReduceIntIndexMessageProcessor |
MapReduceIntIndexMessageProcessor invokes the mapReduceIntIndex(java.lang.String, java.lang.String, java.lang.Long, java.lang.Long, java.lang.Long, java.util.List, java.lang.Long) method in RiakConnector. |
| MapReduceSearchMessageProcessor |
MapReduceSearchMessageProcessor invokes the mapReduceSearch(java.lang.String, java.lang.String, java.util.List, java.lang.Long) method in RiakConnector. |
| StoreMessageProcessor |
StoreMessageProcessor invokes the store(java.lang.String, java.lang.String, java.lang.String, boolean, boolean, boolean, boolean, java.lang.Boolean, java.lang.Boolean, org.mule.modules.riak.config.QuorumConfiguration, com.basho.riak.client.cap.ConflictResolver, com.basho.riak.client.cap.Mutation, java.lang.Object, org.mule.api.MuleEvent) method in RiakConnector. |
| UpdateBucketMessageProcessor |
UpdateBucketMessageProcessor invokes the updateBucket(java.lang.String, boolean, java.lang.String, boolean, java.lang.Boolean, java.lang.Boolean, int, java.lang.Integer, java.lang.Integer, java.lang.Long, java.lang.Long, java.util.List, java.util.List, org.mule.modules.riak.config.FunctionConfiguration, org.mule.modules.riak.config.FunctionConfiguration, org.mule.modules.riak.config.QuorumConfiguration) method in RiakConnector. |
| WalkMessageProcessor |
WalkMessageProcessor invokes the walk(java.lang.String, java.lang.String, java.util.List) method in RiakConnector. |
|