Spring/spring-integration-extensions
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Cassandra: polishing before release

Browse Source
This commit is contained in:
Artem Bilan
2015-06-11 16:02:07 -04:00
parent 2bcd54cfba
commit 6747b0605f
2 changed files with 5 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
spring-integration-cassandra/build.gradle
View File

@@ -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"

1
spring-integration-cassandra/src/main/java/org/springframework/integration/cassandra/outbound/CassandraMessageHandler.java
View File

@@ -86,6 +86,7 @@ public class CassandraMessageHandler<T> 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) {