You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by ds...@apache.org on 2018/11/09 23:36:33 UTC
[geode] 02/03: validates JdbcAsyncWriter
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 032959199191ab67476dbd4c2b6595c13fd2c886
Author: Darrel Schneider <ds...@pivotal.io>
AuthorDate: Fri Nov 9 14:12:32 2018 -0800
validates JdbcAsyncWriter
---
.../connectors/jdbc/internal/cli/CreateMappingCommandTest.java | 8 ++++++--
1 file changed, 6 insertions(+), 2 deletions(-)
diff --git a/geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/cli/CreateMappingCommandTest.java b/geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/cli/CreateMappingCommandTest.java
index c10f8b1..3bf8c7b 100644
--- a/geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/cli/CreateMappingCommandTest.java
+++ b/geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/cli/CreateMappingCommandTest.java
@@ -40,6 +40,7 @@ import org.apache.geode.cache.configuration.DeclarableType;
import org.apache.geode.cache.configuration.RegionAttributesType;
import org.apache.geode.cache.configuration.RegionAttributesType.PartitionAttributes;
import org.apache.geode.cache.configuration.RegionConfig;
+import org.apache.geode.connectors.jdbc.JdbcAsyncWriter;
import org.apache.geode.connectors.jdbc.internal.configuration.RegionMapping;
import org.apache.geode.distributed.ConfigurationPersistenceService;
import org.apache.geode.distributed.internal.DistributionManager;
@@ -311,8 +312,11 @@ public class CreateMappingCommandTest {
assertThat(queueList.size()).isEqualTo(1);
String queueName = CreateMappingCommand.getAsyncEventQueueName(regionName);
- assertThat(queueList.get(0).getId()).isEqualTo(queueName);
- assertThat(queueList.get(0).isParallel()).isFalse();
+ AsyncEventQueue createdQueue = queueList.get(0);
+ assertThat(createdQueue.getId()).isEqualTo(queueName);
+ assertThat(createdQueue.isParallel()).isFalse();
+ assertThat(createdQueue.getAsyncEventListener().getClassName())
+ .isEqualTo(JdbcAsyncWriter.class.getName());
}
@Test