Changeset 3616

Timestamp:

08/08/12 11:39:25

Author:

douglm

Message:

First stage in adding change notifications.

New sysevents classes so that any old ones in the pipeline will get processed OK.

New package chgnote to handle asynch processing of notifications.

New JMS queue added

New JMX task to monitor and control processing.

Files:

• trunk/config/bwbuild/jboss-postgresql-devel/activemq-broker-config.xml (modified) (5 diffs)
• trunk/config/bwbuild/jboss-postgresql-devel/activemq-jms-ds.xml (modified) (1 diff)
• trunk/config/bwbuild/jboss-postgresql-devel/build.properties (modified) (1 diff)
• trunk/deployment/bw-core-appjars.xml (modified) (1 diff)
• trunk/deployment/ear.meta/jboss-service.xml (modified) (1 diff)

trunk/config/bwbuild/jboss-postgresql-devel/activemq-broker-config.xml

@@ -52 +52 @@
-    -->
-    <destinations>
+      <!-- If we want to run the bedenote JMS handler we need to
+           define the sysevents queue as a physical queue as shown here
-      <queue name="bedeworkSyseventsIn"
-             physicalName="bedework.sysevents" />
+             -->
+             
+      <!-- The listener handles change notifications -->
+      <queue name="changes"
+             physicalName="bedework.sysevents.changes" />
-             
-      <!-- The listener just logs the system events -->
@@ -79 +86 @@
-      
-      <!--  ================= queues for camel stuff ====================== 
+            We need queues to take output from the bedenote notification
+            processor. We might not need all of these as some might
+            be handled as an internal camel process.
-      <queue name="bedeworkSysevents"
-             physicalName="bedework.sysevents.cm.sysev" />
@@ -94 +104 @@
-    </destinations>
-
-
+
+
+
+
+
-    <destinationInterceptors>
-      <virtualDestinationInterceptor>
@@ -100 +114 @@
-          <compositeQueue name="bedework.sysevents">
-            <forwardTo>
-              <! - - Forward all to the camel sysevents queue for testing. - - >
-              <queue physicalName="bedework.sysevents.cm.sysev" />
-              <queue physicalName="bedework.sysevents.logger" />
-              <queue physicalName="bedework.sysevents.monitor" />
-              <queue physicalName="bedework.crawler" />
+              <filteredDestination selector="changeEvent = 'true'"
+                                   queue="bedework.sysevents.changes" />
-              <filteredDestination selector="inbox = 'true' or scheduleEvent = 'true'"
-                                   queue="bedework.scheduleIn"/>
@@ -113 +127 @@
-        </virtualDestinations>
-      </virtualDestinationInterceptor>
--->
+
-
-    <!--

trunk/config/bwbuild/jboss-postgresql-devel/activemq-jms-ds.xml

@@ -113 +113 @@
-   </mbean>
-
+   <!-- Bedework change processing queue -->
+   <mbean code="org.jboss.resource.deployment.AdminObject" 
+          name="activemq.queue:name=changes">
+      <attribute name="JNDIName">activemq/queue/changes</attribute>
+      <depends optional-attribute-name="RARName">jboss.jca:service=RARDeployment,name='activemq-rar-5.3.0.rar'</depends>
+      <attribute name="Type">javax.jms.Queue</attribute>
+      <attribute name="Properties">PhysicalName=bedework.sysevents.changes</attribute>
+   </mbean>
+
-   <!-- Bedework outbox processing queue -->
-
+
+
-      <attribute name="JNDIName">activemq/queue/schedulerOut</attribute>
-      <depends optional-attribute-name="RARName">jboss.jca:service=RARDeployment,name='activemq-rar-5.3.0.rar'</depends>

trunk/config/bwbuild/jboss-postgresql-devel/build.properties

@@ -11 +11 @@
-org.bedework.configuration.versions=${org.bedework.configuration.defaults}/versions.properties
-
-
+
+
-org.bedework.config.home=${env.BEDEWORK_CONFIG}
-

trunk/deployment/bw-core-appjars.xml

@@ -78 +78 @@
-              libcache="${org.bedework.libcache.dir}"
-              name="bw-calsvc" version="${org.bedework.calcore.version}" 
+              projecthome="${project.home}/../bwcalcore" />
+      
+      <getJar lib="${org.bedework.temp.extrajars.dir}"
+              libcache="${org.bedework.libcache.dir}"
+              name="bw-chgnote" version="${org.bedework.calcore.version}" 
-              projecthome="${project.home}/../bwcalcore" />
-

trunk/deployment/ear.meta/jboss-service.xml

@@ -24 +24 @@
-         name="org.bedework:service=Ischedule">
-    <attribute name="Account">admin</attribute>
+    
+    <!-- We also need the bedework database -->
+    <depends>jboss.jca:service=DataSourceBinding,name=CalendarDS</depends>
+  </mbean>
+  
+  <mbean code="org.bedework.chgnote.BwChgNote"
+         name="org.bedework:service=BwChgNote">
+         <!--  no attributes yet
+    <attribute name="Account">admin</attribute>
+    <attribute name="SkipPaths">/public/unbrowsable:/public/aliases</attribute>
+    -->
+
+    <!-- We need activemq -->    
+    <depends>jboss.jca:service=ConnectionFactoryBinding,name=activemq/QueueConnectionFactory</depends>
-    
-    <!-- We also need the bedework database -->