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:19 UTC
[tomee-chatterbox] branch master updated (85ac5cc -> 6d150f9)
This is an automated email from the ASF dual-hosted git repository.
jgallimore pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/tomee-chatterbox.git.
from 85ac5cc Ensure we close the store when we have finished with it
new 267d824 Bootstrap a NATS JCA Adapter
new ccb9450 WIP
new 0a41080 Wrap the message in a proxy, so we don't need all the libraries the NATS Streaming client uses in TomEE's classpath
new 5beef6a Add basic test to isolate timeout issue from the resource adapter
new 0450a33 Basic adapter working end-to-end. Some more fine tuning needed.
new 6d150f9 Adding parameters and logging
The 6 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
{chatterbox-slack => chatterbox-nats}/.gitignore | 0
.../chatterbox-nats-api}/pom.xml | 6 +-
.../chatterbox/nats}/api/InboundListener.java | 5 +-
.../tomee/chatterbox/nats/api/NATSConnection.java | 6 +-
.../chatterbox/nats/api/NATSConnectionFactory.java | 6 +-
.../tomee/chatterbox/nats/api/NATSException.java | 24 ++-
.../tomee/chatterbox/nats/api/NATSMessage.java | 28 +--
.../src/main/resources/META-INF/LICENSE | 0
.../src/main/resources/META-INF/NOTICE | 0
.../chatterbox-nats-impl}/pom.xml | 21 +--
.../nats/adapter/NATSActivationSpec.java | 23 +--
.../nats/adapter/NATSResourceAdapter.java | 210 +++++++++++++++++++++
.../adapter/out/NATSConnectionFactoryImpl.java | 20 +-
.../nats/adapter/out/NATSConnectionImpl.java | 20 +-
.../nats/adapter/out/NATSManagedConnection.java | 33 ++--
.../adapter/out/NATSManagedConnectionFactory.java | 26 +--
.../adapter/out/NATSManagedConnectionMetaData.java | 8 +-
.../src/main/resources/META-INF/LICENSE | 0
.../src/main/resources/META-INF/NOTICE | 0
.../chatterbox-nats-rar}/pom.xml | 8 +-
.../src/main/rar}/META-INF/LICENSE | 0
.../src/main/rar/META-INF/NOTICE | 0
.../src/main/rar/META-INF/ra.xml | 37 ++--
.../chatterbox-nats-sample-war}/pom.xml | 16 +-
.../src/main/java/org/superbiz/EchoBean.java | 51 ++---
.../src/main/java/org/superbiz/Sender.java | 19 +-
.../src/main/resources/META-INF/LICENSE | 0
.../src/main/resources/META-INF/NOTICE | 0
.../src/main/resources/META-INF/ejb-jar.xml | 0
chatterbox-nats/docker-compose.yml | 35 ++++
{chatterbox-slack => chatterbox-nats}/pom.xml | 12 +-
pom.xml | 1 +
32 files changed, 423 insertions(+), 192 deletions(-)
copy {chatterbox-slack => chatterbox-nats}/.gitignore (100%)
copy {chatterbox-slack/chatterbox-slack-api => chatterbox-nats/chatterbox-nats-api}/pom.xml (92%)
copy {chatterbox-slack/chatterbox-slack-api/src/main/java/org/apache/tomee/chatterbox/slack => chatterbox-nats/chatterbox-nats-api/src/main/java/org/apache/tomee/chatterbox/nats}/api/InboundListener.java (87%)
copy chatterbox-twitter/chatterbox-twitter-api/src/main/java/org/apache/tomee/chatterbox/twitter/api/TwitterConnection.java => chatterbox-nats/chatterbox-nats-api/src/main/java/org/apache/tomee/chatterbox/nats/api/NATSConnection.java (83%)
copy chatterbox-xmpp/chatterbox-xmpp-api/src/main/java/org/apache/tomee/chatterbox/xmpp/api/XMPPConnectionFactory.java => chatterbox-nats/chatterbox-nats-api/src/main/java/org/apache/tomee/chatterbox/nats/api/NATSConnectionFactory.java (84%)
copy chatterbox-twitter/chatterbox-twitter-api/src/main/java/org/apache/tomee/chatterbox/twitter/api/TweetException.java => chatterbox-nats/chatterbox-nats-api/src/main/java/org/apache/tomee/chatterbox/nats/api/NATSException.java (64%)
copy chatterbox-imap/chatterbox-imap-api/src/main/java/org/apache/tomee/chatterbox/imap/api/FromParam.java => chatterbox-nats/chatterbox-nats-api/src/main/java/org/apache/tomee/chatterbox/nats/api/NATSMessage.java (60%)
copy {chatterbox-xmpp/chatterbox-xmpp-sample-war => chatterbox-nats/chatterbox-nats-api}/src/main/resources/META-INF/LICENSE (100%)
copy {chatterbox-slack/chatterbox-slack-api => chatterbox-nats/chatterbox-nats-api}/src/main/resources/META-INF/NOTICE (100%)
copy {chatterbox-twitter/chatterbox-twitter-impl => chatterbox-nats/chatterbox-nats-impl}/pom.xml (78%)
copy chatterbox-slack/chatterbox-slack-impl/src/main/java/org/apache/tomee/chatterbox/slack/adapter/SlackActivationSpec.java => chatterbox-nats/chatterbox-nats-impl/src/main/java/org/apache/tomee/chatterbox/nats/adapter/NATSActivationSpec.java (81%)
create mode 100644 chatterbox-nats/chatterbox-nats-impl/src/main/java/org/apache/tomee/chatterbox/nats/adapter/NATSResourceAdapter.java
copy chatterbox-xmpp/chatterbox-xmpp-impl/src/main/java/org/apache/tomee/chatterbox/xmpp/impl/XMPPConnectionFactoryImpl.java => chatterbox-nats/chatterbox-nats-impl/src/main/java/org/apache/tomee/chatterbox/nats/adapter/out/NATSConnectionFactoryImpl.java (74%)
copy chatterbox-xmpp/chatterbox-xmpp-impl/src/main/java/org/apache/tomee/chatterbox/xmpp/impl/XMPPConnectionImpl.java => chatterbox-nats/chatterbox-nats-impl/src/main/java/org/apache/tomee/chatterbox/nats/adapter/out/NATSConnectionImpl.java (64%)
copy chatterbox-xmpp/chatterbox-xmpp-impl/src/main/java/org/apache/tomee/chatterbox/xmpp/impl/XMPPManagedConnection.java => chatterbox-nats/chatterbox-nats-impl/src/main/java/org/apache/tomee/chatterbox/nats/adapter/out/NATSManagedConnection.java (80%)
copy chatterbox-slack/chatterbox-slack-impl/src/main/java/org/apache/tomee/chatterbox/slack/adapter/out/SlackManagedConnectionFactory.java => chatterbox-nats/chatterbox-nats-impl/src/main/java/org/apache/tomee/chatterbox/nats/adapter/out/NATSManagedConnectionFactory.java (78%)
copy chatterbox-xmpp/chatterbox-xmpp-impl/src/main/java/org/apache/tomee/chatterbox/xmpp/impl/XMPPManagedConnectionMetaData.java => chatterbox-nats/chatterbox-nats-impl/src/main/java/org/apache/tomee/chatterbox/nats/adapter/out/NATSManagedConnectionMetaData.java (87%)
copy {chatterbox-xmpp/chatterbox-xmpp-sample-war => chatterbox-nats/chatterbox-nats-impl}/src/main/resources/META-INF/LICENSE (100%)
copy {chatterbox-slack/chatterbox-slack-impl => chatterbox-nats/chatterbox-nats-impl}/src/main/resources/META-INF/NOTICE (100%)
copy {chatterbox-imap/chatterbox-imap-rar => chatterbox-nats/chatterbox-nats-rar}/pom.xml (87%)
copy {chatterbox-xmpp/chatterbox-xmpp-sample-war/src/main/resources => chatterbox-nats/chatterbox-nats-rar/src/main/rar}/META-INF/LICENSE (100%)
copy {chatterbox-slack/chatterbox-slack-rar => chatterbox-nats/chatterbox-nats-rar}/src/main/rar/META-INF/NOTICE (100%)
copy {chatterbox-twitter/chatterbox-twitter-rar => chatterbox-nats/chatterbox-nats-rar}/src/main/rar/META-INF/ra.xml (62%)
copy {chatterbox-slack/chatterbox-slack-sample-war => chatterbox-nats/chatterbox-nats-sample-war}/pom.xml (83%)
copy chatterbox-slack/chatterbox-slack-sample-war/src/main/java/org/superbiz/SystemBean.java => chatterbox-nats/chatterbox-nats-sample-war/src/main/java/org/superbiz/EchoBean.java (50%)
copy {chatterbox-slack/chatterbox-slack-sample-war => chatterbox-nats/chatterbox-nats-sample-war}/src/main/java/org/superbiz/Sender.java (71%)
copy {chatterbox-xmpp/chatterbox-xmpp-sample-war => chatterbox-nats/chatterbox-nats-sample-war}/src/main/resources/META-INF/LICENSE (100%)
copy {chatterbox-slack/chatterbox-slack-sample-war => chatterbox-nats/chatterbox-nats-sample-war}/src/main/resources/META-INF/NOTICE (100%)
copy {chatterbox-slack/chatterbox-slack-sample-war => chatterbox-nats/chatterbox-nats-sample-war}/src/main/resources/META-INF/ejb-jar.xml (100%)
create mode 100644 chatterbox-nats/docker-compose.yml
copy {chatterbox-slack => chatterbox-nats}/pom.xml (96%)
[tomee-chatterbox] 06/06: Adding parameters and logging
Posted by jg...@apache.org.
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 6d150f94cd8f62ca94327b654c7c8d4aa2f28bed
Author: Jonathan Gallimore <jo...@jrg.me.uk>
AuthorDate: Wed Jun 16 14:35:24 2021 +0100
Adding parameters and logging
---
.../nats/adapter/NATSResourceAdapter.java | 23 ++++++++++++++--------
.../src/main/rar/META-INF/ra.xml | 8 ++++++++
chatterbox-nats/docker-compose.yml | 2 +-
3 files changed, 24 insertions(+), 9 deletions(-)
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 cfbbf41..2f52de6 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
@@ -45,10 +45,13 @@ import java.lang.reflect.Proxy;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
import java.lang.IllegalStateException;
+import java.util.logging.Level;
+import java.util.logging.Logger;
@Connector(description = "Sample Resource Adapter", displayName = "Sample Resource Adapter", eisType = "Sample Resource Adapter", version = "1.0")
public class NATSResourceAdapter implements ResourceAdapter {
- final Map<NATSActivationSpec, EndpointTarget> targets = new ConcurrentHashMap<NATSActivationSpec, EndpointTarget>();
+ private static final Logger LOGGER = Logger.getLogger(NATSResourceAdapter.class.getName());
+ private final Map<NATSActivationSpec, EndpointTarget> targets = new ConcurrentHashMap<NATSActivationSpec, EndpointTarget>();
private static final Method ONMESSAGE;
@@ -63,6 +66,12 @@ public class NATSResourceAdapter implements ResourceAdapter {
@ConfigProperty
private String baseAddress;
+ @ConfigProperty
+ private String clientId;
+
+ @ConfigProperty
+ private String clusterId;
+
private WorkManager workManager;
private StreamingConnectionFactory cf;
private StreamingConnection connection;
@@ -73,12 +82,11 @@ public class NATSResourceAdapter implements ResourceAdapter {
try {
cf = new
StreamingConnectionFactory(new Options.Builder().natsUrl(baseAddress)
- .clusterId("yourclientid").clientId("anythingyoulike").build());
+ .clusterId(clusterId).clientId(clientId).build());
connection = cf.createConnection();
} catch (Throwable t) {
- // TODO: log this
- t.printStackTrace();
+ LOGGER.log(Level.SEVERE, "Error starting connection to NATS server", t);
}
}
@@ -86,7 +94,7 @@ public class NATSResourceAdapter implements ResourceAdapter {
try {
connection.close();
} catch (Throwable t) {
- // TODO: log this
+ LOGGER.log(Level.SEVERE, "Error closing connection to NATS server", t);
}
}
@@ -136,7 +144,6 @@ public class NATSResourceAdapter implements ResourceAdapter {
}
public void publish(final String subject, final byte[] data) throws NATSException {
- // publish a message
try {
connection.publish(subject, data);
} catch (Exception e) {
@@ -178,7 +185,7 @@ public class NATSResourceAdapter implements ResourceAdapter {
messageEndpoint.afterDelivery();
}
} catch (Throwable t) {
- // TODO: log this
+ LOGGER.log(Level.SEVERE, "Error dispatching message from NATS to MDB endpoint", t);
}
}
@@ -196,7 +203,7 @@ public class NATSResourceAdapter implements ResourceAdapter {
subscription.close(true);
}
} catch (IOException e) {
- // TODO: log this
+ LOGGER.log(Level.SEVERE, "Error closing subscription to NATS subject", e);
}
}
}
diff --git a/chatterbox-nats/chatterbox-nats-rar/src/main/rar/META-INF/ra.xml b/chatterbox-nats/chatterbox-nats-rar/src/main/rar/META-INF/ra.xml
index 3d4ed8e..790de56 100644
--- a/chatterbox-nats/chatterbox-nats-rar/src/main/rar/META-INF/ra.xml
+++ b/chatterbox-nats/chatterbox-nats-rar/src/main/rar/META-INF/ra.xml
@@ -35,6 +35,14 @@
<config-property-name>baseAddress</config-property-name>
<config-property-type>String</config-property-type>
</config-property>
+ <config-property>
+ <config-property-name>clientId</config-property-name>
+ <config-property-type>String</config-property-type>
+ </config-property>
+ <config-property>
+ <config-property-name>clusterId</config-property-name>
+ <config-property-type>String</config-property-type>
+ </config-property>
<outbound-resourceadapter>
<connection-definition>
<managedconnectionfactory-class>org.apache.tomee.chatterbox.nats.adapter.out.NATSManagedConnectionFactory
diff --git a/chatterbox-nats/docker-compose.yml b/chatterbox-nats/docker-compose.yml
index f1dab81..7d94584 100644
--- a/chatterbox-nats/docker-compose.yml
+++ b/chatterbox-nats/docker-compose.yml
@@ -16,7 +16,7 @@ services:
- '2'
- '-SD'
- '-cid'
- - 'yourclientid'
+ - 'mycluster'
environment:
TZ: Europe/London
LANG: en_GB.UTF-8
[tomee-chatterbox] 02/06: WIP
Posted by jg...@apache.org.
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 ccb9450089f0d3c6dbf39e8455c53e6eb7271fe1
Author: Jonathan Gallimore <jo...@jrg.me.uk>
AuthorDate: Wed Jun 9 11:44:40 2021 +0100
WIP
---
chatterbox-nats/chatterbox-nats-api/pom.xml | 6 ++
.../tomee/chatterbox/nats/api/InboundListener.java | 4 +-
.../tomee/chatterbox/nats/api/NATSConnection.java | 2 +-
.../tomee/chatterbox/nats/api/NATSException.java | 18 ++++
.../tomee/chatterbox/nats/api/NATSMessage.java | 23 -----
chatterbox-nats/chatterbox-nats-impl/pom.xml | 1 +
.../nats/adapter/NATSActivationSpec.java | 9 ++
.../nats/adapter/NATSResourceAdapter.java | 101 +++++++++++++++++----
.../nats/adapter/out/NATSConnectionImpl.java | 5 +-
.../nats/adapter/out/NATSManagedConnection.java | 5 +-
.../src/main/rar/META-INF/ra.xml | 14 +--
chatterbox-nats/chatterbox-nats-sample-war/pom.xml | 9 +-
.../superbiz/{SystemBean.java => EchoBean.java} | 22 ++++-
.../src/main/java/org/superbiz/Sender.java | 11 ++-
14 files changed, 166 insertions(+), 64 deletions(-)
diff --git a/chatterbox-nats/chatterbox-nats-api/pom.xml b/chatterbox-nats/chatterbox-nats-api/pom.xml
index 6f4ca62..db16e68 100644
--- a/chatterbox-nats/chatterbox-nats-api/pom.xml
+++ b/chatterbox-nats/chatterbox-nats-api/pom.xml
@@ -45,5 +45,11 @@
<artifactId>javaee-api</artifactId>
<scope>provided</scope>
</dependency>
+ <dependency>
+ <groupId>io.nats</groupId>
+ <artifactId>java-nats-streaming</artifactId>
+ <version>2.2.3</version>
+ <scope>provided</scope>
+ </dependency>
</dependencies>
</project>
diff --git a/chatterbox-nats/chatterbox-nats-api/src/main/java/org/apache/tomee/chatterbox/nats/api/InboundListener.java b/chatterbox-nats/chatterbox-nats-api/src/main/java/org/apache/tomee/chatterbox/nats/api/InboundListener.java
index 5f7ea6c..94d6294 100644
--- a/chatterbox-nats/chatterbox-nats-api/src/main/java/org/apache/tomee/chatterbox/nats/api/InboundListener.java
+++ b/chatterbox-nats/chatterbox-nats-api/src/main/java/org/apache/tomee/chatterbox/nats/api/InboundListener.java
@@ -16,11 +16,13 @@
*/
package org.apache.tomee.chatterbox.nats.api;
+import io.nats.streaming.Message;
+
/**
* @version $Revision$ $Date$
*/
public interface InboundListener {
- public void onMessage(final NATSMessage message) throws NATSException;
+ public void onMessage(final Message message) throws NATSException;
}
diff --git a/chatterbox-nats/chatterbox-nats-api/src/main/java/org/apache/tomee/chatterbox/nats/api/NATSConnection.java b/chatterbox-nats/chatterbox-nats-api/src/main/java/org/apache/tomee/chatterbox/nats/api/NATSConnection.java
index e323dd1..8b39874 100755
--- a/chatterbox-nats/chatterbox-nats-api/src/main/java/org/apache/tomee/chatterbox/nats/api/NATSConnection.java
+++ b/chatterbox-nats/chatterbox-nats-api/src/main/java/org/apache/tomee/chatterbox/nats/api/NATSConnection.java
@@ -20,7 +20,7 @@
package org.apache.tomee.chatterbox.nats.api;
public interface NATSConnection {
- public void sendMessage(final String channel, final String message);
+ public void publish(final String subject, final byte[] data) throws NATSException;
public void close();
}
diff --git a/chatterbox-nats/chatterbox-nats-api/src/main/java/org/apache/tomee/chatterbox/nats/api/NATSException.java b/chatterbox-nats/chatterbox-nats-api/src/main/java/org/apache/tomee/chatterbox/nats/api/NATSException.java
index 031ad42..b761cd3 100644
--- a/chatterbox-nats/chatterbox-nats-api/src/main/java/org/apache/tomee/chatterbox/nats/api/NATSException.java
+++ b/chatterbox-nats/chatterbox-nats-api/src/main/java/org/apache/tomee/chatterbox/nats/api/NATSException.java
@@ -20,4 +20,22 @@ package org.apache.tomee.chatterbox.nats.api;
* @version $Revision$ $Date$
*/
public class NATSException extends Exception {
+ public NATSException() {
+ }
+
+ public NATSException(String message) {
+ super(message);
+ }
+
+ public NATSException(String message, Throwable cause) {
+ super(message, cause);
+ }
+
+ public NATSException(Throwable cause) {
+ super(cause);
+ }
+
+ public NATSException(String message, Throwable cause, boolean enableSuppression, boolean writableStackTrace) {
+ super(message, cause, enableSuppression, writableStackTrace);
+ }
}
diff --git a/chatterbox-nats/chatterbox-nats-api/src/main/java/org/apache/tomee/chatterbox/nats/api/NATSMessage.java b/chatterbox-nats/chatterbox-nats-api/src/main/java/org/apache/tomee/chatterbox/nats/api/NATSMessage.java
deleted file mode 100644
index afb7718..0000000
--- a/chatterbox-nats/chatterbox-nats-api/src/main/java/org/apache/tomee/chatterbox/nats/api/NATSMessage.java
+++ /dev/null
@@ -1,23 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.tomee.chatterbox.nats.api;
-
-/**
- * @version $Revision$ $Date$
- */
-public class NATSMessage {
-}
diff --git a/chatterbox-nats/chatterbox-nats-impl/pom.xml b/chatterbox-nats/chatterbox-nats-impl/pom.xml
index fbe5f30..d46e53a 100644
--- a/chatterbox-nats/chatterbox-nats-impl/pom.xml
+++ b/chatterbox-nats/chatterbox-nats-impl/pom.xml
@@ -59,6 +59,7 @@
<groupId>io.nats</groupId>
<artifactId>java-nats-streaming</artifactId>
<version>2.2.3</version>
+ <scope>provided</scope>
</dependency>
</dependencies>
</project>
diff --git a/chatterbox-nats/chatterbox-nats-impl/src/main/java/org/apache/tomee/chatterbox/nats/adapter/NATSActivationSpec.java b/chatterbox-nats/chatterbox-nats-impl/src/main/java/org/apache/tomee/chatterbox/nats/adapter/NATSActivationSpec.java
index 4b62580..1a2fcc4 100644
--- a/chatterbox-nats/chatterbox-nats-impl/src/main/java/org/apache/tomee/chatterbox/nats/adapter/NATSActivationSpec.java
+++ b/chatterbox-nats/chatterbox-nats-impl/src/main/java/org/apache/tomee/chatterbox/nats/adapter/NATSActivationSpec.java
@@ -29,6 +29,7 @@ public class NATSActivationSpec implements ActivationSpec {
private ResourceAdapter resourceAdapter;
private Class beanClass;
+ private String subject;
public Class getBeanClass() {
return beanClass;
@@ -38,6 +39,14 @@ public class NATSActivationSpec implements ActivationSpec {
this.beanClass = beanClass;
}
+ public String getSubject() {
+ return subject;
+ }
+
+ public void setSubject(String subject) {
+ this.subject = subject;
+ }
+
@Override
public void validate() throws InvalidPropertyException {
}
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 54d3a62..804a24f 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
@@ -16,6 +16,15 @@
*/
package org.apache.tomee.chatterbox.nats.adapter;
+import io.nats.streaming.Message;
+import io.nats.streaming.MessageHandler;
+import io.nats.streaming.Options;
+import io.nats.streaming.StreamingConnection;
+import io.nats.streaming.StreamingConnectionFactory;
+import io.nats.streaming.Subscription;
+import org.apache.tomee.chatterbox.nats.api.InboundListener;
+import org.apache.tomee.chatterbox.nats.api.NATSException;
+
import javax.resource.ResourceException;
import javax.resource.spi.ActivationSpec;
import javax.resource.spi.BootstrapContext;
@@ -28,6 +37,8 @@ import javax.resource.spi.endpoint.MessageEndpointFactory;
import javax.resource.spi.work.Work;
import javax.resource.spi.work.WorkManager;
import javax.transaction.xa.XAResource;
+import java.io.IOException;
+import java.lang.reflect.Method;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
import java.lang.IllegalStateException;
@@ -36,20 +47,43 @@ import java.lang.IllegalStateException;
public class NATSResourceAdapter implements ResourceAdapter {
final Map<NATSActivationSpec, EndpointTarget> targets = new ConcurrentHashMap<NATSActivationSpec, EndpointTarget>();
+ private static final Method ONMESSAGE;
+
+ static {
+ try {
+ ONMESSAGE = InboundListener.class.getMethod("onMessage", Message.class);
+ } catch (Exception e) {
+ throw new RuntimeException(e);
+ }
+ }
+
@ConfigProperty
- private String token;
+ private String baseAddress;
private WorkManager workManager;
- private String user;
- private String userId;
+ private StreamingConnectionFactory cf;
+ private StreamingConnection connection;
public void start(BootstrapContext bootstrapContext) throws ResourceAdapterInternalException {
workManager = bootstrapContext.getWorkManager();
- // connect to NATS
+
+ try {
+ cf = new
+ StreamingConnectionFactory(new Options.Builder().natsUrl(baseAddress)
+ .clusterId("cluster-id").clientId("client-id").build());
+
+ connection = cf.createConnection();
+ } catch (Throwable t) {
+ // TODO: log this
+ }
}
public void stop() {
- // disconnect
+ try {
+ connection.close();
+ } catch (Throwable t) {
+ // TODO: log this
+ }
}
public void endpointActivation(final MessageEndpointFactory messageEndpointFactory, final ActivationSpec activationSpec)
@@ -64,11 +98,10 @@ public class NATSResourceAdapter implements ResourceAdapter {
final MessageEndpoint messageEndpoint = messageEndpointFactory.createEndpoint(null);
final EndpointTarget target = new EndpointTarget(messageEndpoint);
- final Class<?> endpointClass = NATSActivationSpec.getBeanClass() != null ? NATSActivationSpec
- .getBeanClass() : messageEndpointFactory.getEndpointClass();
-
-
targets.put(NATSActivationSpec, target);
+
+ final Subscription subscription = connection.subscribe(((NATSActivationSpec) activationSpec).getSubject(), target);
+ target.setSubscription(subscription);
} catch (Exception e) {
e.printStackTrace();
}
@@ -83,15 +116,14 @@ public class NATSResourceAdapter implements ResourceAdapter {
}
public void endpointDeactivation(MessageEndpointFactory messageEndpointFactory, ActivationSpec activationSpec) {
- final NATSActivationSpec telnetActivationSpec = (NATSActivationSpec) activationSpec;
+ final NATSActivationSpec natsActivationSpec = (NATSActivationSpec) activationSpec;
- final EndpointTarget endpointTarget = targets.get(telnetActivationSpec);
+ final EndpointTarget endpointTarget = targets.get(natsActivationSpec);
if (endpointTarget == null) {
throw new IllegalStateException("No EndpointTarget to undeploy for ActivationSpec " + activationSpec);
}
- // unsubscribe
-
+ endpointTarget.close();
endpointTarget.messageEndpoint.release();
}
@@ -99,17 +131,54 @@ public class NATSResourceAdapter implements ResourceAdapter {
return new XAResource[0];
}
- public void sendMessage(final String channel, final String message) {
+ public void publish(final String subject, final byte[] data) throws NATSException {
// publish a message
+ try {
+ connection.publish(subject, data);
+ } catch (Exception e) {
+ throw new NATSException(e);
+ }
}
- private static class EndpointTarget {
+ private static class EndpointTarget implements MessageHandler {
private final MessageEndpoint messageEndpoint;
+ private Subscription subscription;
- public EndpointTarget(MessageEndpoint messageEndpoint) {
+ public EndpointTarget(final MessageEndpoint messageEndpoint) {
this.messageEndpoint = messageEndpoint;
}
+ @Override
+ public void onMessage(final Message msg) {
+ try {
+ try {
+ messageEndpoint.beforeDelivery(ONMESSAGE);
+ ((InboundListener) messageEndpoint).onMessage(msg);
+ } finally {
+ messageEndpoint.afterDelivery();
+ }
+ } catch (Throwable t) {
+ // TODO: log this
+ }
+ }
+
+ public void setSubscription(final Subscription subscription) {
+ this.subscription = subscription;
+ }
+
+ public Subscription getSubscription() {
+ return subscription;
+ }
+
+ public void close() {
+ try {
+ if (subscription != null) {
+ subscription.close(true);
+ }
+ } catch (IOException e) {
+ // TODO: log this
+ }
+ }
}
}
diff --git a/chatterbox-nats/chatterbox-nats-impl/src/main/java/org/apache/tomee/chatterbox/nats/adapter/out/NATSConnectionImpl.java b/chatterbox-nats/chatterbox-nats-impl/src/main/java/org/apache/tomee/chatterbox/nats/adapter/out/NATSConnectionImpl.java
index 8b375f7..d743b9f 100755
--- a/chatterbox-nats/chatterbox-nats-impl/src/main/java/org/apache/tomee/chatterbox/nats/adapter/out/NATSConnectionImpl.java
+++ b/chatterbox-nats/chatterbox-nats-impl/src/main/java/org/apache/tomee/chatterbox/nats/adapter/out/NATSConnectionImpl.java
@@ -19,6 +19,7 @@
package org.apache.tomee.chatterbox.nats.adapter.out;
import org.apache.tomee.chatterbox.nats.api.NATSConnection;
+import org.apache.tomee.chatterbox.nats.api.NATSException;
import java.util.logging.Logger;
@@ -34,8 +35,8 @@ public class NATSConnectionImpl implements NATSConnection {
this.mcf = mcf;
}
- public void sendMessage(final String channel, final String message) {
- mc.sendMessage(channel, message);
+ public void publish(final String subject, final byte[] data) throws NATSException {
+ mc.publish(subject, data);
}
public void close() {
diff --git a/chatterbox-nats/chatterbox-nats-impl/src/main/java/org/apache/tomee/chatterbox/nats/adapter/out/NATSManagedConnection.java b/chatterbox-nats/chatterbox-nats-impl/src/main/java/org/apache/tomee/chatterbox/nats/adapter/out/NATSManagedConnection.java
index 0999036..d7043b2 100755
--- a/chatterbox-nats/chatterbox-nats-impl/src/main/java/org/apache/tomee/chatterbox/nats/adapter/out/NATSManagedConnection.java
+++ b/chatterbox-nats/chatterbox-nats-impl/src/main/java/org/apache/tomee/chatterbox/nats/adapter/out/NATSManagedConnection.java
@@ -20,6 +20,7 @@ package org.apache.tomee.chatterbox.nats.adapter.out;
import org.apache.tomee.chatterbox.nats.adapter.NATSResourceAdapter;
import org.apache.tomee.chatterbox.nats.api.NATSConnection;
+import org.apache.tomee.chatterbox.nats.api.NATSException;
import javax.resource.NotSupportedException;
import javax.resource.ResourceException;
@@ -131,10 +132,10 @@ public class NATSManagedConnection implements ManagedConnection {
return new NATSManagedConnectionMetaData();
}
- void sendMessage(final String channel, final String message) {
+ void publish(final String subject, final byte[] data) throws NATSException {
log.finest("sendMessage()");
final NATSResourceAdapter resourceAdapter = (NATSResourceAdapter) mcf.getResourceAdapter();
- resourceAdapter.sendMessage(channel, message);
+ resourceAdapter.publish(subject, data);
}
}
diff --git a/chatterbox-nats/chatterbox-nats-rar/src/main/rar/META-INF/ra.xml b/chatterbox-nats/chatterbox-nats-rar/src/main/rar/META-INF/ra.xml
index c44905f..3d4ed8e 100644
--- a/chatterbox-nats/chatterbox-nats-rar/src/main/rar/META-INF/ra.xml
+++ b/chatterbox-nats/chatterbox-nats-rar/src/main/rar/META-INF/ra.xml
@@ -22,9 +22,9 @@
xmlns="http://xmlns.jcp.org/xml/ns/javaee"
xsi:schemaLocation="http://xmlns.jcp.org/xml/ns/javaee http://xmlns.jcp.org/xml/ns/javaee/connector_1_7.xsd"
version="1.7">
- <description>Chatterbox Slack Connector</description>
- <display-name>Chatterbox Slack Connector</display-name>
- <eis-type>Slack Connector</eis-type>
+ <description>Chatterbox NATS Connector</description>
+ <display-name>Chatterbox NATS Connector</display-name>
+ <eis-type>NATS Connector</eis-type>
<resourceadapter-version>1.0</resourceadapter-version>
<license>
<license-required>false</license-required>
@@ -32,18 +32,18 @@
<resourceadapter>
<resourceadapter-class>org.apache.tomee.chatterbox.nats.adapter.NATSResourceAdapter</resourceadapter-class>
<config-property>
- <config-property-name>token</config-property-name>
+ <config-property-name>baseAddress</config-property-name>
<config-property-type>String</config-property-type>
</config-property>
<outbound-resourceadapter>
<connection-definition>
<managedconnectionfactory-class>org.apache.tomee.chatterbox.nats.adapter.out.NATSManagedConnectionFactory
</managedconnectionfactory-class>
- <connectionfactory-interface>SlackConnectionFactory
+ <connectionfactory-interface>org.apache.tomee.chatterbox.nats.api.NATSConnectionFactory
</connectionfactory-interface>
<connectionfactory-impl-class>org.apache.tomee.chatterbox.nats.adapter.out.NATSConnectionFactoryImpl
</connectionfactory-impl-class>
- <connection-interface>SlackConnection</connection-interface>
+ <connection-interface>org.apache.tomee.chatterbox.nats.api.NATSConnection</connection-interface>
<connection-impl-class>org.apache.tomee.chatterbox.nats.adapter.out.NATSConnectionImpl</connection-impl-class>
</connection-definition>
<transaction-support>NoTransaction</transaction-support>
@@ -52,7 +52,7 @@
<inbound-resourceadapter>
<messageadapter>
<messagelistener>
- <messagelistener-type>InboundListener</messagelistener-type>
+ <messagelistener-type>org.apache.tomee.chatterbox.nats.api.InboundListener</messagelistener-type>
<activationspec>
<activationspec-class>org.apache.tomee.chatterbox.nats.adapter.NATSActivationSpec</activationspec-class>
</activationspec>
diff --git a/chatterbox-nats/chatterbox-nats-sample-war/pom.xml b/chatterbox-nats/chatterbox-nats-sample-war/pom.xml
index aae7a99..25827a3 100644
--- a/chatterbox-nats/chatterbox-nats-sample-war/pom.xml
+++ b/chatterbox-nats/chatterbox-nats-sample-war/pom.xml
@@ -40,6 +40,12 @@
<scope>provided</scope>
</dependency>
<dependency>
+ <groupId>io.nats</groupId>
+ <artifactId>java-nats-streaming</artifactId>
+ <version>2.2.3</version>
+ <scope>provided</scope>
+ </dependency>
+ <dependency>
<groupId>${project.groupId}</groupId>
<artifactId>chatterbox-nats-impl</artifactId>
<version>${project.version}</version>
@@ -89,8 +95,7 @@
<tomeeClassifier>plus</tomeeClassifier>
<libs>
<lib>org.apache.tomee.chatterbox:chatterbox-nats-api:${project.version}:jar</lib>
- <lib>org.tomitribe:tomitribe-util:1.1.0:jar</lib>
- <lib>org.tomitribe:tomitribe-crest-api:0.3:jar</lib>
+ <lib>io.nats:java-nats-streaming:2.2.3:jar</lib>
</libs>
<apps>
<app>org.apache.tomee.chatterbox:chatterbox-nats-rar:${project.version}:rar</app>
diff --git a/chatterbox-nats/chatterbox-nats-sample-war/src/main/java/org/superbiz/SystemBean.java b/chatterbox-nats/chatterbox-nats-sample-war/src/main/java/org/superbiz/EchoBean.java
similarity index 60%
rename from chatterbox-nats/chatterbox-nats-sample-war/src/main/java/org/superbiz/SystemBean.java
rename to chatterbox-nats/chatterbox-nats-sample-war/src/main/java/org/superbiz/EchoBean.java
index 623b3f4..2c0e81a 100644
--- a/chatterbox-nats/chatterbox-nats-sample-war/src/main/java/org/superbiz/SystemBean.java
+++ b/chatterbox-nats/chatterbox-nats-sample-war/src/main/java/org/superbiz/EchoBean.java
@@ -18,16 +18,28 @@ package org.superbiz;
import org.apache.tomee.chatterbox.nats.api.InboundListener;
import org.apache.tomee.chatterbox.nats.api.NATSException;
-import org.apache.tomee.chatterbox.nats.api.NATSMessage;
+import io.nats.streaming.Message;
+import javax.ejb.ActivationConfigProperty;
import javax.ejb.MessageDriven;
+import java.io.IOException;
+import java.nio.charset.StandardCharsets;
-@MessageDriven(name = "Receiver")
-public class SystemBean implements InboundListener {
+@MessageDriven(name = "Echo", activationConfig = {
+ @ActivationConfigProperty(propertyName = "subject", propertyValue = "echo")
+})
+public class EchoBean implements InboundListener {
@Override
- public void onMessage(NATSMessage message) throws NATSException {
- // TODO: fill in implementation here
+ public void onMessage(final Message message) throws NATSException {
+ try {
+ final String text = new String(message.getData(), StandardCharsets.UTF_8);
+ System.out.println(text);
+
+ message.ack();
+ } catch (IOException e) {
+ throw new NATSException(e);
+ }
}
}
diff --git a/chatterbox-nats/chatterbox-nats-sample-war/src/main/java/org/superbiz/Sender.java b/chatterbox-nats/chatterbox-nats-sample-war/src/main/java/org/superbiz/Sender.java
index 7ea3778..fa50cbc 100644
--- a/chatterbox-nats/chatterbox-nats-sample-war/src/main/java/org/superbiz/Sender.java
+++ b/chatterbox-nats/chatterbox-nats-sample-war/src/main/java/org/superbiz/Sender.java
@@ -29,6 +29,7 @@ import javax.ws.rs.POST;
import javax.ws.rs.Path;
import javax.ws.rs.PathParam;
import javax.ws.rs.core.MediaType;
+import java.nio.charset.StandardCharsets;
@Singleton
@Lock(LockType.READ)
@@ -38,16 +39,16 @@ public class Sender {
@Resource
private NATSConnectionFactory cf;
- @Path("{channel}")
+ @Path("{subject}")
@POST
@Consumes(MediaType.TEXT_PLAIN)
- public void sendMessage(@PathParam("channel") final String channel, final String message) {
+ public void sendMessage(@PathParam("subject") final String subject, final String message) {
try {
final NATSConnection connection = cf.getConnection();
- connection.sendMessage(channel, message);
+ connection.publish(subject, message.getBytes(StandardCharsets.UTF_8));
connection.close();
- } catch (ResourceException e) {
- // ignore
+ } catch (Throwable t) {
+ // TODO: log this
}
}
[tomee-chatterbox] 03/06: Wrap the message in a proxy,
so we don't need all the libraries the NATS Streaming client uses
in TomEE's classpath
Posted by jg...@apache.org.
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 0a41080d443c9a5e1be6c133233af379577c2f9a
Author: Jonathan Gallimore <jo...@jrg.me.uk>
AuthorDate: Wed Jun 9 12:07:52 2021 +0100
Wrap the message in a proxy, so we don't need all the libraries the NATS Streaming client uses in TomEE's classpath
---
chatterbox-nats/chatterbox-nats-api/pom.xml | 6 ------
.../tomee/chatterbox/nats/api/InboundListener.java | 4 +---
.../api/{InboundListener.java => NATSMessage.java} | 24 ++++++++++++++--------
chatterbox-nats/chatterbox-nats-impl/pom.xml | 1 -
.../nats/adapter/NATSResourceAdapter.java | 16 +++++++++++++--
chatterbox-nats/chatterbox-nats-sample-war/pom.xml | 7 -------
.../src/main/java/org/superbiz/EchoBean.java | 8 +++-----
7 files changed, 34 insertions(+), 32 deletions(-)
diff --git a/chatterbox-nats/chatterbox-nats-api/pom.xml b/chatterbox-nats/chatterbox-nats-api/pom.xml
index db16e68..6f4ca62 100644
--- a/chatterbox-nats/chatterbox-nats-api/pom.xml
+++ b/chatterbox-nats/chatterbox-nats-api/pom.xml
@@ -45,11 +45,5 @@
<artifactId>javaee-api</artifactId>
<scope>provided</scope>
</dependency>
- <dependency>
- <groupId>io.nats</groupId>
- <artifactId>java-nats-streaming</artifactId>
- <version>2.2.3</version>
- <scope>provided</scope>
- </dependency>
</dependencies>
</project>
diff --git a/chatterbox-nats/chatterbox-nats-api/src/main/java/org/apache/tomee/chatterbox/nats/api/InboundListener.java b/chatterbox-nats/chatterbox-nats-api/src/main/java/org/apache/tomee/chatterbox/nats/api/InboundListener.java
index 94d6294..5f7ea6c 100644
--- a/chatterbox-nats/chatterbox-nats-api/src/main/java/org/apache/tomee/chatterbox/nats/api/InboundListener.java
+++ b/chatterbox-nats/chatterbox-nats-api/src/main/java/org/apache/tomee/chatterbox/nats/api/InboundListener.java
@@ -16,13 +16,11 @@
*/
package org.apache.tomee.chatterbox.nats.api;
-import io.nats.streaming.Message;
-
/**
* @version $Revision$ $Date$
*/
public interface InboundListener {
- public void onMessage(final Message message) throws NATSException;
+ public void onMessage(final NATSMessage message) throws NATSException;
}
diff --git a/chatterbox-nats/chatterbox-nats-api/src/main/java/org/apache/tomee/chatterbox/nats/api/InboundListener.java b/chatterbox-nats/chatterbox-nats-api/src/main/java/org/apache/tomee/chatterbox/nats/api/NATSMessage.java
similarity index 64%
copy from chatterbox-nats/chatterbox-nats-api/src/main/java/org/apache/tomee/chatterbox/nats/api/InboundListener.java
copy to chatterbox-nats/chatterbox-nats-api/src/main/java/org/apache/tomee/chatterbox/nats/api/NATSMessage.java
index 94d6294..2335bf6 100644
--- a/chatterbox-nats/chatterbox-nats-api/src/main/java/org/apache/tomee/chatterbox/nats/api/InboundListener.java
+++ b/chatterbox-nats/chatterbox-nats-api/src/main/java/org/apache/tomee/chatterbox/nats/api/NATSMessage.java
@@ -16,13 +16,21 @@
*/
package org.apache.tomee.chatterbox.nats.api;
-import io.nats.streaming.Message;
-
-/**
- * @version $Revision$ $Date$
- */
-public interface InboundListener {
-
- public void onMessage(final Message message) throws NATSException;
+import java.time.Instant;
+public interface NATSMessage {
+ Instant getInstant();
+ long getSequence();
+ String getSubject();
+ void setSubject(String subject);
+ String getReplyTo();
+ void setReplyTo(String reply);
+ byte[] getData();
+ void setData(byte[] data);
+ void setData(byte[] data, int offset, int length);
+ long getTimestamp();
+ public boolean isRedelivered();
+ public int getCrc32();
+ public void ack();
+ public String toString();
}
diff --git a/chatterbox-nats/chatterbox-nats-impl/pom.xml b/chatterbox-nats/chatterbox-nats-impl/pom.xml
index d46e53a..fbe5f30 100644
--- a/chatterbox-nats/chatterbox-nats-impl/pom.xml
+++ b/chatterbox-nats/chatterbox-nats-impl/pom.xml
@@ -59,7 +59,6 @@
<groupId>io.nats</groupId>
<artifactId>java-nats-streaming</artifactId>
<version>2.2.3</version>
- <scope>provided</scope>
</dependency>
</dependencies>
</project>
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 804a24f..4ed4485 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
@@ -24,6 +24,7 @@ import io.nats.streaming.StreamingConnectionFactory;
import io.nats.streaming.Subscription;
import org.apache.tomee.chatterbox.nats.api.InboundListener;
import org.apache.tomee.chatterbox.nats.api.NATSException;
+import org.apache.tomee.chatterbox.nats.api.NATSMessage;
import javax.resource.ResourceException;
import javax.resource.spi.ActivationSpec;
@@ -38,7 +39,9 @@ import javax.resource.spi.work.Work;
import javax.resource.spi.work.WorkManager;
import javax.transaction.xa.XAResource;
import java.io.IOException;
+import java.lang.reflect.InvocationHandler;
import java.lang.reflect.Method;
+import java.lang.reflect.Proxy;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
import java.lang.IllegalStateException;
@@ -51,7 +54,7 @@ public class NATSResourceAdapter implements ResourceAdapter {
static {
try {
- ONMESSAGE = InboundListener.class.getMethod("onMessage", Message.class);
+ ONMESSAGE = InboundListener.class.getMethod("onMessage", NATSMessage.class);
} catch (Exception e) {
throw new RuntimeException(e);
}
@@ -75,6 +78,7 @@ public class NATSResourceAdapter implements ResourceAdapter {
connection = cf.createConnection();
} catch (Throwable t) {
// TODO: log this
+ t.printStackTrace();
}
}
@@ -154,7 +158,15 @@ public class NATSResourceAdapter implements ResourceAdapter {
try {
try {
messageEndpoint.beforeDelivery(ONMESSAGE);
- ((InboundListener) messageEndpoint).onMessage(msg);
+
+ final NATSMessage message = (NATSMessage) Proxy.newProxyInstance(getClass().getClassLoader(), new Class[]{InboundListener.class}, new InvocationHandler() {
+ @Override
+ public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
+ return method.invoke(msg, args);
+ }
+ });
+
+ ((InboundListener) messageEndpoint).onMessage(message);
} finally {
messageEndpoint.afterDelivery();
}
diff --git a/chatterbox-nats/chatterbox-nats-sample-war/pom.xml b/chatterbox-nats/chatterbox-nats-sample-war/pom.xml
index 25827a3..0dbf389 100644
--- a/chatterbox-nats/chatterbox-nats-sample-war/pom.xml
+++ b/chatterbox-nats/chatterbox-nats-sample-war/pom.xml
@@ -40,12 +40,6 @@
<scope>provided</scope>
</dependency>
<dependency>
- <groupId>io.nats</groupId>
- <artifactId>java-nats-streaming</artifactId>
- <version>2.2.3</version>
- <scope>provided</scope>
- </dependency>
- <dependency>
<groupId>${project.groupId}</groupId>
<artifactId>chatterbox-nats-impl</artifactId>
<version>${project.version}</version>
@@ -95,7 +89,6 @@
<tomeeClassifier>plus</tomeeClassifier>
<libs>
<lib>org.apache.tomee.chatterbox:chatterbox-nats-api:${project.version}:jar</lib>
- <lib>io.nats:java-nats-streaming:2.2.3:jar</lib>
</libs>
<apps>
<app>org.apache.tomee.chatterbox:chatterbox-nats-rar:${project.version}:rar</app>
diff --git a/chatterbox-nats/chatterbox-nats-sample-war/src/main/java/org/superbiz/EchoBean.java b/chatterbox-nats/chatterbox-nats-sample-war/src/main/java/org/superbiz/EchoBean.java
index 2c0e81a..e66e0ff 100644
--- a/chatterbox-nats/chatterbox-nats-sample-war/src/main/java/org/superbiz/EchoBean.java
+++ b/chatterbox-nats/chatterbox-nats-sample-war/src/main/java/org/superbiz/EchoBean.java
@@ -17,12 +17,11 @@
package org.superbiz;
import org.apache.tomee.chatterbox.nats.api.InboundListener;
+import org.apache.tomee.chatterbox.nats.api.NATSMessage;
import org.apache.tomee.chatterbox.nats.api.NATSException;
-import io.nats.streaming.Message;
import javax.ejb.ActivationConfigProperty;
import javax.ejb.MessageDriven;
-import java.io.IOException;
import java.nio.charset.StandardCharsets;
@MessageDriven(name = "Echo", activationConfig = {
@@ -30,15 +29,14 @@ import java.nio.charset.StandardCharsets;
})
public class EchoBean implements InboundListener {
-
@Override
- public void onMessage(final Message message) throws NATSException {
+ public void onMessage(final NATSMessage message) throws NATSException {
try {
final String text = new String(message.getData(), StandardCharsets.UTF_8);
System.out.println(text);
message.ack();
- } catch (IOException e) {
+ } catch (Exception e) {
throw new NATSException(e);
}
}
[tomee-chatterbox] 04/06: Add basic test to isolate timeout issue
from the resource adapter
Posted by jg...@apache.org.
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();
+ }
+}
[tomee-chatterbox] 05/06: Basic adapter working end-to-end. Some
more fine tuning needed.
Posted by jg...@apache.org.
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 0450a3382c4418e8cd320ae8169d78171b00198e
Author: Jonathan Gallimore <jo...@jrg.me.uk>
AuthorDate: Thu Jun 10 17:59:46 2021 +0100
Basic adapter working end-to-end. Some more fine tuning needed.
---
.../nats/adapter/NATSResourceAdapter.java | 21 ++++++++++++++-------
.../tomee/chatterbox/nats/adapter/NATSTest.java | 22 ----------------------
.../src/main/java/org/superbiz/EchoBean.java | 2 --
3 files changed, 14 insertions(+), 31 deletions(-)
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 fdea9a8..cfbbf41 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("yourclientid").build());
+ .clusterId("yourclientid").clientId("anythingyoulike").build());
connection = cf.createConnection();
} catch (Throwable t) {
@@ -159,14 +159,21 @@ public class NATSResourceAdapter implements ResourceAdapter {
try {
messageEndpoint.beforeDelivery(ONMESSAGE);
- final NATSMessage message = (NATSMessage) Proxy.newProxyInstance(getClass().getClassLoader(), new Class[]{InboundListener.class}, new InvocationHandler() {
- @Override
- public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
- return method.invoke(msg, args);
- }
- });
+ final NATSMessage message = (NATSMessage) Proxy.newProxyInstance(
+ getClass().getClassLoader(),
+ new Class[]{NATSMessage.class},
+ new InvocationHandler() {
+ @Override
+ public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
+ final Method m = Message.class.getMethod(method.getName(), method.getParameterTypes());
+ return m.invoke(msg, args);
+ }
+ }
+ );
((InboundListener) messageEndpoint).onMessage(message);
+ } catch (Exception e) {
+ e.printStackTrace();
} finally {
messageEndpoint.afterDelivery();
}
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
deleted file mode 100644
index d2e4258..0000000
--- a/chatterbox-nats/chatterbox-nats-impl/src/test/java/org/apache/tomee/chatterbox/nats/adapter/NATSTest.java
+++ /dev/null
@@ -1,22 +0,0 @@
-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();
- }
-}
diff --git a/chatterbox-nats/chatterbox-nats-sample-war/src/main/java/org/superbiz/EchoBean.java b/chatterbox-nats/chatterbox-nats-sample-war/src/main/java/org/superbiz/EchoBean.java
index e66e0ff..12b69fa 100644
--- a/chatterbox-nats/chatterbox-nats-sample-war/src/main/java/org/superbiz/EchoBean.java
+++ b/chatterbox-nats/chatterbox-nats-sample-war/src/main/java/org/superbiz/EchoBean.java
@@ -34,8 +34,6 @@ public class EchoBean implements InboundListener {
try {
final String text = new String(message.getData(), StandardCharsets.UTF_8);
System.out.println(text);
-
- message.ack();
} catch (Exception e) {
throw new NATSException(e);
}
[tomee-chatterbox] 01/06: Bootstrap a NATS JCA Adapter
Posted by jg...@apache.org.
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 267d8241a992f14d8993eb936aa0e444b2f93245
Author: Jonathan Gallimore <jo...@jrg.me.uk>
AuthorDate: Tue Jun 8 17:55:03 2021 +0100
Bootstrap a NATS JCA Adapter
---
chatterbox-nats/.gitignore | 30 +++
chatterbox-nats/chatterbox-nats-api/pom.xml | 49 +++++
.../tomee/chatterbox/nats/api/InboundListener.java | 26 +++
.../tomee/chatterbox/nats/api/NATSConnection.java | 26 +++
.../chatterbox/nats/api/NATSConnectionFactory.java | 28 +++
.../tomee/chatterbox/nats/api/NATSException.java | 23 +++
.../tomee/chatterbox/nats/api/NATSMessage.java | 23 +++
.../src/main/resources/META-INF/LICENSE | 201 ++++++++++++++++++
.../src/main/resources/META-INF/NOTICE | 7 +
chatterbox-nats/chatterbox-nats-impl/pom.xml | 64 ++++++
.../nats/adapter/NATSActivationSpec.java | 54 +++++
.../nats/adapter/NATSResourceAdapter.java | 115 +++++++++++
.../adapter/out/NATSConnectionFactoryImpl.java | 69 +++++++
.../nats/adapter/out/NATSConnectionImpl.java | 44 ++++
.../nats/adapter/out/NATSManagedConnection.java | 140 +++++++++++++
.../adapter/out/NATSManagedConnectionFactory.java | 105 ++++++++++
.../adapter/out/NATSManagedConnectionMetaData.java | 56 +++++
.../src/main/resources/META-INF/LICENSE | 201 ++++++++++++++++++
.../src/main/resources/META-INF/NOTICE | 7 +
chatterbox-nats/chatterbox-nats-rar/pom.xml | 42 ++++
.../src/main/rar/META-INF/LICENSE | 201 ++++++++++++++++++
.../src/main/rar/META-INF/NOTICE | 5 +
.../src/main/rar/META-INF/ra.xml | 63 ++++++
chatterbox-nats/chatterbox-nats-sample-war/pom.xml | 102 +++++++++
.../src/main/java/org/superbiz/Sender.java | 54 +++++
.../src/main/java/org/superbiz/SystemBean.java | 33 +++
.../src/main/resources/META-INF/LICENSE | 201 ++++++++++++++++++
.../src/main/resources/META-INF/NOTICE | 7 +
.../src/main/resources/META-INF/ejb-jar.xml | 26 +++
chatterbox-nats/docker-compose.yml | 35 ++++
chatterbox-nats/pom.xml | 229 +++++++++++++++++++++
pom.xml | 1 +
32 files changed, 2267 insertions(+)
diff --git a/chatterbox-nats/.gitignore b/chatterbox-nats/.gitignore
new file mode 100644
index 0000000..9e544aa
--- /dev/null
+++ b/chatterbox-nats/.gitignore
@@ -0,0 +1,30 @@
+# Java #
+*.class
+*.ser
+
+# Package Files #
+*.jar
+*.war
+*.ear
+
+# IDEA #
+*.iml
+.idea
+*~
+
+# eclipse specific git ignore
+.project
+.metadata
+.classpath
+.settings/
+
+
+# Maven files #
+target/
+pom.xml.tag
+pom.xml.releaseBackup
+pom.xml.next
+release.properties
+
+# Checkstyle #
+.checkstyle
diff --git a/chatterbox-nats/chatterbox-nats-api/pom.xml b/chatterbox-nats/chatterbox-nats-api/pom.xml
new file mode 100644
index 0000000..6f4ca62
--- /dev/null
+++ b/chatterbox-nats/chatterbox-nats-api/pom.xml
@@ -0,0 +1,49 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+ ~ Licensed to the Apache Software Foundation (ASF) under one
+ ~ or more contributor license agreements. See the NOTICE file
+ ~ distributed with this work for additional information
+ ~ regarding copyright ownership. The ASF licenses this file
+ ~ to you under the Apache License, Version 2.0 (the
+ ~ "License"); you may not use this file except in compliance
+ ~ with the License. You may obtain a copy of the License at
+ ~
+ ~ http://www.apache.org/licenses/LICENSE-2.0
+ ~
+ ~ Unless required by applicable law or agreed to in writing,
+ ~ software distributed under the License is distributed on an
+ ~ "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ ~ KIND, either express or implied. See the License for the
+ ~ specific language governing permissions and limitations
+ ~ under the License.
+ -->
+
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
+
+ <modelVersion>4.0.0</modelVersion>
+
+ <parent>
+ <groupId>org.apache.tomee.chatterbox</groupId>
+ <artifactId>chatterbox-nats-parent</artifactId>
+ <version>0.3-SNAPSHOT</version>
+ </parent>
+
+ <artifactId>chatterbox-nats-api</artifactId>
+ <packaging>jar</packaging>
+ <name>Chatterbox :: NATS :: API</name>
+
+ <properties>
+ <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+ <version.arquillian>1.1.1.Final</version.arquillian>
+ <version.shrinkwrap.descriptor>2.0.0-alpha-5</version.shrinkwrap.descriptor>
+ <version.shrinkwrap.shrinkwrap>1.0.1</version.shrinkwrap.shrinkwrap>
+ </properties>
+
+ <dependencies>
+ <dependency>
+ <groupId>javax</groupId>
+ <artifactId>javaee-api</artifactId>
+ <scope>provided</scope>
+ </dependency>
+ </dependencies>
+</project>
diff --git a/chatterbox-nats/chatterbox-nats-api/src/main/java/org/apache/tomee/chatterbox/nats/api/InboundListener.java b/chatterbox-nats/chatterbox-nats-api/src/main/java/org/apache/tomee/chatterbox/nats/api/InboundListener.java
new file mode 100644
index 0000000..5f7ea6c
--- /dev/null
+++ b/chatterbox-nats/chatterbox-nats-api/src/main/java/org/apache/tomee/chatterbox/nats/api/InboundListener.java
@@ -0,0 +1,26 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.tomee.chatterbox.nats.api;
+
+/**
+ * @version $Revision$ $Date$
+ */
+public interface InboundListener {
+
+ public void onMessage(final NATSMessage message) throws NATSException;
+
+}
diff --git a/chatterbox-nats/chatterbox-nats-api/src/main/java/org/apache/tomee/chatterbox/nats/api/NATSConnection.java b/chatterbox-nats/chatterbox-nats-api/src/main/java/org/apache/tomee/chatterbox/nats/api/NATSConnection.java
new file mode 100755
index 0000000..e323dd1
--- /dev/null
+++ b/chatterbox-nats/chatterbox-nats-api/src/main/java/org/apache/tomee/chatterbox/nats/api/NATSConnection.java
@@ -0,0 +1,26 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+package org.apache.tomee.chatterbox.nats.api;
+
+public interface NATSConnection {
+ public void sendMessage(final String channel, final String message);
+
+ public void close();
+}
diff --git a/chatterbox-nats/chatterbox-nats-api/src/main/java/org/apache/tomee/chatterbox/nats/api/NATSConnectionFactory.java b/chatterbox-nats/chatterbox-nats-api/src/main/java/org/apache/tomee/chatterbox/nats/api/NATSConnectionFactory.java
new file mode 100755
index 0000000..e762869
--- /dev/null
+++ b/chatterbox-nats/chatterbox-nats-api/src/main/java/org/apache/tomee/chatterbox/nats/api/NATSConnectionFactory.java
@@ -0,0 +1,28 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.tomee.chatterbox.nats.api;
+
+import javax.resource.Referenceable;
+import javax.resource.ResourceException;
+import java.io.Serializable;
+
+public interface NATSConnectionFactory extends Serializable, Referenceable {
+ public NATSConnection getConnection() throws ResourceException;
+
+}
diff --git a/chatterbox-nats/chatterbox-nats-api/src/main/java/org/apache/tomee/chatterbox/nats/api/NATSException.java b/chatterbox-nats/chatterbox-nats-api/src/main/java/org/apache/tomee/chatterbox/nats/api/NATSException.java
new file mode 100644
index 0000000..031ad42
--- /dev/null
+++ b/chatterbox-nats/chatterbox-nats-api/src/main/java/org/apache/tomee/chatterbox/nats/api/NATSException.java
@@ -0,0 +1,23 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.tomee.chatterbox.nats.api;
+
+/**
+ * @version $Revision$ $Date$
+ */
+public class NATSException extends Exception {
+}
diff --git a/chatterbox-nats/chatterbox-nats-api/src/main/java/org/apache/tomee/chatterbox/nats/api/NATSMessage.java b/chatterbox-nats/chatterbox-nats-api/src/main/java/org/apache/tomee/chatterbox/nats/api/NATSMessage.java
new file mode 100644
index 0000000..afb7718
--- /dev/null
+++ b/chatterbox-nats/chatterbox-nats-api/src/main/java/org/apache/tomee/chatterbox/nats/api/NATSMessage.java
@@ -0,0 +1,23 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.tomee.chatterbox.nats.api;
+
+/**
+ * @version $Revision$ $Date$
+ */
+public class NATSMessage {
+}
diff --git a/chatterbox-nats/chatterbox-nats-api/src/main/resources/META-INF/LICENSE b/chatterbox-nats/chatterbox-nats-api/src/main/resources/META-INF/LICENSE
new file mode 100644
index 0000000..261eeb9
--- /dev/null
+++ b/chatterbox-nats/chatterbox-nats-api/src/main/resources/META-INF/LICENSE
@@ -0,0 +1,201 @@
+ Apache License
+ Version 2.0, January 2004
+ http://www.apache.org/licenses/
+
+ TERMS AND CONDITIONS FOR USE, REPRODUCTION, AND DISTRIBUTION
+
+ 1. Definitions.
+
+ "License" shall mean the terms and conditions for use, reproduction,
+ and distribution as defined by Sections 1 through 9 of this document.
+
+ "Licensor" shall mean the copyright owner or entity authorized by
+ the copyright owner that is granting the License.
+
+ "Legal Entity" shall mean the union of the acting entity and all
+ other entities that control, are controlled by, or are under common
+ control with that entity. For the purposes of this definition,
+ "control" means (i) the power, direct or indirect, to cause the
+ direction or management of such entity, whether by contract or
+ otherwise, or (ii) ownership of fifty percent (50%) or more of the
+ outstanding shares, or (iii) beneficial ownership of such entity.
+
+ "You" (or "Your") shall mean an individual or Legal Entity
+ exercising permissions granted by this License.
+
+ "Source" form shall mean the preferred form for making modifications,
+ including but not limited to software source code, documentation
+ source, and configuration files.
+
+ "Object" form shall mean any form resulting from mechanical
+ transformation or translation of a Source form, including but
+ not limited to compiled object code, generated documentation,
+ and conversions to other media types.
+
+ "Work" shall mean the work of authorship, whether in Source or
+ Object form, made available under the License, as indicated by a
+ copyright notice that is included in or attached to the work
+ (an example is provided in the Appendix below).
+
+ "Derivative Works" shall mean any work, whether in Source or Object
+ form, that is based on (or derived from) the Work and for which the
+ editorial revisions, annotations, elaborations, or other modifications
+ represent, as a whole, an original work of authorship. For the purposes
+ of this License, Derivative Works shall not include works that remain
+ separable from, or merely link (or bind by name) to the interfaces of,
+ the Work and Derivative Works thereof.
+
+ "Contribution" shall mean any work of authorship, including
+ the original version of the Work and any modifications or additions
+ to that Work or Derivative Works thereof, that is intentionally
+ submitted to Licensor for inclusion in the Work by the copyright owner
+ or by an individual or Legal Entity authorized to submit on behalf of
+ the copyright owner. For the purposes of this definition, "submitted"
+ means any form of electronic, verbal, or written communication sent
+ to the Licensor or its representatives, including but not limited to
+ communication on electronic mailing lists, source code control systems,
+ and issue tracking systems that are managed by, or on behalf of, the
+ Licensor for the purpose of discussing and improving the Work, but
+ excluding communication that is conspicuously marked or otherwise
+ designated in writing by the copyright owner as "Not a Contribution."
+
+ "Contributor" shall mean Licensor and any individual or Legal Entity
+ on behalf of whom a Contribution has been received by Licensor and
+ subsequently incorporated within the Work.
+
+ 2. Grant of Copyright License. Subject to the terms and conditions of
+ this License, each Contributor hereby grants to You a perpetual,
+ worldwide, non-exclusive, no-charge, royalty-free, irrevocable
+ copyright license to reproduce, prepare Derivative Works of,
+ publicly display, publicly perform, sublicense, and distribute the
+ Work and such Derivative Works in Source or Object form.
+
+ 3. Grant of Patent License. Subject to the terms and conditions of
+ this License, each Contributor hereby grants to You a perpetual,
+ worldwide, non-exclusive, no-charge, royalty-free, irrevocable
+ (except as stated in this section) patent license to make, have made,
+ use, offer to sell, sell, import, and otherwise transfer the Work,
+ where such license applies only to those patent claims licensable
+ by such Contributor that are necessarily infringed by their
+ Contribution(s) alone or by combination of their Contribution(s)
+ with the Work to which such Contribution(s) was submitted. If You
+ institute patent litigation against any entity (including a
+ cross-claim or counterclaim in a lawsuit) alleging that the Work
+ or a Contribution incorporated within the Work constitutes direct
+ or contributory patent infringement, then any patent licenses
+ granted to You under this License for that Work shall terminate
+ as of the date such litigation is filed.
+
+ 4. Redistribution. You may reproduce and distribute copies of the
+ Work or Derivative Works thereof in any medium, with or without
+ modifications, and in Source or Object form, provided that You
+ meet the following conditions:
+
+ (a) You must give any other recipients of the Work or
+ Derivative Works a copy of this License; and
+
+ (b) You must cause any modified files to carry prominent notices
+ stating that You changed the files; and
+
+ (c) You must retain, in the Source form of any Derivative Works
+ that You distribute, all copyright, patent, trademark, and
+ attribution notices from the Source form of the Work,
+ excluding those notices that do not pertain to any part of
+ the Derivative Works; and
+
+ (d) If the Work includes a "NOTICE" text file as part of its
+ distribution, then any Derivative Works that You distribute must
+ include a readable copy of the attribution notices contained
+ within such NOTICE file, excluding those notices that do not
+ pertain to any part of the Derivative Works, in at least one
+ of the following places: within a NOTICE text file distributed
+ as part of the Derivative Works; within the Source form or
+ documentation, if provided along with the Derivative Works; or,
+ within a display generated by the Derivative Works, if and
+ wherever such third-party notices normally appear. The contents
+ of the NOTICE file are for informational purposes only and
+ do not modify the License. You may add Your own attribution
+ notices within Derivative Works that You distribute, alongside
+ or as an addendum to the NOTICE text from the Work, provided
+ that such additional attribution notices cannot be construed
+ as modifying the License.
+
+ You may add Your own copyright statement to Your modifications and
+ may provide additional or different license terms and conditions
+ for use, reproduction, or distribution of Your modifications, or
+ for any such Derivative Works as a whole, provided Your use,
+ reproduction, and distribution of the Work otherwise complies with
+ the conditions stated in this License.
+
+ 5. Submission of Contributions. Unless You explicitly state otherwise,
+ any Contribution intentionally submitted for inclusion in the Work
+ by You to the Licensor shall be under the terms and conditions of
+ this License, without any additional terms or conditions.
+ Notwithstanding the above, nothing herein shall supersede or modify
+ the terms of any separate license agreement you may have executed
+ with Licensor regarding such Contributions.
+
+ 6. Trademarks. This License does not grant permission to use the trade
+ names, trademarks, service marks, or product names of the Licensor,
+ except as required for reasonable and customary use in describing the
+ origin of the Work and reproducing the content of the NOTICE file.
+
+ 7. Disclaimer of Warranty. Unless required by applicable law or
+ agreed to in writing, Licensor provides the Work (and each
+ Contributor provides its Contributions) on an "AS IS" BASIS,
+ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
+ implied, including, without limitation, any warranties or conditions
+ of TITLE, NON-INFRINGEMENT, MERCHANTABILITY, or FITNESS FOR A
+ PARTICULAR PURPOSE. You are solely responsible for determining the
+ appropriateness of using or redistributing the Work and assume any
+ risks associated with Your exercise of permissions under this License.
+
+ 8. Limitation of Liability. In no event and under no legal theory,
+ whether in tort (including negligence), contract, or otherwise,
+ unless required by applicable law (such as deliberate and grossly
+ negligent acts) or agreed to in writing, shall any Contributor be
+ liable to You for damages, including any direct, indirect, special,
+ incidental, or consequential damages of any character arising as a
+ result of this License or out of the use or inability to use the
+ Work (including but not limited to damages for loss of goodwill,
+ work stoppage, computer failure or malfunction, or any and all
+ other commercial damages or losses), even if such Contributor
+ has been advised of the possibility of such damages.
+
+ 9. Accepting Warranty or Additional Liability. While redistributing
+ the Work or Derivative Works thereof, You may choose to offer,
+ and charge a fee for, acceptance of support, warranty, indemnity,
+ or other liability obligations and/or rights consistent with this
+ License. However, in accepting such obligations, You may act only
+ on Your own behalf and on Your sole responsibility, not on behalf
+ of any other Contributor, and only if You agree to indemnify,
+ defend, and hold each Contributor harmless for any liability
+ incurred by, or claims asserted against, such Contributor by reason
+ of your accepting any such warranty or additional liability.
+
+ END OF TERMS AND CONDITIONS
+
+ APPENDIX: How to apply the Apache License to your work.
+
+ To apply the Apache License to your work, attach the following
+ boilerplate notice, with the fields enclosed by brackets "[]"
+ replaced with your own identifying information. (Don't include
+ the brackets!) The text should be enclosed in the appropriate
+ comment syntax for the file format. We also recommend that a
+ file or class name and description of purpose be included on the
+ same "printed page" as the copyright notice for easier
+ identification within third-party archives.
+
+ Copyright [yyyy] [name of copyright owner]
+
+ Licensed under the Apache License, Version 2.0 (the "License");
+ you may not use this file except in compliance with the License.
+ You may obtain a copy of the License at
+
+ http://www.apache.org/licenses/LICENSE-2.0
+
+ Unless required by applicable law or agreed to in writing, software
+ distributed under the License is distributed on an "AS IS" BASIS,
+ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ See the License for the specific language governing permissions and
+ limitations under the License.
diff --git a/chatterbox-nats/chatterbox-nats-api/src/main/resources/META-INF/NOTICE b/chatterbox-nats/chatterbox-nats-api/src/main/resources/META-INF/NOTICE
new file mode 100644
index 0000000..c17892d
--- /dev/null
+++ b/chatterbox-nats/chatterbox-nats-api/src/main/resources/META-INF/NOTICE
@@ -0,0 +1,7 @@
+Slack Connector :: API
+Copyright 2017-2018 The Apache Software Foundation
+
+This product includes software developed at
+The Apache Software Foundation (http://www.apache.org/).
+
+
diff --git a/chatterbox-nats/chatterbox-nats-impl/pom.xml b/chatterbox-nats/chatterbox-nats-impl/pom.xml
new file mode 100644
index 0000000..fbe5f30
--- /dev/null
+++ b/chatterbox-nats/chatterbox-nats-impl/pom.xml
@@ -0,0 +1,64 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+ ~ Licensed to the Apache Software Foundation (ASF) under one
+ ~ or more contributor license agreements. See the NOTICE file
+ ~ distributed with this work for additional information
+ ~ regarding copyright ownership. The ASF licenses this file
+ ~ to you under the Apache License, Version 2.0 (the
+ ~ "License"); you may not use this file except in compliance
+ ~ with the License. You may obtain a copy of the License at
+ ~
+ ~ http://www.apache.org/licenses/LICENSE-2.0
+ ~
+ ~ Unless required by applicable law or agreed to in writing,
+ ~ software distributed under the License is distributed on an
+ ~ "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ ~ KIND, either express or implied. See the License for the
+ ~ specific language governing permissions and limitations
+ ~ under the License.
+ -->
+
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
+
+ <modelVersion>4.0.0</modelVersion>
+
+ <parent>
+ <groupId>org.apache.tomee.chatterbox</groupId>
+ <artifactId>chatterbox-nats-parent</artifactId>
+ <version>0.3-SNAPSHOT</version>
+ </parent>
+
+ <artifactId>chatterbox-nats-impl</artifactId>
+ <packaging>jar</packaging>
+ <name>Chatterbox :: NATS :: Resource Adapter Implementation</name>
+
+ <dependencies>
+ <dependency>
+ <groupId>junit</groupId>
+ <artifactId>junit</artifactId>
+ <scope>test</scope>
+ </dependency>
+ <dependency>
+ <groupId>javax</groupId>
+ <artifactId>javaee-api</artifactId>
+ <scope>provided</scope>
+ </dependency>
+ <dependency>
+ <groupId>${project.groupId}</groupId>
+ <artifactId>chatterbox-nats-api</artifactId>
+ <version>${project.version}</version>
+ <scope>provided</scope>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.tomee</groupId>
+ <artifactId>openejb-core</artifactId>
+ <version>${version.openejb}</version>
+ <scope>provided</scope>
+ </dependency>
+ <dependency>
+ <groupId>io.nats</groupId>
+ <artifactId>java-nats-streaming</artifactId>
+ <version>2.2.3</version>
+ </dependency>
+ </dependencies>
+</project>
diff --git a/chatterbox-nats/chatterbox-nats-impl/src/main/java/org/apache/tomee/chatterbox/nats/adapter/NATSActivationSpec.java b/chatterbox-nats/chatterbox-nats-impl/src/main/java/org/apache/tomee/chatterbox/nats/adapter/NATSActivationSpec.java
new file mode 100644
index 0000000..4b62580
--- /dev/null
+++ b/chatterbox-nats/chatterbox-nats-impl/src/main/java/org/apache/tomee/chatterbox/nats/adapter/NATSActivationSpec.java
@@ -0,0 +1,54 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.tomee.chatterbox.nats.adapter;
+
+import org.apache.tomee.chatterbox.nats.api.InboundListener;
+
+import javax.resource.ResourceException;
+import javax.resource.spi.Activation;
+import javax.resource.spi.ActivationSpec;
+import javax.resource.spi.InvalidPropertyException;
+import javax.resource.spi.ResourceAdapter;
+
+@Activation(messageListeners = InboundListener.class)
+public class NATSActivationSpec implements ActivationSpec {
+
+ private ResourceAdapter resourceAdapter;
+ private Class beanClass;
+
+ public Class getBeanClass() {
+ return beanClass;
+ }
+
+ public void setBeanClass(Class beanClass) {
+ this.beanClass = beanClass;
+ }
+
+ @Override
+ public void validate() throws InvalidPropertyException {
+ }
+
+ @Override
+ public ResourceAdapter getResourceAdapter() {
+ return resourceAdapter;
+ }
+
+ @Override
+ public void setResourceAdapter(ResourceAdapter ra) throws ResourceException {
+ this.resourceAdapter = ra;
+ }
+}
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
new file mode 100644
index 0000000..54d3a62
--- /dev/null
+++ b/chatterbox-nats/chatterbox-nats-impl/src/main/java/org/apache/tomee/chatterbox/nats/adapter/NATSResourceAdapter.java
@@ -0,0 +1,115 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.tomee.chatterbox.nats.adapter;
+
+import javax.resource.ResourceException;
+import javax.resource.spi.ActivationSpec;
+import javax.resource.spi.BootstrapContext;
+import javax.resource.spi.ConfigProperty;
+import javax.resource.spi.Connector;
+import javax.resource.spi.ResourceAdapter;
+import javax.resource.spi.ResourceAdapterInternalException;
+import javax.resource.spi.endpoint.MessageEndpoint;
+import javax.resource.spi.endpoint.MessageEndpointFactory;
+import javax.resource.spi.work.Work;
+import javax.resource.spi.work.WorkManager;
+import javax.transaction.xa.XAResource;
+import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
+import java.lang.IllegalStateException;
+
+@Connector(description = "Sample Resource Adapter", displayName = "Sample Resource Adapter", eisType = "Sample Resource Adapter", version = "1.0")
+public class NATSResourceAdapter implements ResourceAdapter {
+ final Map<NATSActivationSpec, EndpointTarget> targets = new ConcurrentHashMap<NATSActivationSpec, EndpointTarget>();
+
+ @ConfigProperty
+ private String token;
+
+ private WorkManager workManager;
+ private String user;
+ private String userId;
+
+ public void start(BootstrapContext bootstrapContext) throws ResourceAdapterInternalException {
+ workManager = bootstrapContext.getWorkManager();
+ // connect to NATS
+ }
+
+ public void stop() {
+ // disconnect
+ }
+
+ public void endpointActivation(final MessageEndpointFactory messageEndpointFactory, final ActivationSpec activationSpec)
+ throws ResourceException {
+ final NATSActivationSpec NATSActivationSpec = (NATSActivationSpec) activationSpec;
+
+ workManager.scheduleWork(new Work() {
+
+ @Override
+ public void run() {
+ try {
+ final MessageEndpoint messageEndpoint = messageEndpointFactory.createEndpoint(null);
+
+ final EndpointTarget target = new EndpointTarget(messageEndpoint);
+ final Class<?> endpointClass = NATSActivationSpec.getBeanClass() != null ? NATSActivationSpec
+ .getBeanClass() : messageEndpointFactory.getEndpointClass();
+
+
+ targets.put(NATSActivationSpec, target);
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ }
+
+ @Override
+ public void release() {
+ }
+
+ });
+
+ }
+
+ public void endpointDeactivation(MessageEndpointFactory messageEndpointFactory, ActivationSpec activationSpec) {
+ final NATSActivationSpec telnetActivationSpec = (NATSActivationSpec) activationSpec;
+
+ final EndpointTarget endpointTarget = targets.get(telnetActivationSpec);
+ if (endpointTarget == null) {
+ throw new IllegalStateException("No EndpointTarget to undeploy for ActivationSpec " + activationSpec);
+ }
+
+ // unsubscribe
+
+ endpointTarget.messageEndpoint.release();
+ }
+
+ public XAResource[] getXAResources(ActivationSpec[] activationSpecs) throws ResourceException {
+ return new XAResource[0];
+ }
+
+ public void sendMessage(final String channel, final String message) {
+ // publish a message
+ }
+
+
+ private static class EndpointTarget {
+ private final MessageEndpoint messageEndpoint;
+
+ public EndpointTarget(MessageEndpoint messageEndpoint) {
+ this.messageEndpoint = messageEndpoint;
+ }
+
+ }
+}
diff --git a/chatterbox-nats/chatterbox-nats-impl/src/main/java/org/apache/tomee/chatterbox/nats/adapter/out/NATSConnectionFactoryImpl.java b/chatterbox-nats/chatterbox-nats-impl/src/main/java/org/apache/tomee/chatterbox/nats/adapter/out/NATSConnectionFactoryImpl.java
new file mode 100755
index 0000000..429add0
--- /dev/null
+++ b/chatterbox-nats/chatterbox-nats-impl/src/main/java/org/apache/tomee/chatterbox/nats/adapter/out/NATSConnectionFactoryImpl.java
@@ -0,0 +1,69 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.tomee.chatterbox.nats.adapter.out;
+
+import org.apache.tomee.chatterbox.nats.api.NATSConnection;
+import org.apache.tomee.chatterbox.nats.api.NATSConnectionFactory;
+
+import javax.naming.NamingException;
+import javax.naming.Reference;
+import javax.resource.ResourceException;
+import javax.resource.spi.ConnectionManager;
+import java.util.logging.Logger;
+
+public class NATSConnectionFactoryImpl implements NATSConnectionFactory {
+ private static final long serialVersionUID = 1L;
+
+ private static Logger log = Logger.getLogger(NATSConnectionFactoryImpl.class.getName());
+
+ private Reference reference;
+
+ private NATSManagedConnectionFactory mcf;
+
+ private ConnectionManager connectionManager;
+
+ public NATSConnectionFactoryImpl() {
+
+ }
+
+ public NATSConnectionFactoryImpl(NATSManagedConnectionFactory mcf, ConnectionManager cxManager) {
+ this.mcf = mcf;
+ this.connectionManager = cxManager;
+ }
+
+ @Override
+ public NATSConnection getConnection() throws ResourceException {
+ log.finest("getConnection()");
+ return (NATSConnection) connectionManager.allocateConnection(mcf, null);
+ }
+
+ @Override
+ public Reference getReference() throws NamingException {
+ log.finest("getReference()");
+ return reference;
+ }
+
+ @Override
+ public void setReference(Reference reference) {
+ log.finest("setReference()");
+ this.reference = reference;
+ }
+
+
+}
diff --git a/chatterbox-nats/chatterbox-nats-impl/src/main/java/org/apache/tomee/chatterbox/nats/adapter/out/NATSConnectionImpl.java b/chatterbox-nats/chatterbox-nats-impl/src/main/java/org/apache/tomee/chatterbox/nats/adapter/out/NATSConnectionImpl.java
new file mode 100755
index 0000000..8b375f7
--- /dev/null
+++ b/chatterbox-nats/chatterbox-nats-impl/src/main/java/org/apache/tomee/chatterbox/nats/adapter/out/NATSConnectionImpl.java
@@ -0,0 +1,44 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.tomee.chatterbox.nats.adapter.out;
+
+import org.apache.tomee.chatterbox.nats.api.NATSConnection;
+
+import java.util.logging.Logger;
+
+public class NATSConnectionImpl implements NATSConnection {
+ private static Logger log = Logger.getLogger(NATSConnectionImpl.class.getName());
+
+ private NATSManagedConnection mc;
+
+ private NATSManagedConnectionFactory mcf;
+
+ public NATSConnectionImpl(NATSManagedConnection mc, NATSManagedConnectionFactory mcf) {
+ this.mc = mc;
+ this.mcf = mcf;
+ }
+
+ public void sendMessage(final String channel, final String message) {
+ mc.sendMessage(channel, message);
+ }
+
+ public void close() {
+ mc.closeHandle(this);
+ }
+}
diff --git a/chatterbox-nats/chatterbox-nats-impl/src/main/java/org/apache/tomee/chatterbox/nats/adapter/out/NATSManagedConnection.java b/chatterbox-nats/chatterbox-nats-impl/src/main/java/org/apache/tomee/chatterbox/nats/adapter/out/NATSManagedConnection.java
new file mode 100755
index 0000000..0999036
--- /dev/null
+++ b/chatterbox-nats/chatterbox-nats-impl/src/main/java/org/apache/tomee/chatterbox/nats/adapter/out/NATSManagedConnection.java
@@ -0,0 +1,140 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.tomee.chatterbox.nats.adapter.out;
+
+import org.apache.tomee.chatterbox.nats.adapter.NATSResourceAdapter;
+import org.apache.tomee.chatterbox.nats.api.NATSConnection;
+
+import javax.resource.NotSupportedException;
+import javax.resource.ResourceException;
+import javax.resource.spi.ConnectionEvent;
+import javax.resource.spi.ConnectionEventListener;
+import javax.resource.spi.ConnectionRequestInfo;
+import javax.resource.spi.LocalTransaction;
+import javax.resource.spi.ManagedConnection;
+import javax.resource.spi.ManagedConnectionMetaData;
+import javax.security.auth.Subject;
+import javax.transaction.xa.XAResource;
+import java.io.PrintWriter;
+import java.util.ArrayList;
+import java.util.Collections;
+import java.util.List;
+import java.util.logging.Logger;
+
+public class NATSManagedConnection implements ManagedConnection {
+
+ private static Logger log = Logger.getLogger(NATSManagedConnection.class.getName());
+
+ private PrintWriter logwriter;
+
+ private NATSManagedConnectionFactory mcf;
+
+ private List<ConnectionEventListener> listeners;
+
+ private NATSConnectionImpl connection;
+
+ public NATSManagedConnection(NATSManagedConnectionFactory mcf) {
+ this.mcf = mcf;
+ this.logwriter = null;
+ this.listeners = Collections.synchronizedList(new ArrayList<ConnectionEventListener>(1));
+ this.connection = null;
+ }
+
+ public Object getConnection(Subject subject,
+ ConnectionRequestInfo cxRequestInfo) throws ResourceException {
+ log.finest("getConnection()");
+ connection = new NATSConnectionImpl(this, mcf);
+ return connection;
+ }
+
+ public void associateConnection(Object connection) throws ResourceException {
+ log.finest("associateConnection()");
+
+ if (connection == null)
+ throw new ResourceException("Null connection handle");
+
+ if (!(connection instanceof NATSConnectionImpl))
+ throw new ResourceException("Wrong connection handle");
+
+ this.connection = (NATSConnectionImpl) connection;
+ }
+
+ public void cleanup() throws ResourceException {
+ log.finest("cleanup()");
+ }
+
+ public void destroy() throws ResourceException {
+ log.finest("destroy()");
+ }
+
+ public void addConnectionEventListener(ConnectionEventListener listener) {
+ log.finest("addConnectionEventListener()");
+
+ if (listener == null) {
+ throw new IllegalArgumentException("Listener is null");
+ }
+
+ listeners.add(listener);
+ }
+
+ public void removeConnectionEventListener(ConnectionEventListener listener) {
+ log.finest("removeConnectionEventListener()");
+ if (listener == null)
+ throw new IllegalArgumentException("Listener is null");
+ listeners.remove(listener);
+ }
+
+ void closeHandle(NATSConnection handle) {
+ ConnectionEvent event = new ConnectionEvent(this, ConnectionEvent.CONNECTION_CLOSED);
+ event.setConnectionHandle(handle);
+ for (ConnectionEventListener cel : listeners) {
+ cel.connectionClosed(event);
+ }
+ }
+
+ public PrintWriter getLogWriter() throws ResourceException {
+ log.finest("getLogWriter()");
+ return logwriter;
+ }
+
+ public void setLogWriter(PrintWriter out) throws ResourceException {
+ log.finest("setLogWriter()");
+ logwriter = out;
+ }
+
+ public LocalTransaction getLocalTransaction() throws ResourceException {
+ throw new NotSupportedException("getLocalTransaction() not supported");
+ }
+
+ public XAResource getXAResource() throws ResourceException {
+ throw new NotSupportedException("getXAResource() not supported");
+ }
+
+ public ManagedConnectionMetaData getMetaData() throws ResourceException {
+ log.finest("getMetaData()");
+ return new NATSManagedConnectionMetaData();
+ }
+
+ void sendMessage(final String channel, final String message) {
+ log.finest("sendMessage()");
+
+ final NATSResourceAdapter resourceAdapter = (NATSResourceAdapter) mcf.getResourceAdapter();
+ resourceAdapter.sendMessage(channel, message);
+ }
+}
diff --git a/chatterbox-nats/chatterbox-nats-impl/src/main/java/org/apache/tomee/chatterbox/nats/adapter/out/NATSManagedConnectionFactory.java b/chatterbox-nats/chatterbox-nats-impl/src/main/java/org/apache/tomee/chatterbox/nats/adapter/out/NATSManagedConnectionFactory.java
new file mode 100755
index 0000000..7abdd65
--- /dev/null
+++ b/chatterbox-nats/chatterbox-nats-impl/src/main/java/org/apache/tomee/chatterbox/nats/adapter/out/NATSManagedConnectionFactory.java
@@ -0,0 +1,105 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.tomee.chatterbox.nats.adapter.out;
+
+import org.apache.tomee.chatterbox.nats.api.NATSConnection;
+import org.apache.tomee.chatterbox.nats.api.NATSConnectionFactory;
+
+import javax.resource.ResourceException;
+import javax.resource.spi.ConnectionDefinition;
+import javax.resource.spi.ConnectionManager;
+import javax.resource.spi.ConnectionRequestInfo;
+import javax.resource.spi.ManagedConnection;
+import javax.resource.spi.ManagedConnectionFactory;
+import javax.resource.spi.ResourceAdapter;
+import javax.resource.spi.ResourceAdapterAssociation;
+import javax.security.auth.Subject;
+import java.io.PrintWriter;
+import java.util.Iterator;
+import java.util.Set;
+import java.util.logging.Logger;
+
+@ConnectionDefinition(connectionFactory = NATSConnectionFactory.class,
+ connectionFactoryImpl = NATSConnectionFactoryImpl.class,
+ connection = NATSConnection.class,
+ connectionImpl = NATSConnectionImpl.class)
+public class NATSManagedConnectionFactory implements ManagedConnectionFactory, ResourceAdapterAssociation {
+
+ private static final long serialVersionUID = 1L;
+
+ private static Logger log = Logger.getLogger(NATSManagedConnectionFactory.class.getName());
+
+ private ResourceAdapter ra;
+
+ private PrintWriter logwriter;
+
+ public NATSManagedConnectionFactory() {
+
+ }
+
+ public Object createConnectionFactory(ConnectionManager cxManager) throws ResourceException {
+ log.finest("createConnectionFactory()");
+ return new NATSConnectionFactoryImpl(this, cxManager);
+ }
+
+ public Object createConnectionFactory() throws ResourceException {
+ throw new ResourceException("This resource adapter doesn't support non-managed environments");
+ }
+
+ public ManagedConnection createManagedConnection(Subject subject,
+ ConnectionRequestInfo cxRequestInfo) throws ResourceException {
+ log.finest("createManagedConnection()");
+ return new NATSManagedConnection(this);
+ }
+
+ public ManagedConnection matchManagedConnections(Set connectionSet,
+ Subject subject, ConnectionRequestInfo cxRequestInfo) throws ResourceException {
+ log.finest("matchManagedConnections()");
+ ManagedConnection result = null;
+ Iterator it = connectionSet.iterator();
+ while (result == null && it.hasNext()) {
+ ManagedConnection mc = (ManagedConnection) it.next();
+ if (mc instanceof NATSManagedConnection) {
+ result = mc;
+ }
+
+ }
+ return result;
+ }
+
+ public PrintWriter getLogWriter() throws ResourceException {
+ log.finest("getLogWriter()");
+ return logwriter;
+ }
+
+ public void setLogWriter(PrintWriter out) throws ResourceException {
+ log.finest("setLogWriter()");
+ logwriter = out;
+ }
+
+ public ResourceAdapter getResourceAdapter() {
+ log.finest("getResourceAdapter()");
+ return ra;
+ }
+
+ public void setResourceAdapter(ResourceAdapter ra) {
+ log.finest("setResourceAdapter()");
+ this.ra = ra;
+ }
+}
diff --git a/chatterbox-nats/chatterbox-nats-impl/src/main/java/org/apache/tomee/chatterbox/nats/adapter/out/NATSManagedConnectionMetaData.java b/chatterbox-nats/chatterbox-nats-impl/src/main/java/org/apache/tomee/chatterbox/nats/adapter/out/NATSManagedConnectionMetaData.java
new file mode 100755
index 0000000..3a6a780
--- /dev/null
+++ b/chatterbox-nats/chatterbox-nats-impl/src/main/java/org/apache/tomee/chatterbox/nats/adapter/out/NATSManagedConnectionMetaData.java
@@ -0,0 +1,56 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.tomee.chatterbox.nats.adapter.out;
+
+import javax.resource.ResourceException;
+import javax.resource.spi.ManagedConnectionMetaData;
+import java.util.logging.Logger;
+
+public class NATSManagedConnectionMetaData implements ManagedConnectionMetaData {
+
+ private static Logger log = Logger.getLogger(NATSManagedConnectionMetaData.class.getName());
+
+ public NATSManagedConnectionMetaData() {
+
+ }
+
+ @Override
+ public String getEISProductName() throws ResourceException {
+ log.finest("getEISProductName()");
+ return null; //TODO
+ }
+
+ @Override
+ public String getEISProductVersion() throws ResourceException {
+ log.finest("getEISProductVersion()");
+ return null; //TODO
+ }
+
+ @Override
+ public int getMaxConnections() throws ResourceException {
+ log.finest("getMaxConnections()");
+ return 0; //TODO
+ }
+
+ @Override
+ public String getUserName() throws ResourceException {
+ log.finest("getUserName()");
+ return null; //TODO
+ }
+}
diff --git a/chatterbox-nats/chatterbox-nats-impl/src/main/resources/META-INF/LICENSE b/chatterbox-nats/chatterbox-nats-impl/src/main/resources/META-INF/LICENSE
new file mode 100644
index 0000000..261eeb9
--- /dev/null
+++ b/chatterbox-nats/chatterbox-nats-impl/src/main/resources/META-INF/LICENSE
@@ -0,0 +1,201 @@
+ Apache License
+ Version 2.0, January 2004
+ http://www.apache.org/licenses/
+
+ TERMS AND CONDITIONS FOR USE, REPRODUCTION, AND DISTRIBUTION
+
+ 1. Definitions.
+
+ "License" shall mean the terms and conditions for use, reproduction,
+ and distribution as defined by Sections 1 through 9 of this document.
+
+ "Licensor" shall mean the copyright owner or entity authorized by
+ the copyright owner that is granting the License.
+
+ "Legal Entity" shall mean the union of the acting entity and all
+ other entities that control, are controlled by, or are under common
+ control with that entity. For the purposes of this definition,
+ "control" means (i) the power, direct or indirect, to cause the
+ direction or management of such entity, whether by contract or
+ otherwise, or (ii) ownership of fifty percent (50%) or more of the
+ outstanding shares, or (iii) beneficial ownership of such entity.
+
+ "You" (or "Your") shall mean an individual or Legal Entity
+ exercising permissions granted by this License.
+
+ "Source" form shall mean the preferred form for making modifications,
+ including but not limited to software source code, documentation
+ source, and configuration files.
+
+ "Object" form shall mean any form resulting from mechanical
+ transformation or translation of a Source form, including but
+ not limited to compiled object code, generated documentation,
+ and conversions to other media types.
+
+ "Work" shall mean the work of authorship, whether in Source or
+ Object form, made available under the License, as indicated by a
+ copyright notice that is included in or attached to the work
+ (an example is provided in the Appendix below).
+
+ "Derivative Works" shall mean any work, whether in Source or Object
+ form, that is based on (or derived from) the Work and for which the
+ editorial revisions, annotations, elaborations, or other modifications
+ represent, as a whole, an original work of authorship. For the purposes
+ of this License, Derivative Works shall not include works that remain
+ separable from, or merely link (or bind by name) to the interfaces of,
+ the Work and Derivative Works thereof.
+
+ "Contribution" shall mean any work of authorship, including
+ the original version of the Work and any modifications or additions
+ to that Work or Derivative Works thereof, that is intentionally
+ submitted to Licensor for inclusion in the Work by the copyright owner
+ or by an individual or Legal Entity authorized to submit on behalf of
+ the copyright owner. For the purposes of this definition, "submitted"
+ means any form of electronic, verbal, or written communication sent
+ to the Licensor or its representatives, including but not limited to
+ communication on electronic mailing lists, source code control systems,
+ and issue tracking systems that are managed by, or on behalf of, the
+ Licensor for the purpose of discussing and improving the Work, but
+ excluding communication that is conspicuously marked or otherwise
+ designated in writing by the copyright owner as "Not a Contribution."
+
+ "Contributor" shall mean Licensor and any individual or Legal Entity
+ on behalf of whom a Contribution has been received by Licensor and
+ subsequently incorporated within the Work.
+
+ 2. Grant of Copyright License. Subject to the terms and conditions of
+ this License, each Contributor hereby grants to You a perpetual,
+ worldwide, non-exclusive, no-charge, royalty-free, irrevocable
+ copyright license to reproduce, prepare Derivative Works of,
+ publicly display, publicly perform, sublicense, and distribute the
+ Work and such Derivative Works in Source or Object form.
+
+ 3. Grant of Patent License. Subject to the terms and conditions of
+ this License, each Contributor hereby grants to You a perpetual,
+ worldwide, non-exclusive, no-charge, royalty-free, irrevocable
+ (except as stated in this section) patent license to make, have made,
+ use, offer to sell, sell, import, and otherwise transfer the Work,
+ where such license applies only to those patent claims licensable
+ by such Contributor that are necessarily infringed by their
+ Contribution(s) alone or by combination of their Contribution(s)
+ with the Work to which such Contribution(s) was submitted. If You
+ institute patent litigation against any entity (including a
+ cross-claim or counterclaim in a lawsuit) alleging that the Work
+ or a Contribution incorporated within the Work constitutes direct
+ or contributory patent infringement, then any patent licenses
+ granted to You under this License for that Work shall terminate
+ as of the date such litigation is filed.
+
+ 4. Redistribution. You may reproduce and distribute copies of the
+ Work or Derivative Works thereof in any medium, with or without
+ modifications, and in Source or Object form, provided that You
+ meet the following conditions:
+
+ (a) You must give any other recipients of the Work or
+ Derivative Works a copy of this License; and
+
+ (b) You must cause any modified files to carry prominent notices
+ stating that You changed the files; and
+
+ (c) You must retain, in the Source form of any Derivative Works
+ that You distribute, all copyright, patent, trademark, and
+ attribution notices from the Source form of the Work,
+ excluding those notices that do not pertain to any part of
+ the Derivative Works; and
+
+ (d) If the Work includes a "NOTICE" text file as part of its
+ distribution, then any Derivative Works that You distribute must
+ include a readable copy of the attribution notices contained
+ within such NOTICE file, excluding those notices that do not
+ pertain to any part of the Derivative Works, in at least one
+ of the following places: within a NOTICE text file distributed
+ as part of the Derivative Works; within the Source form or
+ documentation, if provided along with the Derivative Works; or,
+ within a display generated by the Derivative Works, if and
+ wherever such third-party notices normally appear. The contents
+ of the NOTICE file are for informational purposes only and
+ do not modify the License. You may add Your own attribution
+ notices within Derivative Works that You distribute, alongside
+ or as an addendum to the NOTICE text from the Work, provided
+ that such additional attribution notices cannot be construed
+ as modifying the License.
+
+ You may add Your own copyright statement to Your modifications and
+ may provide additional or different license terms and conditions
+ for use, reproduction, or distribution of Your modifications, or
+ for any such Derivative Works as a whole, provided Your use,
+ reproduction, and distribution of the Work otherwise complies with
+ the conditions stated in this License.
+
+ 5. Submission of Contributions. Unless You explicitly state otherwise,
+ any Contribution intentionally submitted for inclusion in the Work
+ by You to the Licensor shall be under the terms and conditions of
+ this License, without any additional terms or conditions.
+ Notwithstanding the above, nothing herein shall supersede or modify
+ the terms of any separate license agreement you may have executed
+ with Licensor regarding such Contributions.
+
+ 6. Trademarks. This License does not grant permission to use the trade
+ names, trademarks, service marks, or product names of the Licensor,
+ except as required for reasonable and customary use in describing the
+ origin of the Work and reproducing the content of the NOTICE file.
+
+ 7. Disclaimer of Warranty. Unless required by applicable law or
+ agreed to in writing, Licensor provides the Work (and each
+ Contributor provides its Contributions) on an "AS IS" BASIS,
+ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
+ implied, including, without limitation, any warranties or conditions
+ of TITLE, NON-INFRINGEMENT, MERCHANTABILITY, or FITNESS FOR A
+ PARTICULAR PURPOSE. You are solely responsible for determining the
+ appropriateness of using or redistributing the Work and assume any
+ risks associated with Your exercise of permissions under this License.
+
+ 8. Limitation of Liability. In no event and under no legal theory,
+ whether in tort (including negligence), contract, or otherwise,
+ unless required by applicable law (such as deliberate and grossly
+ negligent acts) or agreed to in writing, shall any Contributor be
+ liable to You for damages, including any direct, indirect, special,
+ incidental, or consequential damages of any character arising as a
+ result of this License or out of the use or inability to use the
+ Work (including but not limited to damages for loss of goodwill,
+ work stoppage, computer failure or malfunction, or any and all
+ other commercial damages or losses), even if such Contributor
+ has been advised of the possibility of such damages.
+
+ 9. Accepting Warranty or Additional Liability. While redistributing
+ the Work or Derivative Works thereof, You may choose to offer,
+ and charge a fee for, acceptance of support, warranty, indemnity,
+ or other liability obligations and/or rights consistent with this
+ License. However, in accepting such obligations, You may act only
+ on Your own behalf and on Your sole responsibility, not on behalf
+ of any other Contributor, and only if You agree to indemnify,
+ defend, and hold each Contributor harmless for any liability
+ incurred by, or claims asserted against, such Contributor by reason
+ of your accepting any such warranty or additional liability.
+
+ END OF TERMS AND CONDITIONS
+
+ APPENDIX: How to apply the Apache License to your work.
+
+ To apply the Apache License to your work, attach the following
+ boilerplate notice, with the fields enclosed by brackets "[]"
+ replaced with your own identifying information. (Don't include
+ the brackets!) The text should be enclosed in the appropriate
+ comment syntax for the file format. We also recommend that a
+ file or class name and description of purpose be included on the
+ same "printed page" as the copyright notice for easier
+ identification within third-party archives.
+
+ Copyright [yyyy] [name of copyright owner]
+
+ Licensed under the Apache License, Version 2.0 (the "License");
+ you may not use this file except in compliance with the License.
+ You may obtain a copy of the License at
+
+ http://www.apache.org/licenses/LICENSE-2.0
+
+ Unless required by applicable law or agreed to in writing, software
+ distributed under the License is distributed on an "AS IS" BASIS,
+ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ See the License for the specific language governing permissions and
+ limitations under the License.
diff --git a/chatterbox-nats/chatterbox-nats-impl/src/main/resources/META-INF/NOTICE b/chatterbox-nats/chatterbox-nats-impl/src/main/resources/META-INF/NOTICE
new file mode 100644
index 0000000..22c327e
--- /dev/null
+++ b/chatterbox-nats/chatterbox-nats-impl/src/main/resources/META-INF/NOTICE
@@ -0,0 +1,7 @@
+Slack Connector :: Resource Adapter Implementation
+Copyright 2017-2018 The Apache Software Foundation
+
+This product includes software developed at
+The Apache Software Foundation (http://www.apache.org/).
+
+
diff --git a/chatterbox-nats/chatterbox-nats-rar/pom.xml b/chatterbox-nats/chatterbox-nats-rar/pom.xml
new file mode 100644
index 0000000..5ca1b39
--- /dev/null
+++ b/chatterbox-nats/chatterbox-nats-rar/pom.xml
@@ -0,0 +1,42 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+ ~ Licensed to the Apache Software Foundation (ASF) under one
+ ~ or more contributor license agreements. See the NOTICE file
+ ~ distributed with this work for additional information
+ ~ regarding copyright ownership. The ASF licenses this file
+ ~ to you under the Apache License, Version 2.0 (the
+ ~ "License"); you may not use this file except in compliance
+ ~ with the License. You may obtain a copy of the License at
+ ~
+ ~ http://www.apache.org/licenses/LICENSE-2.0
+ ~
+ ~ Unless required by applicable law or agreed to in writing,
+ ~ software distributed under the License is distributed on an
+ ~ "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ ~ KIND, either express or implied. See the License for the
+ ~ specific language governing permissions and limitations
+ ~ under the License.
+ -->
+
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
+
+ <modelVersion>4.0.0</modelVersion>
+
+ <parent>
+ <groupId>org.apache.tomee.chatterbox</groupId>
+ <artifactId>chatterbox-nats-parent</artifactId>
+ <version>0.3-SNAPSHOT</version>
+ </parent>
+
+ <artifactId>chatterbox-nats-rar</artifactId>
+ <packaging>rar</packaging>
+ <name>Chatterbox :: NATS :: Resource Adapter</name>
+
+ <dependencies>
+ <dependency>
+ <groupId>${project.groupId}</groupId>
+ <artifactId>chatterbox-nats-impl</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+ </dependencies>
+</project>
diff --git a/chatterbox-nats/chatterbox-nats-rar/src/main/rar/META-INF/LICENSE b/chatterbox-nats/chatterbox-nats-rar/src/main/rar/META-INF/LICENSE
new file mode 100644
index 0000000..261eeb9
--- /dev/null
+++ b/chatterbox-nats/chatterbox-nats-rar/src/main/rar/META-INF/LICENSE
@@ -0,0 +1,201 @@
+ Apache License
+ Version 2.0, January 2004
+ http://www.apache.org/licenses/
+
+ TERMS AND CONDITIONS FOR USE, REPRODUCTION, AND DISTRIBUTION
+
+ 1. Definitions.
+
+ "License" shall mean the terms and conditions for use, reproduction,
+ and distribution as defined by Sections 1 through 9 of this document.
+
+ "Licensor" shall mean the copyright owner or entity authorized by
+ the copyright owner that is granting the License.
+
+ "Legal Entity" shall mean the union of the acting entity and all
+ other entities that control, are controlled by, or are under common
+ control with that entity. For the purposes of this definition,
+ "control" means (i) the power, direct or indirect, to cause the
+ direction or management of such entity, whether by contract or
+ otherwise, or (ii) ownership of fifty percent (50%) or more of the
+ outstanding shares, or (iii) beneficial ownership of such entity.
+
+ "You" (or "Your") shall mean an individual or Legal Entity
+ exercising permissions granted by this License.
+
+ "Source" form shall mean the preferred form for making modifications,
+ including but not limited to software source code, documentation
+ source, and configuration files.
+
+ "Object" form shall mean any form resulting from mechanical
+ transformation or translation of a Source form, including but
+ not limited to compiled object code, generated documentation,
+ and conversions to other media types.
+
+ "Work" shall mean the work of authorship, whether in Source or
+ Object form, made available under the License, as indicated by a
+ copyright notice that is included in or attached to the work
+ (an example is provided in the Appendix below).
+
+ "Derivative Works" shall mean any work, whether in Source or Object
+ form, that is based on (or derived from) the Work and for which the
+ editorial revisions, annotations, elaborations, or other modifications
+ represent, as a whole, an original work of authorship. For the purposes
+ of this License, Derivative Works shall not include works that remain
+ separable from, or merely link (or bind by name) to the interfaces of,
+ the Work and Derivative Works thereof.
+
+ "Contribution" shall mean any work of authorship, including
+ the original version of the Work and any modifications or additions
+ to that Work or Derivative Works thereof, that is intentionally
+ submitted to Licensor for inclusion in the Work by the copyright owner
+ or by an individual or Legal Entity authorized to submit on behalf of
+ the copyright owner. For the purposes of this definition, "submitted"
+ means any form of electronic, verbal, or written communication sent
+ to the Licensor or its representatives, including but not limited to
+ communication on electronic mailing lists, source code control systems,
+ and issue tracking systems that are managed by, or on behalf of, the
+ Licensor for the purpose of discussing and improving the Work, but
+ excluding communication that is conspicuously marked or otherwise
+ designated in writing by the copyright owner as "Not a Contribution."
+
+ "Contributor" shall mean Licensor and any individual or Legal Entity
+ on behalf of whom a Contribution has been received by Licensor and
+ subsequently incorporated within the Work.
+
+ 2. Grant of Copyright License. Subject to the terms and conditions of
+ this License, each Contributor hereby grants to You a perpetual,
+ worldwide, non-exclusive, no-charge, royalty-free, irrevocable
+ copyright license to reproduce, prepare Derivative Works of,
+ publicly display, publicly perform, sublicense, and distribute the
+ Work and such Derivative Works in Source or Object form.
+
+ 3. Grant of Patent License. Subject to the terms and conditions of
+ this License, each Contributor hereby grants to You a perpetual,
+ worldwide, non-exclusive, no-charge, royalty-free, irrevocable
+ (except as stated in this section) patent license to make, have made,
+ use, offer to sell, sell, import, and otherwise transfer the Work,
+ where such license applies only to those patent claims licensable
+ by such Contributor that are necessarily infringed by their
+ Contribution(s) alone or by combination of their Contribution(s)
+ with the Work to which such Contribution(s) was submitted. If You
+ institute patent litigation against any entity (including a
+ cross-claim or counterclaim in a lawsuit) alleging that the Work
+ or a Contribution incorporated within the Work constitutes direct
+ or contributory patent infringement, then any patent licenses
+ granted to You under this License for that Work shall terminate
+ as of the date such litigation is filed.
+
+ 4. Redistribution. You may reproduce and distribute copies of the
+ Work or Derivative Works thereof in any medium, with or without
+ modifications, and in Source or Object form, provided that You
+ meet the following conditions:
+
+ (a) You must give any other recipients of the Work or
+ Derivative Works a copy of this License; and
+
+ (b) You must cause any modified files to carry prominent notices
+ stating that You changed the files; and
+
+ (c) You must retain, in the Source form of any Derivative Works
+ that You distribute, all copyright, patent, trademark, and
+ attribution notices from the Source form of the Work,
+ excluding those notices that do not pertain to any part of
+ the Derivative Works; and
+
+ (d) If the Work includes a "NOTICE" text file as part of its
+ distribution, then any Derivative Works that You distribute must
+ include a readable copy of the attribution notices contained
+ within such NOTICE file, excluding those notices that do not
+ pertain to any part of the Derivative Works, in at least one
+ of the following places: within a NOTICE text file distributed
+ as part of the Derivative Works; within the Source form or
+ documentation, if provided along with the Derivative Works; or,
+ within a display generated by the Derivative Works, if and
+ wherever such third-party notices normally appear. The contents
+ of the NOTICE file are for informational purposes only and
+ do not modify the License. You may add Your own attribution
+ notices within Derivative Works that You distribute, alongside
+ or as an addendum to the NOTICE text from the Work, provided
+ that such additional attribution notices cannot be construed
+ as modifying the License.
+
+ You may add Your own copyright statement to Your modifications and
+ may provide additional or different license terms and conditions
+ for use, reproduction, or distribution of Your modifications, or
+ for any such Derivative Works as a whole, provided Your use,
+ reproduction, and distribution of the Work otherwise complies with
+ the conditions stated in this License.
+
+ 5. Submission of Contributions. Unless You explicitly state otherwise,
+ any Contribution intentionally submitted for inclusion in the Work
+ by You to the Licensor shall be under the terms and conditions of
+ this License, without any additional terms or conditions.
+ Notwithstanding the above, nothing herein shall supersede or modify
+ the terms of any separate license agreement you may have executed
+ with Licensor regarding such Contributions.
+
+ 6. Trademarks. This License does not grant permission to use the trade
+ names, trademarks, service marks, or product names of the Licensor,
+ except as required for reasonable and customary use in describing the
+ origin of the Work and reproducing the content of the NOTICE file.
+
+ 7. Disclaimer of Warranty. Unless required by applicable law or
+ agreed to in writing, Licensor provides the Work (and each
+ Contributor provides its Contributions) on an "AS IS" BASIS,
+ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
+ implied, including, without limitation, any warranties or conditions
+ of TITLE, NON-INFRINGEMENT, MERCHANTABILITY, or FITNESS FOR A
+ PARTICULAR PURPOSE. You are solely responsible for determining the
+ appropriateness of using or redistributing the Work and assume any
+ risks associated with Your exercise of permissions under this License.
+
+ 8. Limitation of Liability. In no event and under no legal theory,
+ whether in tort (including negligence), contract, or otherwise,
+ unless required by applicable law (such as deliberate and grossly
+ negligent acts) or agreed to in writing, shall any Contributor be
+ liable to You for damages, including any direct, indirect, special,
+ incidental, or consequential damages of any character arising as a
+ result of this License or out of the use or inability to use the
+ Work (including but not limited to damages for loss of goodwill,
+ work stoppage, computer failure or malfunction, or any and all
+ other commercial damages or losses), even if such Contributor
+ has been advised of the possibility of such damages.
+
+ 9. Accepting Warranty or Additional Liability. While redistributing
+ the Work or Derivative Works thereof, You may choose to offer,
+ and charge a fee for, acceptance of support, warranty, indemnity,
+ or other liability obligations and/or rights consistent with this
+ License. However, in accepting such obligations, You may act only
+ on Your own behalf and on Your sole responsibility, not on behalf
+ of any other Contributor, and only if You agree to indemnify,
+ defend, and hold each Contributor harmless for any liability
+ incurred by, or claims asserted against, such Contributor by reason
+ of your accepting any such warranty or additional liability.
+
+ END OF TERMS AND CONDITIONS
+
+ APPENDIX: How to apply the Apache License to your work.
+
+ To apply the Apache License to your work, attach the following
+ boilerplate notice, with the fields enclosed by brackets "[]"
+ replaced with your own identifying information. (Don't include
+ the brackets!) The text should be enclosed in the appropriate
+ comment syntax for the file format. We also recommend that a
+ file or class name and description of purpose be included on the
+ same "printed page" as the copyright notice for easier
+ identification within third-party archives.
+
+ Copyright [yyyy] [name of copyright owner]
+
+ Licensed under the Apache License, Version 2.0 (the "License");
+ you may not use this file except in compliance with the License.
+ You may obtain a copy of the License at
+
+ http://www.apache.org/licenses/LICENSE-2.0
+
+ Unless required by applicable law or agreed to in writing, software
+ distributed under the License is distributed on an "AS IS" BASIS,
+ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ See the License for the specific language governing permissions and
+ limitations under the License.
diff --git a/chatterbox-nats/chatterbox-nats-rar/src/main/rar/META-INF/NOTICE b/chatterbox-nats/chatterbox-nats-rar/src/main/rar/META-INF/NOTICE
new file mode 100644
index 0000000..626516d
--- /dev/null
+++ b/chatterbox-nats/chatterbox-nats-rar/src/main/rar/META-INF/NOTICE
@@ -0,0 +1,5 @@
+Slack Connector :: Resource Adapter
+Copyright 2017-2018 The Apache Software Foundation
+
+This product includes software developed at
+The Apache Software Foundation (http://www.apache.org/).
diff --git a/chatterbox-nats/chatterbox-nats-rar/src/main/rar/META-INF/ra.xml b/chatterbox-nats/chatterbox-nats-rar/src/main/rar/META-INF/ra.xml
new file mode 100644
index 0000000..c44905f
--- /dev/null
+++ b/chatterbox-nats/chatterbox-nats-rar/src/main/rar/META-INF/ra.xml
@@ -0,0 +1,63 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+ ~ Licensed to the Apache Software Foundation (ASF) under one
+ ~ or more contributor license agreements. See the NOTICE file
+ ~ distributed with this work for additional information
+ ~ regarding copyright ownership. The ASF licenses this file
+ ~ to you under the Apache License, Version 2.0 (the
+ ~ "License"); you may not use this file except in compliance
+ ~ with the License. You may obtain a copy of the License at
+ ~
+ ~ http://www.apache.org/licenses/LICENSE-2.0
+ ~
+ ~ Unless required by applicable law or agreed to in writing,
+ ~ software distributed under the License is distributed on an
+ ~ "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ ~ KIND, either express or implied. See the License for the
+ ~ specific language governing permissions and limitations
+ ~ under the License.
+ -->
+
+<connector xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+ xmlns="http://xmlns.jcp.org/xml/ns/javaee"
+ xsi:schemaLocation="http://xmlns.jcp.org/xml/ns/javaee http://xmlns.jcp.org/xml/ns/javaee/connector_1_7.xsd"
+ version="1.7">
+ <description>Chatterbox Slack Connector</description>
+ <display-name>Chatterbox Slack Connector</display-name>
+ <eis-type>Slack Connector</eis-type>
+ <resourceadapter-version>1.0</resourceadapter-version>
+ <license>
+ <license-required>false</license-required>
+ </license>
+ <resourceadapter>
+ <resourceadapter-class>org.apache.tomee.chatterbox.nats.adapter.NATSResourceAdapter</resourceadapter-class>
+ <config-property>
+ <config-property-name>token</config-property-name>
+ <config-property-type>String</config-property-type>
+ </config-property>
+ <outbound-resourceadapter>
+ <connection-definition>
+ <managedconnectionfactory-class>org.apache.tomee.chatterbox.nats.adapter.out.NATSManagedConnectionFactory
+ </managedconnectionfactory-class>
+ <connectionfactory-interface>SlackConnectionFactory
+ </connectionfactory-interface>
+ <connectionfactory-impl-class>org.apache.tomee.chatterbox.nats.adapter.out.NATSConnectionFactoryImpl
+ </connectionfactory-impl-class>
+ <connection-interface>SlackConnection</connection-interface>
+ <connection-impl-class>org.apache.tomee.chatterbox.nats.adapter.out.NATSConnectionImpl</connection-impl-class>
+ </connection-definition>
+ <transaction-support>NoTransaction</transaction-support>
+ <reauthentication-support>false</reauthentication-support>
+ </outbound-resourceadapter>
+ <inbound-resourceadapter>
+ <messageadapter>
+ <messagelistener>
+ <messagelistener-type>InboundListener</messagelistener-type>
+ <activationspec>
+ <activationspec-class>org.apache.tomee.chatterbox.nats.adapter.NATSActivationSpec</activationspec-class>
+ </activationspec>
+ </messagelistener>
+ </messageadapter>
+ </inbound-resourceadapter>
+ </resourceadapter>
+</connector>
diff --git a/chatterbox-nats/chatterbox-nats-sample-war/pom.xml b/chatterbox-nats/chatterbox-nats-sample-war/pom.xml
new file mode 100644
index 0000000..aae7a99
--- /dev/null
+++ b/chatterbox-nats/chatterbox-nats-sample-war/pom.xml
@@ -0,0 +1,102 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+ ~ Licensed to the Apache Software Foundation (ASF) under one
+ ~ or more contributor license agreements. See the NOTICE file
+ ~ distributed with this work for additional information
+ ~ regarding copyright ownership. The ASF licenses this file
+ ~ to you under the Apache License, Version 2.0 (the
+ ~ "License"); you may not use this file except in compliance
+ ~ with the License. You may obtain a copy of the License at
+ ~
+ ~ http://www.apache.org/licenses/LICENSE-2.0
+ ~
+ ~ Unless required by applicable law or agreed to in writing,
+ ~ software distributed under the License is distributed on an
+ ~ "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ ~ KIND, either express or implied. See the License for the
+ ~ specific language governing permissions and limitations
+ ~ under the License.
+ -->
+
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
+
+ <modelVersion>4.0.0</modelVersion>
+
+ <parent>
+ <groupId>org.apache.tomee.chatterbox</groupId>
+ <artifactId>chatterbox-nats-parent</artifactId>
+ <version>0.3-SNAPSHOT</version>
+ </parent>
+
+ <artifactId>chatterbox-nats-sample-war</artifactId>
+ <packaging>war</packaging>
+ <name>Chatterbox :: NATS :: Sample</name>
+
+ <dependencies>
+ <dependency>
+ <groupId>${project.groupId}</groupId>
+ <artifactId>chatterbox-nats-api</artifactId>
+ <version>${project.version}</version>
+ <scope>provided</scope>
+ </dependency>
+ <dependency>
+ <groupId>${project.groupId}</groupId>
+ <artifactId>chatterbox-nats-impl</artifactId>
+ <version>${project.version}</version>
+ <scope>test</scope>
+ </dependency>
+ <dependency>
+ <groupId>junit</groupId>
+ <artifactId>junit</artifactId>
+ <version>4.11</version>
+ <scope>test</scope>
+ </dependency>
+ <dependency>
+ <groupId>javax</groupId>
+ <artifactId>javaee-api</artifactId>
+ <scope>provided</scope>
+ </dependency>
+ <dependency>
+ <groupId>org.tomitribe</groupId>
+ <artifactId>tomitribe-util</artifactId>
+ <scope>provided</scope>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.tomee</groupId>
+ <artifactId>apache-tomee</artifactId>
+ <version>${version.tomee}</version>
+ <classifier>plus</classifier>
+ <type>zip</type>
+ <scope>test</scope>
+ </dependency>
+ </dependencies>
+
+ <build>
+ <plugins>
+ <plugin>
+ <groupId>org.apache.maven.plugins</groupId>
+ <artifactId>maven-war-plugin</artifactId>
+ <configuration>
+ <failOnMissingWebXml>false</failOnMissingWebXml>
+ </configuration>
+ </plugin>
+ <plugin>
+ <groupId>org.apache.tomee.maven</groupId>
+ <artifactId>tomee-maven-plugin</artifactId>
+ <version>${version.tomee}</version>
+ <configuration>
+ <tomeeVersion>${version.tomee}</tomeeVersion>
+ <tomeeClassifier>plus</tomeeClassifier>
+ <libs>
+ <lib>org.apache.tomee.chatterbox:chatterbox-nats-api:${project.version}:jar</lib>
+ <lib>org.tomitribe:tomitribe-util:1.1.0:jar</lib>
+ <lib>org.tomitribe:tomitribe-crest-api:0.3:jar</lib>
+ </libs>
+ <apps>
+ <app>org.apache.tomee.chatterbox:chatterbox-nats-rar:${project.version}:rar</app>
+ </apps>
+ </configuration>
+ </plugin>
+ </plugins>
+ </build>
+</project>
diff --git a/chatterbox-nats/chatterbox-nats-sample-war/src/main/java/org/superbiz/Sender.java b/chatterbox-nats/chatterbox-nats-sample-war/src/main/java/org/superbiz/Sender.java
new file mode 100644
index 0000000..7ea3778
--- /dev/null
+++ b/chatterbox-nats/chatterbox-nats-sample-war/src/main/java/org/superbiz/Sender.java
@@ -0,0 +1,54 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.superbiz;
+
+import org.apache.tomee.chatterbox.nats.api.NATSConnection;
+import org.apache.tomee.chatterbox.nats.api.NATSConnectionFactory;
+
+import javax.annotation.Resource;
+import javax.ejb.Lock;
+import javax.ejb.LockType;
+import javax.ejb.Singleton;
+import javax.resource.ResourceException;
+import javax.ws.rs.Consumes;
+import javax.ws.rs.POST;
+import javax.ws.rs.Path;
+import javax.ws.rs.PathParam;
+import javax.ws.rs.core.MediaType;
+
+@Singleton
+@Lock(LockType.READ)
+@Path("sender")
+public class Sender {
+
+ @Resource
+ private NATSConnectionFactory cf;
+
+ @Path("{channel}")
+ @POST
+ @Consumes(MediaType.TEXT_PLAIN)
+ public void sendMessage(@PathParam("channel") final String channel, final String message) {
+ try {
+ final NATSConnection connection = cf.getConnection();
+ connection.sendMessage(channel, message);
+ connection.close();
+ } catch (ResourceException e) {
+ // ignore
+ }
+ }
+
+}
diff --git a/chatterbox-nats/chatterbox-nats-sample-war/src/main/java/org/superbiz/SystemBean.java b/chatterbox-nats/chatterbox-nats-sample-war/src/main/java/org/superbiz/SystemBean.java
new file mode 100644
index 0000000..623b3f4
--- /dev/null
+++ b/chatterbox-nats/chatterbox-nats-sample-war/src/main/java/org/superbiz/SystemBean.java
@@ -0,0 +1,33 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.superbiz;
+
+import org.apache.tomee.chatterbox.nats.api.InboundListener;
+import org.apache.tomee.chatterbox.nats.api.NATSException;
+import org.apache.tomee.chatterbox.nats.api.NATSMessage;
+
+import javax.ejb.MessageDriven;
+
+@MessageDriven(name = "Receiver")
+public class SystemBean implements InboundListener {
+
+
+ @Override
+ public void onMessage(NATSMessage message) throws NATSException {
+ // TODO: fill in implementation here
+ }
+}
diff --git a/chatterbox-nats/chatterbox-nats-sample-war/src/main/resources/META-INF/LICENSE b/chatterbox-nats/chatterbox-nats-sample-war/src/main/resources/META-INF/LICENSE
new file mode 100644
index 0000000..261eeb9
--- /dev/null
+++ b/chatterbox-nats/chatterbox-nats-sample-war/src/main/resources/META-INF/LICENSE
@@ -0,0 +1,201 @@
+ Apache License
+ Version 2.0, January 2004
+ http://www.apache.org/licenses/
+
+ TERMS AND CONDITIONS FOR USE, REPRODUCTION, AND DISTRIBUTION
+
+ 1. Definitions.
+
+ "License" shall mean the terms and conditions for use, reproduction,
+ and distribution as defined by Sections 1 through 9 of this document.
+
+ "Licensor" shall mean the copyright owner or entity authorized by
+ the copyright owner that is granting the License.
+
+ "Legal Entity" shall mean the union of the acting entity and all
+ other entities that control, are controlled by, or are under common
+ control with that entity. For the purposes of this definition,
+ "control" means (i) the power, direct or indirect, to cause the
+ direction or management of such entity, whether by contract or
+ otherwise, or (ii) ownership of fifty percent (50%) or more of the
+ outstanding shares, or (iii) beneficial ownership of such entity.
+
+ "You" (or "Your") shall mean an individual or Legal Entity
+ exercising permissions granted by this License.
+
+ "Source" form shall mean the preferred form for making modifications,
+ including but not limited to software source code, documentation
+ source, and configuration files.
+
+ "Object" form shall mean any form resulting from mechanical
+ transformation or translation of a Source form, including but
+ not limited to compiled object code, generated documentation,
+ and conversions to other media types.
+
+ "Work" shall mean the work of authorship, whether in Source or
+ Object form, made available under the License, as indicated by a
+ copyright notice that is included in or attached to the work
+ (an example is provided in the Appendix below).
+
+ "Derivative Works" shall mean any work, whether in Source or Object
+ form, that is based on (or derived from) the Work and for which the
+ editorial revisions, annotations, elaborations, or other modifications
+ represent, as a whole, an original work of authorship. For the purposes
+ of this License, Derivative Works shall not include works that remain
+ separable from, or merely link (or bind by name) to the interfaces of,
+ the Work and Derivative Works thereof.
+
+ "Contribution" shall mean any work of authorship, including
+ the original version of the Work and any modifications or additions
+ to that Work or Derivative Works thereof, that is intentionally
+ submitted to Licensor for inclusion in the Work by the copyright owner
+ or by an individual or Legal Entity authorized to submit on behalf of
+ the copyright owner. For the purposes of this definition, "submitted"
+ means any form of electronic, verbal, or written communication sent
+ to the Licensor or its representatives, including but not limited to
+ communication on electronic mailing lists, source code control systems,
+ and issue tracking systems that are managed by, or on behalf of, the
+ Licensor for the purpose of discussing and improving the Work, but
+ excluding communication that is conspicuously marked or otherwise
+ designated in writing by the copyright owner as "Not a Contribution."
+
+ "Contributor" shall mean Licensor and any individual or Legal Entity
+ on behalf of whom a Contribution has been received by Licensor and
+ subsequently incorporated within the Work.
+
+ 2. Grant of Copyright License. Subject to the terms and conditions of
+ this License, each Contributor hereby grants to You a perpetual,
+ worldwide, non-exclusive, no-charge, royalty-free, irrevocable
+ copyright license to reproduce, prepare Derivative Works of,
+ publicly display, publicly perform, sublicense, and distribute the
+ Work and such Derivative Works in Source or Object form.
+
+ 3. Grant of Patent License. Subject to the terms and conditions of
+ this License, each Contributor hereby grants to You a perpetual,
+ worldwide, non-exclusive, no-charge, royalty-free, irrevocable
+ (except as stated in this section) patent license to make, have made,
+ use, offer to sell, sell, import, and otherwise transfer the Work,
+ where such license applies only to those patent claims licensable
+ by such Contributor that are necessarily infringed by their
+ Contribution(s) alone or by combination of their Contribution(s)
+ with the Work to which such Contribution(s) was submitted. If You
+ institute patent litigation against any entity (including a
+ cross-claim or counterclaim in a lawsuit) alleging that the Work
+ or a Contribution incorporated within the Work constitutes direct
+ or contributory patent infringement, then any patent licenses
+ granted to You under this License for that Work shall terminate
+ as of the date such litigation is filed.
+
+ 4. Redistribution. You may reproduce and distribute copies of the
+ Work or Derivative Works thereof in any medium, with or without
+ modifications, and in Source or Object form, provided that You
+ meet the following conditions:
+
+ (a) You must give any other recipients of the Work or
+ Derivative Works a copy of this License; and
+
+ (b) You must cause any modified files to carry prominent notices
+ stating that You changed the files; and
+
+ (c) You must retain, in the Source form of any Derivative Works
+ that You distribute, all copyright, patent, trademark, and
+ attribution notices from the Source form of the Work,
+ excluding those notices that do not pertain to any part of
+ the Derivative Works; and
+
+ (d) If the Work includes a "NOTICE" text file as part of its
+ distribution, then any Derivative Works that You distribute must
+ include a readable copy of the attribution notices contained
+ within such NOTICE file, excluding those notices that do not
+ pertain to any part of the Derivative Works, in at least one
+ of the following places: within a NOTICE text file distributed
+ as part of the Derivative Works; within the Source form or
+ documentation, if provided along with the Derivative Works; or,
+ within a display generated by the Derivative Works, if and
+ wherever such third-party notices normally appear. The contents
+ of the NOTICE file are for informational purposes only and
+ do not modify the License. You may add Your own attribution
+ notices within Derivative Works that You distribute, alongside
+ or as an addendum to the NOTICE text from the Work, provided
+ that such additional attribution notices cannot be construed
+ as modifying the License.
+
+ You may add Your own copyright statement to Your modifications and
+ may provide additional or different license terms and conditions
+ for use, reproduction, or distribution of Your modifications, or
+ for any such Derivative Works as a whole, provided Your use,
+ reproduction, and distribution of the Work otherwise complies with
+ the conditions stated in this License.
+
+ 5. Submission of Contributions. Unless You explicitly state otherwise,
+ any Contribution intentionally submitted for inclusion in the Work
+ by You to the Licensor shall be under the terms and conditions of
+ this License, without any additional terms or conditions.
+ Notwithstanding the above, nothing herein shall supersede or modify
+ the terms of any separate license agreement you may have executed
+ with Licensor regarding such Contributions.
+
+ 6. Trademarks. This License does not grant permission to use the trade
+ names, trademarks, service marks, or product names of the Licensor,
+ except as required for reasonable and customary use in describing the
+ origin of the Work and reproducing the content of the NOTICE file.
+
+ 7. Disclaimer of Warranty. Unless required by applicable law or
+ agreed to in writing, Licensor provides the Work (and each
+ Contributor provides its Contributions) on an "AS IS" BASIS,
+ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
+ implied, including, without limitation, any warranties or conditions
+ of TITLE, NON-INFRINGEMENT, MERCHANTABILITY, or FITNESS FOR A
+ PARTICULAR PURPOSE. You are solely responsible for determining the
+ appropriateness of using or redistributing the Work and assume any
+ risks associated with Your exercise of permissions under this License.
+
+ 8. Limitation of Liability. In no event and under no legal theory,
+ whether in tort (including negligence), contract, or otherwise,
+ unless required by applicable law (such as deliberate and grossly
+ negligent acts) or agreed to in writing, shall any Contributor be
+ liable to You for damages, including any direct, indirect, special,
+ incidental, or consequential damages of any character arising as a
+ result of this License or out of the use or inability to use the
+ Work (including but not limited to damages for loss of goodwill,
+ work stoppage, computer failure or malfunction, or any and all
+ other commercial damages or losses), even if such Contributor
+ has been advised of the possibility of such damages.
+
+ 9. Accepting Warranty or Additional Liability. While redistributing
+ the Work or Derivative Works thereof, You may choose to offer,
+ and charge a fee for, acceptance of support, warranty, indemnity,
+ or other liability obligations and/or rights consistent with this
+ License. However, in accepting such obligations, You may act only
+ on Your own behalf and on Your sole responsibility, not on behalf
+ of any other Contributor, and only if You agree to indemnify,
+ defend, and hold each Contributor harmless for any liability
+ incurred by, or claims asserted against, such Contributor by reason
+ of your accepting any such warranty or additional liability.
+
+ END OF TERMS AND CONDITIONS
+
+ APPENDIX: How to apply the Apache License to your work.
+
+ To apply the Apache License to your work, attach the following
+ boilerplate notice, with the fields enclosed by brackets "[]"
+ replaced with your own identifying information. (Don't include
+ the brackets!) The text should be enclosed in the appropriate
+ comment syntax for the file format. We also recommend that a
+ file or class name and description of purpose be included on the
+ same "printed page" as the copyright notice for easier
+ identification within third-party archives.
+
+ Copyright [yyyy] [name of copyright owner]
+
+ Licensed under the Apache License, Version 2.0 (the "License");
+ you may not use this file except in compliance with the License.
+ You may obtain a copy of the License at
+
+ http://www.apache.org/licenses/LICENSE-2.0
+
+ Unless required by applicable law or agreed to in writing, software
+ distributed under the License is distributed on an "AS IS" BASIS,
+ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ See the License for the specific language governing permissions and
+ limitations under the License.
diff --git a/chatterbox-nats/chatterbox-nats-sample-war/src/main/resources/META-INF/NOTICE b/chatterbox-nats/chatterbox-nats-sample-war/src/main/resources/META-INF/NOTICE
new file mode 100644
index 0000000..57a46af
--- /dev/null
+++ b/chatterbox-nats/chatterbox-nats-sample-war/src/main/resources/META-INF/NOTICE
@@ -0,0 +1,7 @@
+Slack Connector :: Sample WAR
+Copyright 2017-2018 The Apache Software Foundation
+
+This product includes software developed at
+The Apache Software Foundation (http://www.apache.org/).
+
+
diff --git a/chatterbox-nats/chatterbox-nats-sample-war/src/main/resources/META-INF/ejb-jar.xml b/chatterbox-nats/chatterbox-nats-sample-war/src/main/resources/META-INF/ejb-jar.xml
new file mode 100644
index 0000000..09cfc43
--- /dev/null
+++ b/chatterbox-nats/chatterbox-nats-sample-war/src/main/resources/META-INF/ejb-jar.xml
@@ -0,0 +1,26 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+ ~ Licensed to the Apache Software Foundation (ASF) under one
+ ~ or more contributor license agreements. See the NOTICE file
+ ~ distributed with this work for additional information
+ ~ regarding copyright ownership. The ASF licenses this file
+ ~ to you under the Apache License, Version 2.0 (the
+ ~ "License"); you may not use this file except in compliance
+ ~ with the License. You may obtain a copy of the License at
+ ~
+ ~ http://www.apache.org/licenses/LICENSE-2.0
+ ~
+ ~ Unless required by applicable law or agreed to in writing,
+ ~ software distributed under the License is distributed on an
+ ~ "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ ~ KIND, either express or implied. See the License for the
+ ~ specific language governing permissions and limitations
+ ~ under the License.
+ -->
+
+<ejb-jar xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+ xmlns="http://java.sun.com/xml/ns/javaee"
+ xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/ejb-jar_3_1.xsd"
+ version="3.1">
+ <display-name>slack-connector-sample-ejb</display-name>
+</ejb-jar>
diff --git a/chatterbox-nats/docker-compose.yml b/chatterbox-nats/docker-compose.yml
new file mode 100644
index 0000000..f1dab81
--- /dev/null
+++ b/chatterbox-nats/docker-compose.yml
@@ -0,0 +1,35 @@
+version: '3.1'
+services:
+ nats-docker:
+ image: nats-streaming:0.17.0
+ restart: always
+ command:
+ - '-p'
+ - '4222'
+ - '-m'
+ - '8222'
+ - '-hbi'
+ - '5s'
+ - '-hbt'
+ - '5s'
+ - '-hbf'
+ - '2'
+ - '-SD'
+ - '-cid'
+ - 'yourclientid'
+ environment:
+ TZ: Europe/London
+ LANG: en_GB.UTF-8
+ LANGUAGE: en_GB:en
+ LC_ALL: en_GB.UTF-8
+ ports:
+ - '4222:4222'
+ - '8222:8222'
+ expose:
+ - 4222
+ - 8222
+ networks:
+ - backend
+networks:
+ backend:
+ driver: bridge
diff --git a/chatterbox-nats/pom.xml b/chatterbox-nats/pom.xml
new file mode 100644
index 0000000..13f4734
--- /dev/null
+++ b/chatterbox-nats/pom.xml
@@ -0,0 +1,229 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+ ~ Licensed to the Apache Software Foundation (ASF) under one
+ ~ or more contributor license agreements. See the NOTICE file
+ ~ distributed with this work for additional information
+ ~ regarding copyright ownership. The ASF licenses this file
+ ~ to you under the Apache License, Version 2.0 (the
+ ~ "License"); you may not use this file except in compliance
+ ~ with the License. You may obtain a copy of the License at
+ ~
+ ~ http://www.apache.org/licenses/LICENSE-2.0
+ ~
+ ~ Unless required by applicable law or agreed to in writing,
+ ~ software distributed under the License is distributed on an
+ ~ "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ ~ KIND, either express or implied. See the License for the
+ ~ specific language governing permissions and limitations
+ ~ under the License.
+ -->
+
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
+
+ <modelVersion>4.0.0</modelVersion>
+
+ <parent>
+ <groupId>org.apache.tomee.chatterbox</groupId>
+ <artifactId>chatterbox-parent</artifactId>
+ <version>0.3-SNAPSHOT</version>
+ </parent>
+
+ <artifactId>chatterbox-nats-parent</artifactId>
+ <packaging>pom</packaging>
+ <version>0.3-SNAPSHOT</version>
+ <name>Chatterbox :: NATS</name>
+
+ <properties>
+ <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+ <version.arquillian>1.1.1.Final</version.arquillian>
+ <version.shrinkwrap.descriptor>2.0.0-alpha-5</version.shrinkwrap.descriptor>
+ <version.shrinkwrap.shrinkwrap>1.0.1</version.shrinkwrap.shrinkwrap>
+ <version.tomee>8.0.1</version.tomee>
+ <version.openejb>8.0.1</version.openejb>
+ <version.crest>0.3</version.crest>
+ <maven.checkstyle.plugin.version>2.16</maven.checkstyle.plugin.version>
+ </properties>
+
+ <repositories>
+ <repository>
+ <id>jitpack.io</id>
+ <url>https://jitpack.io</url>
+ </repository>
+ </repositories>
+
+ <dependencyManagement>
+ <dependencies>
+ <dependency>
+ <groupId>org.tomitribe</groupId>
+ <artifactId>tomitribe-crest</artifactId>
+ <version>${version.crest}</version>
+ </dependency>
+ <dependency>
+ <groupId>org.tomitribe</groupId>
+ <artifactId>tomitribe-crest-api</artifactId>
+ <version>${version.crest}</version>
+ <scope>provided</scope>
+ </dependency>
+ <dependency>
+ <groupId>org.tomitribe</groupId>
+ <artifactId>tomitribe-util</artifactId>
+ <version>1.1.0</version>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.sshd</groupId>
+ <artifactId>sshd-core</artifactId>
+ <version>0.9.0</version>
+ </dependency>
+ <dependency>
+ <groupId>junit</groupId>
+ <artifactId>junit</artifactId>
+ <version>4.11</version>
+ <scope>test</scope>
+ </dependency>
+ <dependency>
+ <groupId>javax</groupId>
+ <artifactId>javaee-api</artifactId>
+ <version>7.0</version>
+ <scope>provided</scope>
+ </dependency>
+ </dependencies>
+ </dependencyManagement>
+ <modules>
+ <module>chatterbox-nats-api</module>
+ <module>chatterbox-nats-impl</module>
+ <module>chatterbox-nats-rar</module>
+ <module>chatterbox-nats-sample-war</module>
+ </modules>
+ <build>
+ <defaultGoal>install</defaultGoal>
+ <pluginManagement>
+ <plugins>
+
+ <plugin>
+ <groupId>org.codehaus.mojo</groupId>
+ <artifactId>build-helper-maven-plugin</artifactId>
+ <version>1.8</version>
+ <executions>
+ <execution>
+ <id>reserve-network-port</id>
+ <phase>process-test-classes</phase>
+ <goals>
+ <goal>reserve-network-port</goal>
+ </goals>
+ <configuration>
+ <portNames>
+ <portName>tomee.http.port</portName>
+ <portName>tomee.shutdown.port</portName>
+ </portNames>
+ </configuration>
+ </execution>
+ </executions>
+ </plugin>
+ <plugin>
+ <groupId>org.apache.maven.plugins</groupId>
+ <artifactId>maven-dependency-plugin</artifactId>
+ <executions>
+ <execution>
+ <id>copy-test-libs</id>
+ <phase>process-test-resources</phase>
+ <configuration>
+ <artifactItems>
+ <artifactItem>
+ <groupId>junit</groupId>
+ <artifactId>junit</artifactId>
+ </artifactItem>
+ </artifactItems>
+ <outputDirectory>
+ ${project.build.directory}/test-libs
+ </outputDirectory>
+ <stripVersion>true</stripVersion>
+ </configuration>
+ <goals>
+ <goal>copy</goal>
+ </goals>
+ </execution>
+ </executions>
+ </plugin>
+
+ </plugins>
+ </pluginManagement>
+ <plugins>
+ <plugin>
+ <groupId>org.apache.maven.plugins</groupId>
+ <artifactId>maven-compiler-plugin</artifactId>
+ <configuration>
+ <optimize>true</optimize>
+ <source>1.8</source>
+ <target>1.8</target>
+ </configuration>
+ </plugin>
+ </plugins>
+ </build>
+
+ <profiles>
+ <profile>
+ <id>tomee-plus-remote</id>
+ <activation>
+ <activeByDefault>true</activeByDefault>
+ </activation>
+ <properties>
+ <tomee.version>${version.tomee}</tomee.version>
+ <tomee.classifier>plus</tomee.classifier>
+ </properties>
+ <build>
+ <pluginManagement>
+ <plugins>
+ <plugin>
+ <groupId>org.apache.maven.plugins</groupId>
+ <artifactId>maven-surefire-plugin</artifactId>
+ <configuration>
+ <systemPropertyVariables>
+ <tomee.classifier>${tomee.classifier}</tomee.classifier>
+ <tomee.version>${tomee.version}</tomee.version>
+ </systemPropertyVariables>
+ </configuration>
+ </plugin>
+ </plugins>
+ </pluginManagement>
+ </build>
+ <dependencyManagement>
+ <dependencies>
+ <dependency>
+ <groupId>org.apache.tomee</groupId>
+ <artifactId>arquillian-tomee-remote</artifactId>
+ <version>${tomee.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>org.jboss.arquillian.junit</groupId>
+ <artifactId>arquillian-junit-container</artifactId>
+ <version>${version.arquillian}</version>
+ <scope>test</scope>
+ </dependency>
+ <dependency>
+ <groupId>org.jboss.arquillian.junit</groupId>
+ <artifactId>arquillian-junit-container</artifactId>
+ <version>${version.arquillian}</version>
+ <scope>test</scope>
+ </dependency>
+ <dependency>
+ <groupId>org.jboss.shrinkwrap.descriptors</groupId>
+ <artifactId>shrinkwrap-descriptors-impl-javaee</artifactId>
+ <version>${version.shrinkwrap.descriptor}</version>
+ </dependency>
+ <dependency>
+ <groupId>org.jboss.shrinkwrap.resolver</groupId>
+ <artifactId>shrinkwrap-resolver-impl-maven</artifactId>
+ <version>2.1.0</version>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.tomee</groupId>
+ <artifactId>apache-tomee</artifactId>
+ <version>${tomee.version}</version>
+ <classifier>${tomee.classifier}</classifier>
+ <type>zip</type>
+ </dependency>
+ </dependencies>
+ </dependencyManagement>
+ </profile>
+ </profiles>
+</project>
diff --git a/pom.xml b/pom.xml
index 2367c4c..3425b57 100644
--- a/pom.xml
+++ b/pom.xml
@@ -78,6 +78,7 @@
<module>chatterbox-twitter</module>
<module>chatterbox-xmpp</module>
<module>chatterbox-slack</module>
+ <module>chatterbox-nats</module>
</modules>
<build>