From fc506da61f90d4dd44bf6aa7433c73ec6142590d Mon Sep 17 00:00:00 2001
From: Mathieu Baudier <mbaudier@argeo.org>
Date: Sat, 10 Jan 2009 18:41:34 +0000
Subject: [PATCH] Integrate ActiveMQ on the server side

git-svn-id: https://svn.argeo.org/slc/trunk@2072 4cfe0d0a-d680-48aa-b62c-e0a02a3f76cc
---
 .../src/main/webapp/WEB-INF/activemq.xml      | 159 ++++++++++++++++++
 .../webapp/WEB-INF/applicationContext.xml     |  15 +-
 .../webapp/WEB-INF/classes/log4j.properties   |   3 +
 .../src/main/webapp/WEB-INF/web.xml           |  75 +++++++++
 .../src/main/webapp/index.jsp                 |   2 +-
 .../src/main/webapp/test-amq/send.html        |   7 +
 .../src/main/webapp/test-amq/send.js          |   3 +
 org.argeo.slc/pom.xml                         |  39 +++--
 runtime/org.argeo.slc.server/pom.xml          |  31 +++-
 9 files changed, 307 insertions(+), 27 deletions(-)
 create mode 100644 org.argeo.slc.webapp/src/main/webapp/WEB-INF/activemq.xml
 create mode 100644 org.argeo.slc.webapp/src/main/webapp/test-amq/send.html
 create mode 100644 org.argeo.slc.webapp/src/main/webapp/test-amq/send.js

