Implement ActiveMQ Artemis Connector

Related issue ballerina-platform#13814
sameerajayasoma · Mar 20, 2019 · 0ab2efe · 0ab2efe
1 parent 6fc2c81
commit 0ab2efe
Show file tree

Hide file tree

Showing 62 changed files with 4,026 additions and 10 deletions.
diff --git a/distribution/zip/ballerina-tools/pom.xml b/distribution/zip/ballerina-tools/pom.xml
@@ -116,6 +116,12 @@
             <type>zip</type>
             <classifier>ballerina-sources</classifier>
         </dependency>
+        <dependency>
+            <groupId>org.ballerinalang</groupId>
+            <artifactId>ballerina-activemq-artemis</artifactId>
+            <type>zip</type>
+            <classifier>ballerina-sources</classifier>
+        </dependency>
         <dependency>
             <groupId>org.ballerinalang</groupId>
             <artifactId>ballerina-log-api</artifactId>

diff --git a/distribution/zip/ballerina/build.gradle b/distribution/zip/ballerina/build.gradle
@@ -80,6 +80,15 @@ dependencies {
     dist 'com.google.protobuf:protobuf-java:3.5.1'
     dist 'org.wso2.orbit.org.yaml:snakeyaml:1.16.0.wso2v1'
     dist 'org.wso2.staxon:staxon-core:1.2.0.wso2v2'
+    dist 'com.jcraft:jzlib:1.1.3'
+    dist 'org.apache.activemq:artemis-core-client:2.6.3'
+    dist 'org.apache.activemq:artemis-commons:2.6.3'
+    dist 'commons-beanutils:commons-beanutils:1.9.3'
+    dist 'org.jboss.logging:jboss-logging:3.3.1.Final'
+    dist 'commons-collections:commons-collections:3.2.2'
+    dist 'org.apache.geronimo.specs:geronimo-json_1.0_spec:1.0-alpha-1'
+    dist 'io.netty:netty-transport-native-epoll:4.1.34.Final'
+    dist 'io.netty:netty-transport-native-kqueue:4.1.34.Final'
 
 
     distBal project(path: ':ballerina-auth', configuration: 'baloImplementation')
@@ -110,6 +119,7 @@ dependencies {
     distBal project(path: ':ballerina-time', configuration: 'baloImplementation')
     distBal project(path: ':ballerina-transactions', configuration: 'baloImplementation')
     distBal project(path: ':ballerina-websub', configuration: 'baloImplementation')
+    distBal project(path: ':ballerina-activemq-artemis', configuration: 'baloImplementation')
 
     balSource project(path: ':ballerina-auth', configuration: 'balSource')
     balSource project(path: ':ballerina-builtin', configuration: 'balSource')
@@ -139,6 +149,7 @@ dependencies {
     balSource project(path: ':ballerina-time', configuration: 'balSource')
     balSource project(path: ':ballerina-transactions', configuration: 'balSource')
     balSource project(path: ':ballerina-websub', configuration: 'balSource')
+    balSource project(path: ':ballerina-activemq-artemis', configuration: 'balSource')
 
     dist project(':ballerina-auth')
     dist project(':ballerina-builtin')
@@ -181,6 +192,7 @@ dependencies {
     dist project(':strip-bouncycastle')
     dist project(':toml-parser')
     dist project(':tracing-extensions:ballerina-jaeger-extension')
+    dist project(':ballerina-activemq-artemis')
 
 }
 

diff --git a/distribution/zip/ballerina/pom.xml b/distribution/zip/ballerina/pom.xml
@@ -102,6 +102,10 @@
             <groupId>org.ballerinalang</groupId>
             <artifactId>ballerina-jms</artifactId>
         </dependency>
+        <dependency>
+            <groupId>org.ballerinalang</groupId>
+            <artifactId>ballerina-activemq-artemis</artifactId>
+        </dependency>
         <dependency>
             <groupId>org.ballerinalang</groupId>
             <artifactId>ballerina-log-api</artifactId>
@@ -162,6 +166,42 @@
             <groupId>org.ballerinalang</groupId>
             <artifactId>ballerina-privacy</artifactId>
         </dependency>
+        <dependency>
+            <groupId>com.jcraft</groupId>
+            <artifactId>jzlib</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.activemq</groupId>
+            <artifactId>artemis-core-client</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.activemq</groupId>
+            <artifactId>artemis-commons</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>commons-beanutils</groupId>
+            <artifactId>commons-beanutils</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.jboss.logging</groupId>
+            <artifactId>jboss-logging</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>commons-collections</groupId>
+            <artifactId>commons-collections</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.geronimo.specs</groupId>
+            <artifactId>geronimo-json_1.0_spec</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>io.netty</groupId>
+            <artifactId>netty-transport-native-epoll</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>io.netty</groupId>
+            <artifactId>netty-transport-native-kqueue</artifactId>
+        </dependency>
         <!-- end of stdlib jar dependencies -->
 
         <dependency>
@@ -245,10 +285,6 @@
             <groupId>com.h2database</groupId>
             <artifactId>h2</artifactId>
         </dependency>
-        <dependency>
-            <groupId>com.jcraft</groupId>
-            <artifactId>jzlib</artifactId>
-        </dependency>
 
         <!-- Siddhi Stream Dependencies -->
         <dependency>
@@ -403,6 +439,12 @@
             <type>zip</type>
             <classifier>ballerina-binary-repo</classifier>
         </dependency>
+        <dependency>
+            <groupId>org.ballerinalang</groupId>
+            <artifactId>ballerina-activemq-artemis</artifactId>
+            <type>zip</type>
+            <classifier>ballerina-binary-repo</classifier>
+        </dependency>
         <dependency>
             <groupId>org.ballerinalang</groupId>
             <artifactId>ballerina-jms</artifactId>
@@ -598,6 +640,12 @@
             <type>zip</type>
             <classifier>ballerina-sources</classifier>
         </dependency>
+        <dependency>
+            <groupId>org.ballerinalang</groupId>
+            <artifactId>ballerina-activemq-artemis</artifactId>
+            <type>zip</type>
+            <classifier>ballerina-sources</classifier>
+        </dependency>
         <dependency>
             <groupId>org.ballerinalang</groupId>
             <artifactId>ballerina-log-api</artifactId>
@@ -764,6 +812,7 @@
                                 ballerina-socket,
                                 ballerina-internal,
                                 ballerina-jms,
+                                ballerina-activemq-artemis,
                                 ballerina-log-api,
                                 ballerina-math,
                                 ballerina-mime,

diff --git a/distribution/zip/ballerina/src/assembly/bin.xml b/distribution/zip/ballerina/src/assembly/bin.xml
@@ -112,6 +112,7 @@
                 <include>org.ballerinalang:ballerina-io:jar</include>
                 <include>org.ballerinalang:ballerina-socket:jar</include>
                 <include>org.ballerinalang:ballerina-jms:jar</include>
+                <include>org.ballerinalang:ballerina-activemq-artemis:jar</include>
                 <include>org.ballerinalang:ballerina-log-api:jar</include>
                 <include>org.ballerinalang:ballerina-math:jar</include>
                 <include>org.ballerinalang:ballerina-mime:jar</include>
@@ -185,6 +186,17 @@
                 <include>io.netty:netty-tcnative-boringssl-static</include>
                 <include>com.jcraft:jzlib</include>
 
+                <!-- Artemis connector dependencies -->
+                <include>org.apache.activemq:artemis-core-client</include>
+                <include>org.apache.activemq:artemis-commons</include>
+                <include>commons-beanutils:commons-beanutils</include>
+                <include>org.apache.activemq:artemis-commons</include>
+                <include>org.jboss.logging:jboss-logging</include>
+                <include>commons-collections:commons-collections</include>
+                <include>org.apache.geronimo.specs:geronimo-json_1.0_spec</include>
+                <include>io.netty:netty-transport-native-epoll</include>
+                <include>io.netty:netty-transport-native-kqueue</include>
+
                 <!-- Observability Dependencies -->
                 <include>org.ballerinalang:ballerina-jaeger-extension:jar</include>
                 <include>io.opentracing:opentracing-api</include>

diff --git a/language-server/modules/langserver-compiler/build.gradle b/language-server/modules/langserver-compiler/build.gradle
@@ -20,6 +20,7 @@ dependencies {
     implementation project(':ballerina-websub')
     implementation project(':ballerina-jms')
     implementation project(':ballerina-grpc')
+    implementation project(':ballerina-activemq-artemis')
     testCompile 'org.testng:testng:6.13.1'
 }
 

diff --git a/language-server/modules/langserver-compiler/pom.xml b/language-server/modules/langserver-compiler/pom.xml
@@ -94,6 +94,12 @@
             <type>zip</type>
             <classifier>ballerina-binary-repo</classifier>
         </dependency>
+        <dependency>
+            <groupId>org.ballerinalang</groupId>
+            <artifactId>ballerina-activemq-artemis</artifactId>
+            <type>zip</type>
+            <classifier>ballerina-binary-repo</classifier>
+        </dependency>
         <dependency>
             <groupId>org.ballerinalang</groupId>
             <artifactId>ballerina-grpc</artifactId>

diff --git a/language-server/modules/langserver-core/build.gradle b/language-server/modules/langserver-core/build.gradle
@@ -31,6 +31,7 @@ dependencies {
     implementation project(':ballerina-jms')
     implementation project(':ballerina-grpc')
     implementation project(':testerina:testerina-core')
+    implementation project(':ballerina-activemq-artemis')
     implementation 'com.fasterxml.jackson.core:jackson-databind:2.9.1'
     implementation 'com.fasterxml.jackson.dataformat:jackson-dataformat-yaml:2.9.1'
     implementation 'io.netty:netty-buffer:4.1.19.Final'

diff --git a/language-server/modules/langserver-core/pom.xml b/language-server/modules/langserver-core/pom.xml
@@ -102,6 +102,12 @@
             <type>zip</type>
             <classifier>ballerina-binary-repo</classifier>
         </dependency>
+        <dependency>
+            <groupId>org.ballerinalang</groupId>
+            <artifactId>ballerina-activemq-artemis</artifactId>
+            <type>zip</type>
+            <classifier>ballerina-binary-repo</classifier>
+        </dependency>
         <dependency>
             <groupId>org.ballerinalang</groupId>
             <artifactId>ballerina-grpc</artifactId>

diff --git a/pom.xml b/pom.xml
@@ -557,6 +557,27 @@
                 <classifier>ballerina-binary-repo</classifier>
             </dependency>
 
+            <!--ballerina-activemq-artemis-->
+            <dependency>
+                <groupId>org.ballerinalang</groupId>
+                <artifactId>ballerina-activemq-artemis</artifactId>
+                <version>${ballerina.version}</version>
+            </dependency>
+            <dependency>
+                <groupId>org.ballerinalang</groupId>
+                <artifactId>ballerina-activemq-artemis</artifactId>
+                <version>${ballerina.version}</version>
+                <type>zip</type>
+                <classifier>ballerina-sources</classifier>
+            </dependency>
+            <dependency>
+                <groupId>org.ballerinalang</groupId>
+                <artifactId>ballerina-activemq-artemis</artifactId>
+                <version>${ballerina.version}</version>
+                <type>zip</type>
+                <classifier>ballerina-binary-repo</classifier>
+            </dependency>
+
             <!-- ballerina-log-api -->
             <dependency>
                 <groupId>org.ballerinalang</groupId>
@@ -1603,6 +1624,48 @@
                 <artifactId>asm</artifactId>
                 <version>${asm.version}</version>
             </dependency>
+
+            <!--Artemis dependencies -->
+            <dependency>
+                <groupId>org.apache.activemq</groupId>
+                <artifactId>artemis-core-client</artifactId>
+                <version>${artemis.version}</version>
+            </dependency>
+            <dependency>
+                <groupId>org.apache.activemq</groupId>
+                <artifactId>artemis-commons</artifactId>
+                <version>${artemis.version}</version>
+            </dependency>
+            <dependency>
+                <groupId>commons-beanutils</groupId>
+                <artifactId>commons-beanutils</artifactId>
+                <version>${beanutils.version}</version>
+            </dependency>
+            <dependency>
+                <groupId>org.jboss.logging</groupId>
+                <artifactId>jboss-logging</artifactId>
+                <version>${jboss.version}</version>
+            </dependency>
+            <dependency>
+                <groupId>commons-collections</groupId>
+                <artifactId>commons-collections</artifactId>
+                <version>${commons-collections.version}</version>
+            </dependency>
+            <dependency>
+                <groupId>org.apache.geronimo.specs</groupId>
+                <artifactId>geronimo-json_1.0_spec</artifactId>
+                <version>${geronimo-json.version}</version>
+            </dependency>
+            <dependency>
+                <groupId>io.netty</groupId>
+                <artifactId>netty-transport-native-epoll</artifactId>
+                <version>${netty.version}</version>
+            </dependency>
+            <dependency>
+                <groupId>io.netty</groupId>
+                <artifactId>netty-transport-native-kqueue</artifactId>
+                <version>${netty.version}</version>
+            </dependency>
         </dependencies>
     </dependencyManagement>
 
@@ -1725,6 +1788,7 @@
                 <module>stdlib/database/sql</module>
                 <module>stdlib/streams</module>
                 <module>stdlib/privacy</module>
+                <module>stdlib/messaging/activemq-artemis</module>
 
                 <module>misc/lib-creator</module>
 
@@ -1815,6 +1879,7 @@
                 <module>stdlib/database/sql</module>
                 <module>stdlib/streams</module>
                 <module>stdlib/privacy</module>
+                <module>stdlib/messaging/activemq-artemis</module>
 
                 <module>misc/lib-creator</module>
 
@@ -1902,6 +1967,7 @@
                 <module>stdlib/database/sql</module>
                 <module>stdlib/streams</module>
                 <module>stdlib/privacy</module>
+                <module>stdlib/messaging/activemq-artemis</module>
 
                 <module>misc/lib-creator</module>
 
@@ -2402,6 +2468,13 @@
         <andes.client.version>3.2.87</andes.client.version>
         <wso2.securevault.version>1.0.0-wso2v2</wso2.securevault.version>
 
+        <!-- Artemis connector -->
+        <artemis.version>2.6.3</artemis.version>
+        <beanutils.version>1.9.3</beanutils.version>
+        <jboss.version>3.3.1.Final</jboss.version>
+        <commons-collections.version>3.2.2</commons-collections.version>
+        <geronimo-json.version>1.0-alpha-1</geronimo-json.version>
+
         <file.transport.version>6.0.55</file.transport.version>
         <chewiebug.gcviewer.version>1.35</chewiebug.gcviewer.version>
 

diff --git a/settings.gradle b/settings.gradle
@@ -87,6 +87,7 @@ include(':ballerina-tools-integration-test')
 include(':examples-test')
 include(':plugin-vscode')
 include(':benchmarks')
+include(':ballerina-activemq-artemis')
 include(':build-config:checkstyle')
 project(':ballerina-lang').projectDir = file('compiler/ballerina-lang')
 project(':ballerina-utils').projectDir = file('stdlib/utils')
@@ -172,6 +173,7 @@ project(':ballerina-integration-test').projectDir = file('tests/ballerina-integr
 project(':ballerina-tools-integration-test').projectDir = file('tests/ballerina-tools-integration-test')
 project(':examples-test').projectDir = file('tests/ballerina-examples-test')
 project(':plugin-vscode').projectDir = file('tool-plugins/vscode')
+project(':ballerina-activemq-artemis').projectDir = file('stdlib/messaging/activemq-artemis')
 
 buildCache {
     remote(HttpBuildCache) {

diff --git a/stdlib/messaging/activemq-artemis/assembly/balo.xml b/stdlib/messaging/activemq-artemis/assembly/balo.xml
@@ -0,0 +1,35 @@
+<!--
+  ~ /*
+  ~ * Copyright (c) 2019, WSO2 Inc. (http://www.wso2.org) All Rights Reserved.
+  ~ *
+  ~ * 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.
+  ~ */
+  -->
+<assembly>
+    <includeBaseDirectory>true</includeBaseDirectory>
+    <baseDirectory>/</baseDirectory>
+    <id>ballerina-binary-repo</id>
+    <formats>
+        <format>zip</format>
+    </formats>
+
+    <fileSets>
+        <fileSet>
+            <directory>${project.build.directory}/generated-balo</directory>
+            <outputDirectory>/</outputDirectory>
+            <includes>
+                <include>**</include>
+            </includes>
+        </fileSet>
+    </fileSets>
+</assembly>