Add basic test to isolate timeout issue from the resource adapter
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 @@
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();
+ }
+}