diff --git a/org.argeo.slc.webapp/src/main/webapp/WEB-INF/activemq.xml b/org.argeo.slc.webapp/src/main/webapp/WEB-INF/activemq.xml
new file mode 100644
index 000000000..71744743e
--- /dev/null
+++ b/org.argeo.slc.webapp/src/main/webapp/WEB-INF/activemq.xml
@@ -0,0 +1,159 @@
+<beans
+  xmlns="http://www.springframework.org/schema/beans"
+  xmlns:amq="http://activemq.apache.org/schema/core"
+  xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+  xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd
+  http://activemq.apache.org/schema/core http://activemq.apache.org/schema/core/activemq-core-5.2.0.xsd">
+
+    <!-- Allows us to use system properties as variables in this configuration file
+
+    <bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
+         <property name="locations">
+            <value>file:${activemq.base}/conf/credentials.properties</value>
+         </property>      
+    </bean>
+-->
+    <broker xmlns="http://activemq.apache.org/schema/core" brokerName="localhost" dataDirectory="${activemq.base}/data">
+
+        <!-- Destination specific policies using destination names or wildcards
+-->
+        <destinationPolicy>
+            <policyMap>
+                <policyEntries>
+                    <policyEntry queue=">" memoryLimit="5mb"/>
+                    <policyEntry topic=">" memoryLimit="5mb">
+                      <!-- you can add other policies too such as these
+                        <dispatchPolicy>
+                            <strictOrderDispatchPolicy/>
+                        </dispatchPolicy>
+                        <subscriptionRecoveryPolicy>
+                            <lastImageSubscriptionRecoveryPolicy/>
+                        </subscriptionRecoveryPolicy>
+                      -->
+                    </policyEntry>
+                </policyEntries>
+            </policyMap>
+        </destinationPolicy>
+
+        <!-- Use the following to configure how ActiveMQ is exposed in JMX -->
+        <managementContext>
+            <managementContext createConnector="false"/>
+        </managementContext>
+
+        <!-- The store and forward broker networks ActiveMQ will listen to -->
+        <networkConnectors>
+            <!-- by default just auto discover the other brokers -->
+            <networkConnector name="default-nc" uri="multicast://default"/>
+            <!-- Example of a static configuration:
+            <networkConnector name="host1 and host2" uri="static://(tcp://host1:61616,tcp://host2:61616)"/>
+            -->
+        </networkConnectors>
+
+        <persistenceAdapter>
+            <amqPersistenceAdapter syncOnWrite="false" directory="${activemq.base}/data" maxFileLength="20 mb"/>
+        </persistenceAdapter>
+
+        <!-- Use the following if you wish to configure the journal with JDBC
+-->
+        <!--
+        <persistenceAdapter>
+            <journaledJDBC dataDirectory="${activemq.base}/data" dataSource="#postgres-ds"/>
+        </persistenceAdapter>
+        -->
+
+        <!-- Or if you want to use pure JDBC without a journal -->
+        <!--
+        <persistenceAdapter>
+            <jdbcPersistenceAdapter dataSource="#postgres-ds"/>
+        </persistenceAdapter>
+        -->
+
+<!-- 
+        <sslContext>
+            <sslContext keyStore="file:${activemq.base}/conf/broker.ks" keyStorePassword="password" trustStore="file:${activemq.base}/conf/broker.ts" trustStorePassword="password"/>
+        </sslContext>
+    -->     
+        <!--  The maximum about of space the broker will use before slowing down producers
+-->
+        <systemUsage>
+            <systemUsage>
+                <memoryUsage>
+                    <memoryUsage limit="20 mb"/>
+                </memoryUsage>
+                <storeUsage>
+                    <storeUsage limit="1 gb" name="foo"/>
+                </storeUsage>
+                <tempUsage>
+                    <tempUsage limit="100 mb"/>
+                </tempUsage>
+            </systemUsage>
+        </systemUsage>
+
+
+        <!-- The transport connectors ActiveMQ will listen to -->
+        <transportConnectors>
+            <transportConnector name="openwire" uri="tcp://localhost:61616" discoveryUri="multicast://default"/>
+<!--             <transportConnector name="ssl" uri="ssl://localhost:61617"/>
+            <transportConnector name="stomp" uri="stomp://localhost:61613"/>
+            <transportConnector name="xmpp" uri="xmpp://localhost:61222"/> -->
+        </transportConnectors>
+
+    </broker>
+
+
+    <!-- Uncomment to create a command agent to respond to message based admin commands on the ActiveMQ.Agent topic
+-->
+    <!--
+    <commandAgent xmlns="http://activemq.apache.org/schema/core" brokerUrl="vm://localhost" username="${activemq.username}" password="${activemq.password}"/>
+    -->
+
+    <!--  This xbean configuration file supports all the standard spring xml configuration options
+-->
+
+    <!-- Postgres DataSource Sample Setup -->
+    <!--
+    <bean id="postgres-ds" class="org.postgresql.ds.PGPoolingDataSource">
+      <property name="serverName" value="localhost"/>
+      <property name="databaseName" value="activemq"/>
+      <property name="portNumber" value="0"/>
+      <property name="user" value="activemq"/>
+      <property name="password" value="activemq"/>
+      <property name="dataSourceName" value="postgres"/>
+      <property name="initialConnections" value="1"/>
+      <property name="maxConnections" value="10"/>
+    </bean>
+    -->
+
+    <!-- MySql DataSource Sample Setup -->
+    <!--
+    <bean id="mysql-ds" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">
+      <property name="driverClassName" value="com.mysql.jdbc.Driver"/>
+      <property name="url" value="jdbc:mysql://localhost/activemq?relaxAutoCommit=true"/>
+      <property name="username" value="activemq"/>
+      <property name="password" value="activemq"/>
+      <property name="maxActive" value="200"/>
+      <property name="poolPreparedStatements" value="true"/>
+    </bean>
+    -->
+
+    <!-- Oracle DataSource Sample Setup -->
+    <!--
+    <bean id="oracle-ds" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">
+      <property name="driverClassName" value="oracle.jdbc.driver.OracleDriver"/>
+      <property name="url" value="jdbc:oracle:thin:@localhost:1521:AMQDB"/>
+      <property name="username" value="scott"/>
+      <property name="password" value="tiger"/>
+      <property name="maxActive" value="200"/>
+      <property name="poolPreparedStatements" value="true"/>
+    </bean>
+    -->
+
+    <!-- Embedded Derby DataSource Sample Setup -->
+    <!--
+    <bean id="derby-ds" class="org.apache.derby.jdbc.EmbeddedDataSource">
+      <property name="databaseName" value="derbydb"/>
+      <property name="createDatabase" value="create"/>
+    </bean>
+    -->
+
+</beans>
\ No newline at end of file
diff --git a/org.argeo.slc.webapp/src/main/webapp/WEB-INF/applicationContext.xml b/org.argeo.slc.webapp/src/main/webapp/WEB-INF/applicationContext.xml
index 080a075fc..131fb21b0 100644
--- a/org.argeo.slc.webapp/src/main/webapp/WEB-INF/applicationContext.xml
+++ b/org.argeo.slc.webapp/src/main/webapp/WEB-INF/applicationContext.xml
@@ -1,15 +1,20 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <beans xmlns="http://www.springframework.org/schema/beans"
-	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
-	xmlns:aop="http://www.springframework.org/schema/aop"
+	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:aop="http://www.springframework.org/schema/aop"
 	xmlns:tx="http://www.springframework.org/schema/tx"
 	xsi:schemaLocation="
        http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd
        http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-2.5.xsd
        http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-2.5.xsd">
