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 <j...@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(); + } +}