package

org.mule.modules.riak.processors

Classes

AbstractExpressionEvaluator  
AbstractListeningMessageProcessor<O>  
AbstractMessageProcessor<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.