You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2018/07/26 09:34:58 UTC
[camel] branch master updated: Camel-Nats: refactored some tests
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/master by this push:
new 01422c2 Camel-Nats: refactored some tests
01422c2 is described below
commit 01422c28693258734eb065e4e67191fb1e98c414
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Thu Jul 26 11:31:06 2018 +0200
Camel-Nats: refactored some tests
---
.../test/java/org/apache/camel/component/nats/NatsConsumerLoadTest.java | 1 -
.../apache/camel/component/nats/NatsConsumerWithConnectionLoadTest.java | 2 +-
2 files changed, 1 insertion(+), 2 deletions(-)
diff --git a/components/camel-nats/src/test/java/org/apache/camel/component/nats/NatsConsumerLoadTest.java b/components/camel-nats/src/test/java/org/apache/camel/component/nats/NatsConsumerLoadTest.java
index 831f9b6..c040f9b 100644
--- a/components/camel-nats/src/test/java/org/apache/camel/component/nats/NatsConsumerLoadTest.java
+++ b/components/camel-nats/src/test/java/org/apache/camel/component/nats/NatsConsumerLoadTest.java
@@ -51,7 +51,6 @@ public class NatsConsumerLoadTest extends NatsTestSupport {
return new RouteBuilder() {
@Override
public void configure() throws Exception {
- from("direct:send").to("nats://" + getNatsUrl() + "?topic=test");
from("nats://" + getNatsUrl() + "?topic=test").to(mockResultEndpoint);
}
};
diff --git a/components/camel-nats/src/test/java/org/apache/camel/component/nats/NatsConsumerWithConnectionLoadTest.java b/components/camel-nats/src/test/java/org/apache/camel/component/nats/NatsConsumerWithConnectionLoadTest.java
index bea960d..e16a78a 100644
--- a/components/camel-nats/src/test/java/org/apache/camel/component/nats/NatsConsumerWithConnectionLoadTest.java
+++ b/components/camel-nats/src/test/java/org/apache/camel/component/nats/NatsConsumerWithConnectionLoadTest.java
@@ -47,7 +47,7 @@ public class NatsConsumerWithConnectionLoadTest extends NatsTestSupport {
Options options = new Options.Builder().server("nats://" + getNatsUrl()).build();
Connection connection = Nats.connect(options);
- for (int i = 0; i < 10000; i++) {
+ for (int i = 0; i < 100; i++) {
connection.publish("test", ("test" + i).getBytes());
}