Added default NOOP instance for idempotency manager
Project: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/commit/4dc4788f Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/tree/4dc4788f Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/diff/4dc4788f Branch: refs/heads/master Commit: 4dc4788f74178509eb01cc1d4402522601095dcd Parents: 13a3fbe Author: ishark <[email protected]> Authored: Tue Aug 11 15:10:01 2015 -0700 Committer: ishark <[email protected]> Committed: Tue Aug 11 15:10:01 2015 -0700 ---------------------------------------------------------------------- contrib/pom.xml | 6 ------ .../contrib/rabbitmq/AbstractRabbitMQInputOperator.java | 1 + 2 files changed, 1 insertion(+), 6 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/4dc4788f/contrib/pom.xml ---------------------------------------------------------------------- diff --git a/contrib/pom.xml b/contrib/pom.xml index 76e8144..9776e2f 100755 --- a/contrib/pom.xml +++ b/contrib/pom.xml @@ -565,11 +565,5 @@ <version>${dt.framework.version}</version> <type>jar</type> </dependency> - <dependency> - <groupId>com.datatorrent</groupId> - <artifactId>dt-engine</artifactId> - <version>${dt.framework.version}</version> - <scope>test</scope> - </dependency> </dependencies> </project> http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/4dc4788f/contrib/src/main/java/com/datatorrent/contrib/rabbitmq/AbstractRabbitMQInputOperator.java ---------------------------------------------------------------------- diff --git a/contrib/src/main/java/com/datatorrent/contrib/rabbitmq/AbstractRabbitMQInputOperator.java b/contrib/src/main/java/com/datatorrent/contrib/rabbitmq/AbstractRabbitMQInputOperator.java index e408f5e..955a2c8 100644 --- a/contrib/src/main/java/com/datatorrent/contrib/rabbitmq/AbstractRabbitMQInputOperator.java +++ b/contrib/src/main/java/com/datatorrent/contrib/rabbitmq/AbstractRabbitMQInputOperator.java @@ -111,6 +111,7 @@ public abstract class AbstractRabbitMQInputOperator<T> implements currentWindowRecoveryState = new HashMap<Long, byte[]>(); pendingAck = new HashSet<Long>(); recoveredTags = new HashSet<Long>(); + idempotentStorageManager = new IdempotentStorageManager.NoopIdempotentStorageManager(); }
