[geode] 01/03: the created async queue in cluster config is now given a JdbcAsyncWriter

[ds...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

dschneider pushed a commit to branch feature/GEODE-6010
in repository https://gitbox.apache.org/repos/asf/geode.git

commit 9f4ede3bdad28941fd210cb6f463097d7d96ea1a
Author: Darrel Schneider <ds...@pivotal.io>
AuthorDate: Fri Nov 9 14:08:25 2018 -0800

    the created async queue in cluster config is now given a JdbcAsyncWriter
---
 .../geode/connectors/jdbc/internal/cli/CreateMappingCommand.java      | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/cli/CreateMappingCommand.java b/geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/cli/CreateMappingCommand.java
index 21ef915..c603e68 100644
--- a/geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/cli/CreateMappingCommand.java
+++ b/geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/cli/CreateMappingCommand.java
@@ -28,6 +28,7 @@ import org.apache.geode.cache.configuration.CacheConfig.AsyncEventQueue;
 import org.apache.geode.cache.configuration.DeclarableType;
 import org.apache.geode.cache.configuration.RegionAttributesType;
 import org.apache.geode.cache.configuration.RegionConfig;
+import org.apache.geode.connectors.jdbc.JdbcAsyncWriter;
 import org.apache.geode.connectors.jdbc.JdbcLoader;
 import org.apache.geode.connectors.jdbc.internal.configuration.RegionMapping;
 import org.apache.geode.distributed.ConfigurationPersistenceService;
@@ -164,6 +165,9 @@ public class CreateMappingCommand extends SingleGfshCommand {
     asyncEventQueue.setId(queueName);
     boolean isPartitioned = attributes.getPartitionAttributes() != null;
     asyncEventQueue.setParallel(isPartitioned);
+    DeclarableType listener = new DeclarableType();
+    listener.setClassName(JdbcAsyncWriter.class.getName());
+    asyncEventQueue.setAsyncEventListener(listener);
     cacheConfig.getAsyncEventQueues().add(asyncEventQueue);
   }