From 6747b0605f21df62c2a066f53d5d56dc89e8f841 Mon Sep 17 00:00:00 2001 From: Artem Bilan Date: Thu, 11 Jun 2015 16:02:07 -0400 Subject: [PATCH] Cassandra: polishing before release --- spring-integration-cassandra/build.gradle | 6 ++++-- .../cassandra/outbound/CassandraMessageHandler.java | 1 + 2 files changed, 5 insertions(+), 2 deletions(-) diff --git a/spring-integration-cassandra/build.gradle b/spring-integration-cassandra/build.gradle index ddf0bc0..b8aeea3 100644 --- a/spring-integration-cassandra/build.gradle +++ b/spring-integration-cassandra/build.gradle @@ -39,7 +39,7 @@ ext { jacocoVersion = '0.7.2.201409121644' slf4jVersion = '1.7.11' springDataCassandraVersion = '1.2.0.RELEASE' - springIntegrationVersion = '4.1.3.RELEASE' + springIntegrationVersion = '4.1.5.RELEASE' idPrefix = 'cassandra' @@ -70,7 +70,9 @@ configurations { dependencies { compile "org.springframework.integration:spring-integration-core:$springIntegrationVersion" - compile "org.springframework.data:spring-data-cassandra:$springDataCassandraVersion" + compile ("org.springframework.data:spring-data-cassandra:$springDataCassandraVersion") { + exclude group: 'org.liquibase', module: 'liquibase-core' + } testCompile "org.springframework.integration:spring-integration-test:$springIntegrationVersion" diff --git a/spring-integration-cassandra/src/main/java/org/springframework/integration/cassandra/outbound/CassandraMessageHandler.java b/spring-integration-cassandra/src/main/java/org/springframework/integration/cassandra/outbound/CassandraMessageHandler.java index ad1179d..e721291 100644 --- a/spring-integration-cassandra/src/main/java/org/springframework/integration/cassandra/outbound/CassandraMessageHandler.java +++ b/spring-integration-cassandra/src/main/java/org/springframework/integration/cassandra/outbound/CassandraMessageHandler.java @@ -86,6 +86,7 @@ public class CassandraMessageHandler extends AbstractReplyProducingMessageHan public void setIngestQuery(String ingestQuery) { Assert.hasText(ingestQuery, "'ingestQuery' must not be empty"); this.ingestQuery = ingestQuery; + this.queryType = Type.INSERT; } public void setWriteOptions(WriteOptions writeOptions) {