You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2015/09/04 09:36:19 UTC
[2/2] camel git commit: Fixed CS. This closes #603.
Fixed CS. This closes #603.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/23456b66
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/23456b66
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/23456b66
Branch: refs/heads/master
Commit: 23456b66fc11a58dcf6990bd6a266dc02410949e
Parents: 7fb272b
Author: Claus Ibsen <da...@apache.org>
Authored: Fri Sep 4 09:37:01 2015 +0200
Committer: Claus Ibsen <da...@apache.org>
Committed: Fri Sep 4 09:37:01 2015 +0200
----------------------------------------------------------------------
.../CassandraComponentProducerTest.java | 20 ++++++++++----------
1 file changed, 10 insertions(+), 10 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/23456b66/components/camel-cassandraql/src/test/java/org/apache/camel/component/cassandra/CassandraComponentProducerTest.java
----------------------------------------------------------------------
diff --git a/components/camel-cassandraql/src/test/java/org/apache/camel/component/cassandra/CassandraComponentProducerTest.java b/components/camel-cassandraql/src/test/java/org/apache/camel/component/cassandra/CassandraComponentProducerTest.java
index 3bba78c..798a008 100644
--- a/components/camel-cassandraql/src/test/java/org/apache/camel/component/cassandra/CassandraComponentProducerTest.java
+++ b/components/camel-cassandraql/src/test/java/org/apache/camel/component/cassandra/CassandraComponentProducerTest.java
@@ -58,10 +58,10 @@ public class CassandraComponentProducerTest extends CamelTestSupport {
@Produce(uri = "direct:inputNotConsistent")
ProducerTemplate notConsistentProducerTemplate;
-
+
@Produce(uri = "direct:loadBalancingPolicy")
ProducerTemplate loadBalancingPolicyTemplate;
-
+
@Produce(uri = "direct:inputNoEndpointCql")
ProducerTemplate producerTemplateNoEndpointCql;
@@ -89,7 +89,7 @@ public class CassandraComponentProducerTest extends CamelTestSupport {
from("direct:inputNotConsistent")
.to(NOT_CONSISTENT_URI);
from("direct:inputNoEndpointCql")
- .to("cql://localhost/camel_ks");
+ .to("cql://localhost/camel_ks");
}
};
}
@@ -142,7 +142,7 @@ public class CassandraComponentProducerTest extends CamelTestSupport {
session.close();
cluster.close();
}
-
+
@Test
public void testLoadBalancing() throws Exception {
Object response = loadBalancingPolicyTemplate.requestBodyAndHeader(new Object[]{"Claus 2", "Ibsen 2", "c_ibsen"},
@@ -181,7 +181,7 @@ public class CassandraComponentProducerTest extends CamelTestSupport {
session.close();
cluster.close();
}
-
+
/**
* Simulate different CQL statements in the incoming message containing a header with RegularStatement, justifying the cassandracql endpoint not containing a "cql" Uri parameter
*/
@@ -191,9 +191,9 @@ public class CassandraComponentProducerTest extends CamelTestSupport {
.with(set("first_name", bindMarker()))
.where(eq("login", bindMarker()));
@SuppressWarnings("unused")
- Object response1 = producerTemplateNoEndpointCql.requestBodyAndHeader(new Object[]{"Claus 2", "c_ibsen"},
+ Object response1 = producerTemplateNoEndpointCql.requestBodyAndHeader(new Object[]{"Claus 2", "c_ibsen"},
CassandraConstants.CQL_QUERY, updateFirstName);
-
+
Cluster cluster = CassandraUnitUtils.cassandraCluster();
Session session = cluster.connect(CassandraUnitUtils.KEYSPACE);
ResultSet resultSet1 = session.execute("select login, first_name, last_name from camel_user where login = ?", "c_ibsen");
@@ -201,14 +201,14 @@ public class CassandraComponentProducerTest extends CamelTestSupport {
assertNotNull(row1);
assertEquals("Claus 2", row1.getString("first_name"));
assertEquals("Ibsen", row1.getString("last_name"));
-
+
Update.Where updateLastName = update("camel_user")
.with(set("last_name", bindMarker()))
.where(eq("login", bindMarker()));
@SuppressWarnings("unused")
- Object response2 = producerTemplateNoEndpointCql.requestBodyAndHeader(new Object[]{"Ibsen 2", "c_ibsen"},
+ Object response2 = producerTemplateNoEndpointCql.requestBodyAndHeader(new Object[]{"Ibsen 2", "c_ibsen"},
CassandraConstants.CQL_QUERY, updateLastName);
-
+
ResultSet resultSet2 = session.execute("select login, first_name, last_name from camel_user where login = ?", "c_ibsen");
Row row2 = resultSet2.one();
assertNotNull(row2);