this.item = item;
}
+ @Override
+ public Class<?> getPayloadClass() {
+ return item.getClass();
+ }
+
@Override
public String getKey() {
return item.getKey().toString();
return this.key.toString();
}
+ @Override
+ public Class<?> getPayloadClass() {
+ return item.getClass();
+ }
+
@Override
public void doExecute() {
public abstract class IndexAction extends QueueAction {
+ public abstract Class<?> getPayloadClass();
+
public enum Method {
UPSERT, DELETE
}
this.key = key;
}
+ @Override
+ public Class<?> getPayloadClass() {
+ return String.class;
+ }
+
@Override
public String getKey() {
return this.key.toString();