SRAMP-433 JMS events

ArtificerRepo · Sep 2, 2014 · d7ec4ca · d7ec4ca
1 parent b62d4a0
commit d7ec4ca
Show file tree

Hide file tree

Showing 39 changed files with 1,358 additions and 95 deletions.
diff --git a/.gitignore b/.gitignore
@@ -8,3 +8,4 @@ target
 *.versionsBackup
 *~
 .checkstyle
+activemq-data
diff --git a/pom.xml b/pom.xml
@@ -273,6 +273,16 @@
         <artifactId>s-ramp-distro-shell</artifactId>
         <version>${project.version}</version>
       </dependency>
+      <dependency>
+        <groupId>org.overlord.sramp</groupId>
+        <artifactId>s-ramp-events</artifactId>
+        <version>${project.version}</version>
+      </dependency>
+      <dependency>
+        <groupId>org.overlord.sramp</groupId>
+        <artifactId>s-ramp-events-jms</artifactId>
+        <version>${project.version}</version>
+      </dependency>
       <dependency>
         <groupId>org.overlord.sramp</groupId>
         <artifactId>s-ramp-installer</artifactId>
@@ -437,6 +447,18 @@
         <version>${project.version}</version>
         <classifier>sources</classifier>
       </dependency>
+      <dependency>
+        <groupId>org.overlord.sramp</groupId>
+        <artifactId>s-ramp-events</artifactId>
+        <version>${project.version}</version>
+        <classifier>sources</classifier>
+      </dependency>
+      <dependency>
+        <groupId>org.overlord.sramp</groupId>
+        <artifactId>s-ramp-events-jms</artifactId>
+        <version>${project.version}</version>
+        <classifier>sources</classifier>
+      </dependency>
       <dependency>
         <groupId>org.overlord.sramp</groupId>
         <artifactId>s-ramp-repository</artifactId>
@@ -571,6 +593,12 @@
         <artifactId>overlord-commons-config</artifactId>
         <version>${version.org.overlord.overlord-commons}</version>
       </dependency>
+      <dependency>
+        <groupId>org.overlord</groupId>
+        <artifactId>overlord-commons-dist-eap6</artifactId>
+        <version>${overlord-commons.version}</version>
+        <type>zip</type>
+      </dependency>
       <dependency>
         <groupId>org.overlord</groupId>
         <artifactId>overlord-commons-errai-fuse-support</artifactId>
@@ -940,6 +968,8 @@
     <module>s-ramp-demos</module>
     <module>s-ramp-dev-server</module>
     <module>s-ramp-distro</module>
+    <module>s-ramp-events</module>
+    <module>s-ramp-events-jms</module>
     <module>s-ramp-installer</module>
     <module>s-ramp-integration</module>
     <module>s-ramp-javadoc</module>

diff --git a/s-ramp-api/.gitignore b/s-ramp-api/.gitignore
@@ -6,3 +6,4 @@
 /.settings
 /bin
 /target
