This is an automated email from the ASF dual-hosted git repository.
klund pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/geode.git
The following commit(s) were added to refs/heads/develop by this push:
new 8584c0c GEODE-5553: Revert one line in AsyncEventQueueFactoryImpl
8584c0c is described below
commit 8584c0cf1b47aa4e314acd87d4cc14ff76884c09
Author: Kirk Lund <[email protected]>
AuthorDate: Thu Aug 9 10:42:10 2018 -0700
GEODE-5553: Revert one line in AsyncEventQueueFactoryImpl
Fixes ClassCastException of SerialGatewaySenderQueue to
ConcurrentParallelGatewaySenderQueue in Lucene tests.
---
.../geode/cache/asyncqueue/internal/AsyncEventQueueFactoryImpl.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/geode-core/src/main/java/org/apache/geode/cache/asyncqueue/internal/AsyncEventQueueFactoryImpl.java
b/geode-core/src/main/java/org/apache/geode/cache/asyncqueue/internal/AsyncEventQueueFactoryImpl.java
index 0650c3c..517758c 100644
---
a/geode-core/src/main/java/org/apache/geode/cache/asyncqueue/internal/AsyncEventQueueFactoryImpl.java
+++
b/geode-core/src/main/java/org/apache/geode/cache/asyncqueue/internal/AsyncEventQueueFactoryImpl.java
@@ -204,7 +204,7 @@ public class AsyncEventQueueFactoryImpl implements
AsyncEventQueueFactory {
if (cache instanceof CacheCreation) {
sender = new ParallelAsyncEventQueueCreation(cache,
gatewaySenderAttributes);
} else {
- sender = new SerialAsyncEventQueueImpl(cache, gatewaySenderAttributes);
+ sender = new ParallelAsyncEventQueueImpl(cache,
gatewaySenderAttributes);
}
cache.addGatewaySender(sender);