You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tomee.apache.org by jg...@apache.org on 2021/06/16 13:36:23 UTC
[tomee-chatterbox] 04/06: Add basic test to isolate timeout issue
from the resource adapter
This is an automated email from the ASF dual-hosted git repository.
jgallimore pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/tomee-chatterbox.git
commit 5beef6afd49c250e87aaace35cd86aebbf3398e6
Author: Jonathan Gallimore <jo...@jrg.me.uk>
AuthorDate: Wed Jun 9 14:19:39 2021 +0100
Add basic test to isolate timeout issue from the resource adapter
---
.../nats/adapter/NATSResourceAdapter.java | 2 +-
.../tomee/chatterbox/nats/adapter/NATSTest.java | 22 ++++++++++++++++++++++
2 files changed, 23 insertions(+), 1 deletion(-)
diff --git a/chatterbox-nats/chatterbox-nats-impl/src/main/java/org/apache/tomee/chatterbox/nats/adapter/NATSResourceAdapter.java b/chatterbox-nats/chatterbox-nats-impl/src/main/java/org/apache/tomee/chatterbox/nats/adapter/NATSResourceAdapter.java
index 4ed4485..fdea9a8 100644
--- a/chatterbox-nats/chatterbox-nats-impl/src/main/java/org/apache/tomee/chatterbox/nats/adapter/NATSResourceAdapter.java
+++ b/chatterbox-nats/chatterbox-nats-impl/src/main/java/org/apache/tomee/chatterbox/nats/adapter/NATSResourceAdapter.java
@@ -73,7 +73,7 @@ public class NATSResourceAdapter implements ResourceAdapter {
try {
cf = new
StreamingConnectionFactory(new Options.Builder().natsUrl(baseAddress)
- .clusterId("cluster-id").clientId("client-id").build());
+ .clusterId("cluster-id").clientId("yourclientid").build());
connection = cf.createConnection();
} catch (Throwable t) {
diff --git a/chatterbox-nats/chatterbox-nats-impl/src/test/java/org/apache/tomee/chatterbox/nats/adapter/NATSTest.java b/chatterbox-nats/chatterbox-nats-impl/src/test/java/org/apache/tomee/chatterbox/nats/adapter/NATSTest.java
new file mode 100644
index 0000000..d2e4258
--- /dev/null
+++ b/chatterbox-nats/chatterbox-nats-impl/src/test/java/org/apache/tomee/chatterbox/nats/adapter/NATSTest.java
@@ -0,0 +1,22 @@
+package org.apache.tomee.chatterbox.nats.adapter;
+
+import io.nats.streaming.Options;
+import io.nats.streaming.StreamingConnection;
+import io.nats.streaming.StreamingConnectionFactory;
+import org.junit.Assert;
+import org.junit.Test;
+
+public class NATSTest {
+
+ @Test
+ public void testShouldConnect() throws Exception {
+ StreamingConnectionFactory cf = new
+ StreamingConnectionFactory(new Options.Builder().natsUrl("nats://localhost:4222")
+ .clusterId("cluster-id").clientId("yourclientid").build());
+
+ final StreamingConnection connection = cf.createConnection();
+ Assert.assertNotNull(connection);
+
+ connection.close();
+ }
+}