+/target
diff --git a/s-ramp-common/src/main/java/org/overlord/sramp/common/SrampConstants.java b/s-ramp-common/src/main/java/org/overlord/sramp/common/SrampConstants.java
@@ -51,15 +51,18 @@ public class SrampConstants {
     public static final QName SRAMP_TOTAL_RESULTS_QNAME   = new QName(SRAMP_NS, SRAMP_TOTAL_RESULTS, SRAMP_PREFIX);
 
     // Configuration constants
-    public static final String SRAMP_CONFIG_FILE_NAME         = "sramp.config.file.name"; //$NON-NLS-1$
-    public static final String SRAMP_CONFIG_FILE_REFRESH      = "sramp.config.file.refresh"; //$NON-NLS-1$
-    public static final String SRAMP_CONFIG_BASEURL           = "sramp.config.baseurl"; //$NON-NLS-1$
-    public static final String SRAMP_CONFIG_AUDITING          = "sramp.config.auditing.enabled"; //$NON-NLS-1$
-    public static final String SRAMP_CONFIG_DERIVED_AUDITING  = "sramp.config.auditing.enabled-derived"; //$NON-NLS-1$
-    public static final String SRAMP_CONFIG_AUDIT_USER        = "sramp.config.auditing.user"; //$NON-NLS-1$
-    public static final String SRAMP_CONFIG_AUDIT_PASS        = "sramp.config.auditing.password"; //$NON-NLS-1$
-    public static final String SRAMP_CONFIG_JCR_REPO_JNDI     = "sramp.config.jcr.repository.jndi-path"; //$NON-NLS-1$
-    public static final String SRAMP_CONFIG_JCR_REPO_NAME     = "sramp.config.jcr.repository.name"; //$NON-NLS-1$
+    public static final String SRAMP_CONFIG_FILE_NAME           = "sramp.config.file.name"; //$NON-NLS-1$
+    public static final String SRAMP_CONFIG_FILE_REFRESH        = "sramp.config.file.refresh"; //$NON-NLS-1$
+    public static final String SRAMP_CONFIG_BASEURL             = "sramp.config.baseurl"; //$NON-NLS-1$
+    public static final String SRAMP_CONFIG_AUDITING            = "sramp.config.auditing.enabled"; //$NON-NLS-1$
+    public static final String SRAMP_CONFIG_DERIVED_AUDITING    = "sramp.config.auditing.enabled-derived"; //$NON-NLS-1$
+    public static final String SRAMP_CONFIG_AUDIT_USER          = "sramp.config.auditing.user"; //$NON-NLS-1$
+    public static final String SRAMP_CONFIG_AUDIT_PASS          = "sramp.config.auditing.password"; //$NON-NLS-1$
+    public static final String SRAMP_CONFIG_JCR_REPO_JNDI       = "sramp.config.jcr.repository.jndi-path"; //$NON-NLS-1$
+    public static final String SRAMP_CONFIG_JCR_REPO_NAME       = "sramp.config.jcr.repository.name"; //$NON-NLS-1$
+    public static final String SRAMP_CONFIG_EVENT_JMS_TOPICS    = "sramp.config.events.jms.topics"; //$NON-NLS-1$
+    public static final String SRAMP_CONFIG_EVENT_JMS_QUEUES    = "sramp.config.events.jms.queues"; //$NON-NLS-1$
+    public static final String SRAMP_CONFIG_EVENT_JMS_PORT      = "sramp.config.events.jms.embedded-activemq-port"; //$NON-NLS-1$
 
     // Location of a directory containing JARs which provide custom derivers
     public static final String SRAMP_CUSTOM_DERIVER_DIR   = "sramp.derivers.customDir"; //$NON-NLS-1$

diff --git a/s-ramp-dev-server/src/main/java/org/overlord/sramp/devsvr/SrampDevServer.java b/s-ramp-dev-server/src/main/java/org/overlord/sramp/devsvr/SrampDevServer.java
@@ -121,6 +121,9 @@ protected void preConfig() {
 
         // Don't do any resource caching!
         System.setProperty("overlord.resource-caching.disabled", "true");
+
+        System.setProperty("sramp.config.events.jms.topics", "sramp/events/topic");
+        System.setProperty("sramp.config.events.jms.embedded-activemq-port", "61616");
     }
 
     /**

diff --git a/s-ramp-distro/assembly/pom.xml b/s-ramp-distro/assembly/pom.xml
@@ -127,6 +127,16 @@
       <artifactId>s-ramp-common</artifactId>
       <classifier>sources</classifier>
     </dependency>
+    <dependency>
+      <groupId>org.overlord.sramp</groupId>
+      <artifactId>s-ramp-events</artifactId>
+      <classifier>sources</classifier>
+    </dependency>
+    <dependency>
+      <groupId>org.overlord.sramp</groupId>
+      <artifactId>s-ramp-events-jms</artifactId>
+      <classifier>sources</classifier>
+    </dependency>
     <dependency>
       <groupId>org.overlord.sramp</groupId>
       <artifactId>s-ramp-repository</artifactId>

diff --git a/s-ramp-events-jms/pom.xml b/s-ramp-events-jms/pom.xml
@@ -0,0 +1,68 @@
+<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/xsd/maven-4.0.0.xsd">
+  <modelVersion>4.0.0</modelVersion>
+  <parent>
+    <groupId>org.overlord.sramp</groupId>
+    <artifactId>s-ramp</artifactId>
+    <version>0.6.0-SNAPSHOT</version>
+    <relativePath>../pom.xml</relativePath>
+  </parent>
+
+  <artifactId>s-ramp-events-jms</artifactId>
+  <packaging>bundle</packaging>
+  <name>S-RAMP Events: JMS</name>
+  <description>JMS implementation of the S-RAMP Events functionality.</description>
+
+  <dependencyManagement>
+    <dependencies>
+      <dependency>
+        <groupId>org.apache.activemq</groupId>
+        <artifactId>activemq-kahadb-store</artifactId>
+        <version>${version.org.apache.activemq}</version>
+      </dependency>
+    </dependencies>
+  </dependencyManagement>
+
+  <dependencies>
+    <dependency>
+      <groupId>org.overlord.sramp</groupId>
+      <artifactId>s-ramp-common</artifactId>
+    </dependency>
+    <dependency>
+      <groupId>org.overlord.sramp</groupId>
+      <artifactId>s-ramp-events</artifactId>
+    </dependency>
+    <dependency>
+      <groupId>javax.jms</groupId>
+      <artifactId>jms</artifactId>
+    </dependency>
+    <dependency>
+      <groupId>org.codehaus.jackson</groupId>
+      <artifactId>jackson-core-asl</artifactId>
+      <scope>provided</scope>
+    </dependency>
+    <dependency>
+      <groupId>org.codehaus.jackson</groupId>
+      <artifactId>jackson-mapper-asl</artifactId>
+      <scope>provided</scope>
+    </dependency>
+    <dependency>
+      <groupId>org.apache.activemq</groupId>
+      <artifactId>activemq-broker</artifactId>
+    </dependency>
+    <dependency>
+      <groupId>org.apache.activemq</groupId>
+      <artifactId>activemq-kahadb-store</artifactId>
+    </dependency>
+  </dependencies>
+
+  <build>
+    <plugins>
+      <plugin>
+        <groupId>org.apache.felix</groupId>
+        <artifactId>maven-bundle-plugin</artifactId>
+        <extensions>true</extensions>
+      </plugin>
+    </plugins>
+  </build>
+
+</project>