You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tinkerpop.apache.org by sp...@apache.org on 2015/06/03 18:26:55 UTC
[3/7] incubator-tinkerpop git commit: Renamed EventTrigger class to
EventQueue.
Renamed EventTrigger class to EventQueue.
Project: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/commit/d1a7b9ac
Tree: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/tree/d1a7b9ac
Diff: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/diff/d1a7b9ac
Branch: refs/heads/master
Commit: d1a7b9ac54a0d4cb78e2a6b3132cd781a219c5d2
Parents: 0daccb5
Author: Stephen Mallette <sp...@genoprime.com>
Authored: Wed Jun 3 08:20:06 2015 -0400
Committer: Stephen Mallette <sp...@genoprime.com>
Committed: Wed Jun 3 12:25:49 2015 -0400
----------------------------------------------------------------------
.../traversal/strategy/decoration/EventStrategy.java | 14 +++++++-------
1 file changed, 7 insertions(+), 7 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/d1a7b9ac/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/EventStrategy.java
----------------------------------------------------------------------
diff --git a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/EventStrategy.java b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/EventStrategy.java
index 3a787f6..a881260 100644
--- a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/EventStrategy.java
+++ b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/strategy/decoration/EventStrategy.java
@@ -59,7 +59,7 @@ public final class EventStrategy extends AbstractTraversalStrategy<TraversalStra
if (!traversal.getGraph().isPresent())
throw new IllegalStateException(String.format("%s requires a graph instance is present on the traversal", EventStrategy.class.getName()));
- final EventStrategyCallback callback = new EventStrategyCallback(new EventTrigger(traversal.getGraph().get()));
+ final EventStrategyCallback callback = new EventStrategyCallback(new EventQueue(traversal.getGraph().get()));
TraversalHelper.getStepsOfAssignableClass(Mutating.class, traversal).forEach(s -> s.getMutatingCallbackRegistry().addCallback(callback));
}
@@ -68,9 +68,9 @@ public final class EventStrategy extends AbstractTraversalStrategy<TraversalStra
}
public class EventStrategyCallback implements EventCallback<Event>, Serializable {
- private final EventTrigger trigger;
+ private final EventQueue trigger;
- public EventStrategyCallback(final EventTrigger trigger) {
+ public EventStrategyCallback(final EventQueue trigger) {
this.trigger = trigger;
}
@@ -85,7 +85,7 @@ public final class EventStrategy extends AbstractTraversalStrategy<TraversalStra
Builder() {}
- public Builder addListener(MutationListener listener) {
+ public Builder addListener(final MutationListener listener) {
this.listeners.add(listener);
return this;
}
@@ -95,7 +95,7 @@ public final class EventStrategy extends AbstractTraversalStrategy<TraversalStra
}
}
- class EventTrigger {
+ class EventQueue {
/**
* A queue of events that are triggered by change to the graph. The queue builds up until the trigger fires them
@@ -112,7 +112,7 @@ public final class EventStrategy extends AbstractTraversalStrategy<TraversalStra
*/
private final boolean enqueueEvents;
- public EventTrigger(final Graph graph) {
+ public EventQueue(final Graph graph) {
enqueueEvents = graph.features().graph().supportsTransactions();
if (enqueueEvents) {
@@ -124,7 +124,7 @@ public final class EventStrategy extends AbstractTraversalStrategy<TraversalStra
else if (status == Transaction.Status.ROLLBACK)
resetEventQueue();
else
- throw new RuntimeException(String.format("The %s is not aware of this status: %s", EventTrigger.class.getName(), status));
+ throw new RuntimeException(String.format("The %s is not aware of this status: %s", EventQueue.class.getName(), status));
});
}
}