public class

UpdateBucketMessageProcessor

extends AbstractMessageProcessor<O>
implements Disposable Initialisable Startable Stoppable MessageProcessor OperationMetaDataEnabled
java.lang.Object
   ↳ org.mule.modules.riak.processors.AbstractExpressionEvaluator
     ↳ org.mule.modules.riak.processors.AbstractMessageProcessor<O>
       ↳ org.mule.modules.riak.processors.UpdateBucketMessageProcessor

Class Overview

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. For each argument there is a field in this processor to match it. Before invoking the actual method the processor will evaluate and transform where possible to the expected argument type.

Summary

[Expand]
Inherited Constants
From interface org.mule.api.lifecycle.Disposable
From interface org.mule.api.lifecycle.Initialisable
From interface org.mule.api.lifecycle.Startable
From interface org.mule.api.lifecycle.Stoppable
Fields
protected boolean _allowSiblingsType
protected String _backendType
protected Integer _bigVClockType
protected String _bucketNameType
protected FunctionConfiguration _chashKeyFunctionType
protected boolean _enableSearchType
protected Boolean _lastWriteWinsType
protected FunctionConfiguration _linkWalkFunctionType
protected int _nValType
protected Boolean _notFoundOKType
protected Long _oldVClockType
protected List<FunctionConfiguration> _postCommitHooksType
protected List<FunctionConfiguration> _preCommitHooksType
protected QuorumConfiguration _quorumConfigurationType
protected Integer _smallVClockType
protected Long _youngVClockType
protected Object allowSiblings
protected Object backend
protected Object bigVClock
protected Object bucketName
protected Object chashKeyFunction
protected Object enableSearch
protected Object lastWriteWins
protected Object linkWalkFunction
protected Object nVal
protected Object notFoundOK
protected Object oldVClock
protected Object postCommitHooks
protected Object preCommitHooks
protected Object quorumConfiguration
protected Object smallVClock
protected Object youngVClock
[Expand]
Inherited Fields
From class org.mule.modules.riak.processors.AbstractMessageProcessor
Public Constructors
UpdateBucketMessageProcessor()
Public Methods
void dispose()
Result<MetaData> getInputMetaData()
Result<MetaData> getOutputMetaData(MetaData inputMetadata)
void initialise()
Obtains the expression manager from the Mule context and initialises the connector.
MuleEvent process(MuleEvent event)
Invokes the MessageProcessor.
void setAllowSiblings(Object value)
Sets allowSiblings
void setBackend(Object value)
Sets backend
void setBigVClock(Object value)
Sets bigVClock
void setBucketName(Object value)
Sets bucketName
void setChashKeyFunction(Object value)
Sets chashKeyFunction
void setEnableSearch(Object value)
Sets enableSearch
void setFlowConstruct(FlowConstruct flowConstruct)
Sets flow construct
void setLastWriteWins(Object value)
Sets lastWriteWins
void setLinkWalkFunction(Object value)
Sets linkWalkFunction
void setMuleContext(MuleContext context)
Set the Mule context
void setNVal(Object value)
Sets nVal
void setNotFoundOK(Object value)
Sets notFoundOK
void setOldVClock(Object value)
Sets oldVClock
void setPostCommitHooks(Object value)
Sets postCommitHooks
void setPreCommitHooks(Object value)
Sets preCommitHooks
void setQuorumConfiguration(Object value)
Sets quorumConfiguration
void setSmallVClock(Object value)
Sets smallVClock
void setYoungVClock(Object value)
Sets youngVClock
void start()
void stop()
[Expand]
Inherited Methods
From class org.mule.modules.riak.processors.AbstractMessageProcessor
From class org.mule.modules.riak.processors.AbstractExpressionEvaluator
From class java.lang.Object
From interface org.mule.api.construct.FlowConstructAware
From interface org.mule.api.context.MuleContextAware
From interface org.mule.api.lifecycle.Disposable
From interface org.mule.api.lifecycle.Initialisable
From interface org.mule.api.lifecycle.Startable
From interface org.mule.api.lifecycle.Stoppable
From interface org.mule.api.processor.MessageProcessor
From interface org.mule.common.metadata.MetaDataDescriptor

Fields

protected boolean _allowSiblingsType

protected String _backendType

protected Integer _bigVClockType

protected String _bucketNameType

protected FunctionConfiguration _chashKeyFunctionType

protected boolean _enableSearchType

protected Boolean _lastWriteWinsType

protected FunctionConfiguration _linkWalkFunctionType

protected int _nValType

protected Boolean _notFoundOKType

protected Long _oldVClockType

protected List<FunctionConfiguration> _postCommitHooksType

protected List<FunctionConfiguration> _preCommitHooksType

protected QuorumConfiguration _quorumConfigurationType

protected Integer _smallVClockType

protected Long _youngVClockType

protected Object allowSiblings

protected Object backend

protected Object bigVClock

protected Object bucketName

protected Object chashKeyFunction

protected Object enableSearch

protected Object lastWriteWins

protected Object linkWalkFunction

protected Object nVal

protected Object notFoundOK

protected Object oldVClock

protected Object postCommitHooks

protected Object preCommitHooks

protected Object quorumConfiguration

protected Object smallVClock

protected Object youngVClock

Public Constructors

public UpdateBucketMessageProcessor ()

Public Methods

public void dispose ()

public Result<MetaData> getInputMetaData ()

public Result<MetaData> getOutputMetaData (MetaData inputMetadata)

Parameters
inputMetadata

public void initialise ()

Obtains the expression manager from the Mule context and initialises the connector. If a target object has not been set already it will search the Mule registry for a default one.

Throws
InitialisationException

public MuleEvent process (MuleEvent event)

Invokes the MessageProcessor.

Parameters
event MuleEvent to be processed
Throws
MuleException

public void setAllowSiblings (Object value)

Sets allowSiblings

Parameters
value Value to set

public void setBackend (Object value)

Sets backend

Parameters
value Value to set

public void setBigVClock (Object value)

Sets bigVClock

Parameters
value Value to set

public void setBucketName (Object value)

Sets bucketName

Parameters
value Value to set

public void setChashKeyFunction (Object value)

Sets chashKeyFunction

Parameters
value Value to set

public void setEnableSearch (Object value)

Sets enableSearch

Parameters
value Value to set

public void setFlowConstruct (FlowConstruct flowConstruct)

Sets flow construct

Parameters
flowConstruct Flow construct to set

public void setLastWriteWins (Object value)

Sets lastWriteWins

Parameters
value Value to set

public void setLinkWalkFunction (Object value)

Sets linkWalkFunction

Parameters
value Value to set

public void setMuleContext (MuleContext context)

Set the Mule context

Parameters
context Mule context to set

public void setNVal (Object value)

Sets nVal

Parameters
value Value to set

public void setNotFoundOK (Object value)

Sets notFoundOK

Parameters
value Value to set

public void setOldVClock (Object value)

Sets oldVClock

Parameters
value Value to set

public void setPostCommitHooks (Object value)

Sets postCommitHooks

Parameters
value Value to set

public void setPreCommitHooks (Object value)

Sets preCommitHooks

Parameters
value Value to set

public void setQuorumConfiguration (Object value)

Sets quorumConfiguration

Parameters
value Value to set

public void setSmallVClock (Object value)

Sets smallVClock

Parameters
value Value to set

public void setYoungVClock (Object value)

Sets youngVClock

Parameters
value Value to set

public void start ()

Throws
MuleException

public void stop ()

Throws
MuleException