-	<import
-		resource="classpath:/org/argeo/slc/server/spring/servletContext.xml" />
+	<import resource="classpath:/org/argeo/slc/server/spring/servletContext.xml" />
 
-	<!-- <import resource="classpath:/org/argeo/slc/server/spring/jmx.xml" />-->
+	<!--
+		<import resource="classpath:/org/argeo/slc/server/spring/jmx.xml" />
+	-->
+
+	<bean id="activemqBroker" class="org.apache.activemq.xbean.BrokerFactoryBean">
+		<property name="config" value="WEB-INF/activemq.xml" />
+		<property name="start" value="true" />
+	</bean>
 
 </beans>
\ No newline at end of file
diff --git a/org.argeo.slc.webapp/src/main/webapp/WEB-INF/classes/log4j.properties b/org.argeo.slc.webapp/src/main/webapp/WEB-INF/classes/log4j.properties
index 93d424ffd..e80a39052 100644
--- a/org.argeo.slc.webapp/src/main/webapp/WEB-INF/classes/log4j.properties
+++ b/org.argeo.slc.webapp/src/main/webapp/WEB-INF/classes/log4j.properties
@@ -19,6 +19,9 @@ log4j.logger.org.hibernate.transaction=WARN
 #log4j.logger.org.hibernate.tool.hbm2ddl=TRACE
 #log4j.logger.org.hibernate.type=TRACE
 
+# Active MQ
+log4j.logger.org.apache.activemq.web.MessageListenerServlet=DEBUG
+
 # EhCache
 log4j.logger.net.sf.ehcache=WARN
 
diff --git a/org.argeo.slc.webapp/src/main/webapp/WEB-INF/web.xml b/org.argeo.slc.webapp/src/main/webapp/WEB-INF/web.xml
index 55a573449..d7105cf49 100644
--- a/org.argeo.slc.webapp/src/main/webapp/WEB-INF/web.xml
+++ b/org.argeo.slc.webapp/src/main/webapp/WEB-INF/web.xml
@@ -116,4 +116,79 @@
 		<param-value>5000</param-value>
 	</context-param>
 
