org.springframework.data.keyvalue.riak.groovy
Class RiakOperation<T>

java.lang.Object
  org.springframework.data.keyvalue.riak.groovy.RiakOperation<T>

All Implemented Interfaces:

Callable

public class RiakOperation<T>
extends Object
implements Callable

Author:

J. Brisbin

Field Summary

protected String	bucket
protected org.springframework.data.keyvalue.riak.groovy.RiakOperation.ClosureInvokingCallback	callbackInvoker
protected Map<String,List<org.springframework.data.keyvalue.riak.groovy.RiakOperation.GuardedClosure>>	callbacks
protected String	key
protected org.apache.commons.logging.Log	log
protected QosParameters	qosParameters
protected Class<?>	requiredType
protected AsyncRiakTemplate	riak
protected long	timeout
protected org.springframework.data.keyvalue.riak.groovy.RiakOperation.Type	type
protected T	value

Constructor Summary

RiakOperation(AsyncRiakTemplate riak, org.springframework.data.keyvalue.riak.groovy.RiakOperation.Type type)

Method Summary

void	addHandler(String type, groovy.lang.Closure handler, groovy.lang.Closure guard)
Object	call()
String	getBucket()
Map<String,List<org.springframework.data.keyvalue.riak.groovy.RiakOperation.GuardedClosure>>	getCallbacks()
String	getKey()
QosParameters	getQosParameters()
Class<?>	getRequiredType()
long	getTimeout()
org.springframework.data.keyvalue.riak.groovy.RiakOperation.Type	getType()
T	getValue()
void	setBucket(String bucket)
void	setKey(String key)
void	setQosParameters(QosParameters qosParameters)
void	setRequiredType(Class<?> requiredType)
void	setTimeout(long timeout)
void	setValue(T value)

Methods inherited from class java.lang.Object

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

Field Detail

log

protected final org.apache.commons.logging.Log log

riak

protected AsyncRiakTemplate riak

type

protected org.springframework.data.keyvalue.riak.groovy.RiakOperation.Type type

bucket

protected String bucket

key

protected String key

value

protected T value

requiredType

protected Class<?> requiredType

timeout

protected long timeout

qosParameters

protected QosParameters qosParameters

callbacks

protected Map<String,List<org.springframework.data.keyvalue.riak.groovy.RiakOperation.GuardedClosure>> callbacks

callbackInvoker

protected org.springframework.data.keyvalue.riak.groovy.RiakOperation.ClosureInvokingCallback callbackInvoker

Constructor Detail

RiakOperation

public RiakOperation(AsyncRiakTemplate riak,
                     org.springframework.data.keyvalue.riak.groovy.RiakOperation.Type type)

Method Detail

getType

public org.springframework.data.keyvalue.riak.groovy.RiakOperation.Type getType()

getCallbacks

public Map<String,List<org.springframework.data.keyvalue.riak.groovy.RiakOperation.GuardedClosure>> getCallbacks()

getQosParameters

public QosParameters getQosParameters()

setQosParameters

public void setQosParameters(QosParameters qosParameters)

getBucket

public String getBucket()

setBucket

public void setBucket(String bucket)

getKey

public String getKey()

setKey

public void setKey(String key)

getValue

public T getValue()

setValue

public void setValue(T value)

getRequiredType

public Class<?> getRequiredType()

setRequiredType

public void setRequiredType(Class<?> requiredType)

getTimeout

public long getTimeout()

setTimeout

public void setTimeout(long timeout)

addHandler

public void addHandler(String type,
                       groovy.lang.Closure handler,
                       groovy.lang.Closure guard)

call

public Object call()
            throws Exception

Specified by:

call in interface Callable

Throws:

Exception