You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by bo...@apache.org on 2016/04/06 19:00:42 UTC
[2/2] incubator-geode git commit: GEODE-1170: The GatewaySender for
the AsyncEventQueue is now marked internal
GEODE-1170: The GatewaySender for the AsyncEventQueue is now marked internal
Project: http://git-wip-us.apache.org/repos/asf/incubator-geode/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-geode/commit/abedde9a
Tree: http://git-wip-us.apache.org/repos/asf/incubator-geode/tree/abedde9a
Diff: http://git-wip-us.apache.org/repos/asf/incubator-geode/diff/abedde9a
Branch: refs/heads/develop
Commit: abedde9a7d6c039876a4a4976bee48e81f262228
Parents: 8622d63
Author: Barry Oglesby <bo...@pivotal.io>
Authored: Tue Apr 5 17:26:21 2016 -0700
Committer: Barry Oglesby <bo...@pivotal.io>
Committed: Wed Apr 6 10:00:32 2016 -0700
----------------------------------------------------------------------
.../cache/asyncqueue/internal/AsyncEventQueueFactoryImpl.java | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/abedde9a/geode-core/src/main/java/com/gemstone/gemfire/cache/asyncqueue/internal/AsyncEventQueueFactoryImpl.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/com/gemstone/gemfire/cache/asyncqueue/internal/AsyncEventQueueFactoryImpl.java b/geode-core/src/main/java/com/gemstone/gemfire/cache/asyncqueue/internal/AsyncEventQueueFactoryImpl.java
index 0d62944..d15222b 100644
--- a/geode-core/src/main/java/com/gemstone/gemfire/cache/asyncqueue/internal/AsyncEventQueueFactoryImpl.java
+++ b/geode-core/src/main/java/com/gemstone/gemfire/cache/asyncqueue/internal/AsyncEventQueueFactoryImpl.java
@@ -277,6 +277,7 @@ public class AsyncEventQueueFactoryImpl implements AsyncEventQueueFactory {
this.attrs.policy = asyncQueueCreation.getOrderPolicy();
this.attrs.eventFilters = asyncQueueCreation.getGatewayEventFilters();
this.attrs.eventSubstitutionFilter = asyncQueueCreation.getGatewayEventSubstitutionFilter();
+ this.attrs.isForInternalUse = true;
}