+
+	<!-- Active MQ -->
+	    <!-- context config -->
+    <context-param>
+        <param-name>org.apache.activemq.brokerURL</param-name>
+        <param-value>vm://localhost</param-value>
+    </context-param>
+
+    <context-param>
+        <param-name>org.apache.activemq.embeddedBroker</param-name>
+        <param-value>false</param-value>
+    </context-param>
+
+    <!-- servlet mappings -->
+    
+    <!-- the subscription REST servlet -->
+    <servlet>
+        <servlet-name>AjaxServlet</servlet-name>
+        <servlet-class>org.apache.activemq.web.AjaxServlet</servlet-class>
+        <load-on-startup>1</load-on-startup>
+    </servlet>
+
+    <servlet>
+        <servlet-name>MessageServlet</servlet-name>
+        <servlet-class>org.apache.activemq.web.MessageServlet</servlet-class>
+        <load-on-startup>1</load-on-startup>
+        <!--
+        Uncomment this parameter if you plan to use multiple consumers over REST
+        <init-param>
+                <param-name>destinationOptions</param-name>
+                <param-value>consumer.prefetchSize=1</param-value>
+        </init-param> 
+        -->
+
+    </servlet>
+
+    <!-- the queue browse servlet -->
+    <servlet>
+        <servlet-name>QueueBrowseServlet</servlet-name>
+        <servlet-class>org.apache.activemq.web.QueueBrowseServlet</servlet-class>
+    </servlet>
+
+    <servlet-mapping>
+        <servlet-name>AjaxServlet</servlet-name>
+        <url-pattern>/amq/*</url-pattern>
+    </servlet-mapping>
+    
+    <servlet-mapping>
+        <servlet-name>MessageServlet</servlet-name>
+        <url-pattern>/amqMessage/*</url-pattern>
+    </servlet-mapping>
+    
+    <servlet-mapping>
+        <servlet-name>QueueBrowseServlet</servlet-name>
+        <url-pattern>/amqQueueBrowse/*</url-pattern>
+    </servlet-mapping>
+
+    <filter>
+      <filter-name>session</filter-name>
+      <filter-class>org.apache.activemq.web.SessionFilter</filter-class>
+    </filter>
+    
+    <filter-mapping>
+      <filter-name>session</filter-name>
+      <url-pattern>/amq/*</url-pattern>
+    </filter-mapping>
+    <filter-mapping>
+      <filter-name>session</filter-name>
+      <url-pattern>/amqMessage/*</url-pattern>
+    </filter-mapping>
+    <filter-mapping>
+      <filter-name>session</filter-name>
+      <url-pattern>/amqQueueBrowse/*</url-pattern>
+    </filter-mapping>
+	
 </web-app>
diff --git a/org.argeo.slc.webapp/src/main/webapp/index.jsp b/org.argeo.slc.webapp/src/main/webapp/index.jsp
index 9cdd98efc..1c9726909 100644
--- a/org.argeo.slc.webapp/src/main/webapp/index.jsp
+++ b/org.argeo.slc.webapp/src/main/webapp/index.jsp
@@ -1,5 +1,5 @@
 <?xml version="1.0" encoding="ISO-8859-1" ?>
 <%@ page language="java" contentType="text/html"%>
 <%
-response.sendRedirect("build/index.html");
+response.sendRedirect("argeo-ria/index.html");
 %>
diff --git a/org.argeo.slc.webapp/src/main/webapp/test-amq/send.html b/org.argeo.slc.webapp/src/main/webapp/test-amq/send.html
new file mode 100644
index 000000000..4449fcbc5
--- /dev/null
+++ b/org.argeo.slc.webapp/src/main/webapp/test-amq/send.html
@@ -0,0 +1,7 @@
+<html>
+<head>
+<script type="text/javascript" src="../amq/amq.js"></script>
+<script type="text/javascript">amq.uri='../amq';</script>
+<script type="text/javascript" src="send.js"></script>
+</head>
+</html>
\ No newline at end of file
diff --git a/org.argeo.slc.webapp/src/main/webapp/test-amq/send.js b/org.argeo.slc.webapp/src/main/webapp/test-amq/send.js
new file mode 100644
index 000000000..f40d3c49b
--- /dev/null
+++ b/org.argeo.slc.webapp/src/main/webapp/test-amq/send.js
@@ -0,0 +1,3 @@
+amq.sendMessage('TEST.QUEUE','<test>My Test</test>');
+alert('Message sent!');
+document.write('Message sent');
\ No newline at end of file
diff --git a/org.argeo.slc/pom.xml b/org.argeo.slc/pom.xml
index 974e55238..0ef2bd723 100644
--- a/org.argeo.slc/pom.xml
+++ b/org.argeo.slc/pom.xml
@@ -159,37 +159,27 @@ limitations under the License.
 							<version>1.3.0</version>
 						</dependency>
 
-						<!-- Required by ActiveMQ admin
-						<dependency>
+						<!--
+							Required by ActiveMQ admin <dependency>
 							<groupId>org.springframework</groupId>
 							<artifactId>org.springframework.web</artifactId>
-							<version>${version.spring}</version>
-						</dependency>
-						<dependency>
+							<version>${version.spring}</version> </dependency> <dependency>
 							<groupId>org.springframework</groupId>
 							<artifactId>org.springframework.web.servlet</artifactId>
-							<version>${version.spring}</version>
-						</dependency>
-						<dependency>
+							<version>${version.spring}</version> </dependency> <dependency>
 							<groupId>org.apache.activemq</groupId>
 							<artifactId>com.springsource.org.apache.activemq.web</artifactId>
-							<version>${version.activemq}</version>
-						</dependency>
-						<dependency>
+							<version>${version.activemq}</version> </dependency> <dependency>
 							<groupId>javax.jms</groupId>
 							<artifactId>com.springsource.javax.jms</artifactId>
-							<version>1.1.0</version>
-						</dependency>
-						<dependency>
+							<version>1.1.0</version> </dependency> <dependency>
 							<groupId>org.apache.geronimo.specs</groupId>
 							<artifactId>com.springsource.javax.management.j2ee</artifactId>
-							<version>1.0.1</version>
-						</dependency>
-						<dependency>
+							<version>1.0.1</version> </dependency> <dependency>
 							<groupId>com.opensymphony.sitemesh</groupId>
 							<artifactId>com.springsource.com.opensymphony.sitemesh</artifactId>
-							<version>2.3.0</version>
-						</dependency> -->
+							<version>2.3.0</version> </dependency>
+						-->
 					</dependencies>
 				</plugin>
 				<plugin>
@@ -619,12 +609,21 @@ limitations under the License.
 				<artifactId>com.springsource.org.apache.activemq</artifactId>
 				<version>${version.activemq}</version>
 			</dependency>
+			<dependency>
+				<groupId>org.apache.activemq</groupId>
+				<artifactId>com.springsource.org.apache.activemq.web</artifactId>
+				<version>${version.activemq}</version>
+			</dependency>
 			<dependency>
 				<groupId>org.apache.xbean</groupId>
 				<artifactId>com.springsource.org.apache.xbean.spring</artifactId>
 				<version>3.3.0</version>
 			</dependency>
-
+			<dependency>
+				<groupId>org.apache.geronimo.specs</groupId>
+				<artifactId>com.springsource.javax.management.j2ee</artifactId>
+				<version>1.0.1</version>
+			</dependency>
 		</dependencies>
 	</dependencyManagement>
 	<repositories>
diff --git a/runtime/org.argeo.slc.server/pom.xml b/runtime/org.argeo.slc.server/pom.xml
index 78eb3375e..223116e07 100644
--- a/runtime/org.argeo.slc.server/pom.xml
+++ b/runtime/org.argeo.slc.server/pom.xml
@@ -1,4 +1,5 @@
-<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">
+<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.argeo.slc</groupId>
@@ -48,6 +49,12 @@
 						../../org.argeo.slc.webapp/src/main/config/jetty/jetty-test-local.xml
 					</jettyConfig>
 					<webDefaultXml>../../org.argeo.slc.webapp/src/main/config/jetty/webdefault.xml</webDefaultXml>
+					<systemProperties>
+						<systemProperty>
+							<name>activemq.base</name>
+							<value>${user.home}/share/apache-activemq-5.2.0</value>
+						</systemProperty>
+					</systemProperties>
 				</configuration>
 			</plugin>
 		</plugins>
@@ -110,5 +117,27 @@
 			<artifactId>com.springsource.javax.wsdl</artifactId>
 		</dependency>
 
+		<!-- JMS -->
+		<dependency>
+			<groupId>javax.jms</groupId>
+			<artifactId>com.springsource.javax.jms</artifactId>
+		</dependency>
+		<dependency>
+			<groupId>org.apache.activemq</groupId>
+			<artifactId>com.springsource.org.apache.activemq</artifactId>
+		</dependency>
+		<dependency>
+			<groupId>org.apache.xbean</groupId>
+			<artifactId>com.springsource.org.apache.xbean.spring</artifactId>
+		</dependency>
+		<dependency>
+			<groupId>org.apache.activemq</groupId>
+			<artifactId>com.springsource.org.apache.activemq.web</artifactId>
+		</dependency>
+		<dependency>
+			<groupId>org.apache.geronimo.specs</groupId>
+			<artifactId>com.springsource.javax.management.j2ee</artifactId>
+		</dependency>
+
 	</dependencies>
 </project>
-- 
2.39.2