Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with HTTPS or Subversion.

Download ZIP
Browse files

Minor cleanup

  • Loading branch information...
commit d702fbc13e792cee1c1976e54e276e7df0015740 1 parent 6959353
Thomas Kielbus thomas-kielbus authored
3  megadesk-recipes/src/main/java/com/liveramp/megadesk/recipes/queue/QueueExecutable.java
View
@@ -30,7 +30,7 @@ public QueueExecutable(Queue<VALUE> queue, TransactionExecutor executor) {
super(queue, executor);
}
- public static <VALUE> QueueExecutable<VALUE> getQueueByName(String name, DriverFactory factory, BaseTransactionExecutor executor) {
+ public static <VALUE> QueueExecutable<VALUE> getQueueByName(String name, DriverFactory factory) {
return new QueueExecutable<VALUE>(
new Queue<VALUE>(
new BaseVariable<ImmutableList<VALUE>>(new Name<ImmutableList<VALUE>>(name + "input"), factory.get(name + "-input", ImmutableList.<VALUE>of())),
@@ -40,6 +40,7 @@ public QueueExecutable(Queue<VALUE> queue, TransactionExecutor executor) {
);
}
+ @Override
public Queue<VALUE> getQueue() {
return (Queue<VALUE>)super.getQueue();
}
Please sign in to comment.
Something went wrong with that request. Please try again.