Return-Path: 
 <commons-dev-return-17113-qmlist-jakarta-archive-commons-dev=jakarta.apache.org@jakarta.apache.org>
Delivered-To: apmail-jakarta-commons-dev-archive@apache.org
Received: (qmail 83251 invoked from network); 7 Oct 2002 10:38:32 -0000
Received: from unknown (HELO nagoya.betaversion.org) (192.18.49.131)
  by daedalus.apache.org with SMTP; 7 Oct 2002 10:38:32 -0000
Received: (qmail 18381 invoked by uid 97); 7 Oct 2002 10:39:11 -0000
Delivered-To: qmlist-jakarta-archive-commons-dev@jakarta.apache.org
Received: (qmail 18365 invoked by uid 97); 7 Oct 2002 10:39:10 -0000
Mailing-List: contact commons-dev-help@jakarta.apache.org; run by ezmlm
Precedence: bulk
List-Unsubscribe: <mailto:commons-dev-unsubscribe@jakarta.apache.org>
List-Subscribe: <mailto:commons-dev-subscribe@jakarta.apache.org>
List-Help: <mailto:commons-dev-help@jakarta.apache.org>
List-Post: <mailto:commons-dev@jakarta.apache.org>
List-Id: "Jakarta Commons Developers List" <commons-dev.jakarta.apache.org>
Reply-To: "Jakarta Commons Developers List" <commons-dev@jakarta.apache.org>
Delivered-To: mailing list commons-dev@jakarta.apache.org
Received: (qmail 18354 invoked by uid 97); 7 Oct 2002 10:39:09 -0000
X-Antivirus: nagoya (v4218 created Aug 14 2002)
Date: 7 Oct 2002 10:38:23 -0000
Message-ID: <20021007103823.97679.qmail@icarus.apache.org>
From: jstrachan@apache.org
To: jakarta-commons-sandbox-cvs@apache.org
Subject: cvs commit:
 jakarta-commons-sandbox/messenger/src/java/org/apache/commons/messagelet
 Main.java
X-Spam-Rating: daedalus.apache.org 1.6.2 0/1000/N
X-Spam-Rating: daedalus.apache.org 1.6.2 0/1000/N

jstrachan    2002/10/07 03:38:23

  Modified:    messenger/src/conf subscribe.xml MessengerSpiritWave.xml
               messenger maven.xml
               messenger/src/java/org/apache/commons/messagelet Main.java
  Added:       messenger/src/test/org/apache/commons/messenger
                        LoggingMDO.java
  Log:
  Added a simple example to the maven build for consuming JMS messages using the simple command line Messagelet engine and a simple LoggingMDO.
  
  Revision  Changes    Path
  1.9       +11 -5     jakarta-commons-sandbox/messenger/src/conf/subscribe.xml
  
  Index: subscribe.xml
  ===================================================================
  RCS file: /home/cvs/jakarta-commons-sandbox/messenger/src/conf/subscribe.xml,v
  retrieving revision 1.8
  retrieving revision 1.9
  diff -u -r1.8 -r1.9
  --- subscribe.xml	9 Jul 2002 11:53:35 -0000	1.8
  +++ subscribe.xml	7 Oct 2002 10:38:23 -0000	1.9
  @@ -1,6 +1,11 @@
   <?xml version="1.0" encoding="UTF-8"?>
   <subscriptions>
   
  +	<!-- a simple echo consumer -->
  +  <subscription connection="queue" subject="echo.queue">
  +    <listener className="org.apache.commons.messenger.LoggingMDO"/>
  +  </subscription>
  +
     <!-- bridge to another JMS provider -->
     <subscription connection="queue" subject="my.input2" selector="b='12'">
       <bridge outputConnection="queue" outputSubject="my.output"/>
  @@ -9,12 +14,12 @@
     <!-- distribute messages to multiple output queues -->
     <subscription connection="queue" subject="my.input">
       <distributeBridge outputConnection="queue">
  -	  <subject>output.A</subject>		    	
  -	  <subject>output.B</subject>		    	
  -	  <subject>output.C</subject>		    	
  -	  <subject>output.D</subject>		    	
  +		  <subject>output.A</subject>		    	
  +		  <subject>output.B</subject>		    	
  +		  <subject>output.C</subject>		    	
  +		  <subject>output.D</subject>		    	
       </distributeBridge>
  -  </subscription>
  +	</subscription>
   
   
     <!-- consume the output queues and report throughput -->
  @@ -30,6 +35,7 @@
     <subscription connection="queue" subject="output.D">
       <stopWatch groupSize="100"/>
     </subscription>
  +
   
   
   
  
  
  
  1.5       +2 -2      jakarta-commons-sandbox/messenger/src/conf/MessengerSpiritWave.xml
  
  Index: MessengerSpiritWave.xml
  ===================================================================
  RCS file: /home/cvs/jakarta-commons-sandbox/messenger/src/conf/MessengerSpiritWave.xml,v
  retrieving revision 1.4
  retrieving revision 1.5
  diff -u -r1.4 -r1.5
  --- MessengerSpiritWave.xml	8 Jul 2002 16:19:05 -0000	1.4
  +++ MessengerSpiritWave.xml	7 Oct 2002 10:38:23 -0000	1.5
  @@ -2,11 +2,11 @@
   <manager>
   
     <messenger name="topic">
  -    <factory className="com.spirit.messenger.WaveTopicSessionFactory" transacted="true">
  +    <factory className="com.spirit.messenger.WaveTopicSessionFactory">
       </factory>
     </messenger>
     <messenger name="queue">
  -    <factory className="com.spirit.messenger.WaveQueueSessionFactory" transacted="true">
  +    <factory className="com.spirit.messenger.WaveQueueSessionFactory">
       </factory>
     </messenger>
   </manager>
  
  
  
  1.3       +9 -4      jakarta-commons-sandbox/messenger/maven.xml
  
  Index: maven.xml
  ===================================================================
  RCS file: /home/cvs/jakarta-commons-sandbox/messenger/maven.xml,v
  retrieving revision 1.2
  retrieving revision 1.3
  diff -u -r1.2 -r1.3
  --- maven.xml	8 Jul 2002 15:15:24 -0000	1.2
  +++ maven.xml	7 Oct 2002 10:38:23 -0000	1.3
  @@ -1,15 +1,19 @@
   <project default="java:jar" xmlns:j="jelly:core">
   
  -  <goal name="set.classpath" prereqs="java:compile">
  +  <goal name="set.classpath" prereqs="java:compile, test:compile">
   
     	<echo>
   		Using JMS from lib dir ${jms.lib.dir} and config dir ${jms.classes.dir}
  +		Connecting via ${messenger.xml}
       </echo>
       
       <path id="jms.classpath">
  +    	<!--
         <pathelement path="target/classes"/>
  +      -->
  +      <pathelement path="target/test-classes"/>
         <pathelement path="${maven.build.dest}"/>
  -	  <path refid="maven.dependency.classpath"/>
  +	  	<path refid="maven.dependency.classpath"/>
   	  
         <!-- add the JARs required for a pluggable JMS provider -->
         <pathelement path="${jms.classes.dir}"/>
  @@ -21,7 +25,8 @@
     </goal>
     		
     <!-- runs a sample number of subscriptions -->	
  -  <goal name="demo.subscribe" prereqs="set.classpath">
  +  <goal name="demo:subscribe" prereqs="set.classpath"
  +  	description="Subscribes to various destinations waiting for JMS messages">
     
       <java classname="org.apache.commons.messagelet.Main" fork="yes">
         <classpath refid="jms.classpath"/>
  @@ -37,7 +42,7 @@
       <java classname="org.apache.commons.messenger.tool.Producer" fork="yes">
         <classpath refid="jms.classpath"/>
         <arg value="queue"/>
  -      <arg value="my.input"/>
  +      <arg value="echo.queue"/>
         <arg value="src/conf/sampleMessage.txt"/>
         <sysproperty key="org.apache.commons.messenger" value="${messenger.xml}"/>
       </java>
  
  
  
  1.1                  jakarta-commons-sandbox/messenger/src/test/org/apache/commons/messenger/LoggingMDO.java
  
  Index: LoggingMDO.java
  ===================================================================
  /*
   * Copyright (C) The Apache Software Foundation. All rights reserved.
   *
   * This software is published under the terms of the Apache Software License
   * version 1.1, a copy of which has been included with this distribution in
   * the LICENSE file.
   * 
   * $Id: LoggingMDO.java,v 1.4 2002/05/17 15:05:46 jstrachan Exp $
   */
  package org.apache.commons.messenger;
  
  import javax.jms.Message;
  
  import org.apache.commons.logging.Log;
  import org.apache.commons.logging.LogFactory;
  
  import org.apache.commons.messagelet.MessengerMDO;
  import org.apache.commons.messenger.Messenger;
  
  /** 
   * <p><code>LoggingMDO</code> is a simple MDO which
   * logs the fact that it consumed a message.</p>
   *
   * @author <a href="mailto:jstrachan@apache.org">James Strachan</a>
   * @version $Revision: 1.4 $
   */
  public class LoggingMDO extends MessengerMDO {
  
      /** Logger to which logging messages will go */
      private static final Log log = LogFactory.getLog(LoggingMDO.class);
      
      public void onMessage(Message message) {
          log.info( "Received message: " + message );
          
          System.out.println( "Received message: " + message );
      }
  }
  
  
  
  1.5       +24 -3     jakarta-commons-sandbox/messenger/src/java/org/apache/commons/messagelet/Main.java
  
  Index: Main.java
  ===================================================================
  RCS file: /home/cvs/jakarta-commons-sandbox/messenger/src/java/org/apache/commons/messagelet/Main.java,v
  retrieving revision 1.4
  retrieving revision 1.5
  diff -u -r1.4 -r1.5
  --- Main.java	14 Aug 2002 14:36:12 -0000	1.4
  +++ Main.java	7 Oct 2002 10:38:23 -0000	1.5
  @@ -57,7 +57,7 @@
       private String subscriptionsConfig = "subscriptions.xml";
   
       /** Should we use a stopwatch to output performance metrics */
  -    private boolean useStopWatch = true;
  +    private boolean useStopWatch = false;
   
       
       public static void main(String[] args) {
  @@ -88,12 +88,12 @@
       /**
        * Starts all the JMS connections and consumes JMS messages, 
        * passing them onto the MessageListener and Message Driven Objects
  -     * */
  +     */
       public void run() throws Exception {
   
           // force lazy construction
           getMessengerManager();
  -
  +        
           // load the subscriptions....
           subscriptionList = createSubscriptionList();
           subscribe( subscriptionList );
  @@ -109,7 +109,10 @@
                   log.error( "Caught exception trying to start messenger: " + name + ". Exception: " + e, e );
               }
           }
  +        
  +        //waitForever();
       }
  +
       
       public Messenger getMessenger(String name) throws JMSException {
           return getMessengerManager().getMessenger( name );
  @@ -204,6 +207,8 @@
               
               messenger.addListener( destination, listener );
           }
  +        
  +        log.info( "Subscribed with listener: " + listener );
       }
       
       protected MessengerManager createMessengerManager() throws JMSException {
  @@ -257,4 +262,20 @@
           return listener;
       }
           
  +    /**
  +     * This method blocks the current thread indefinitely until the JVM is terminated.
  +     */
  +    protected void waitForever() {
  +        Object lock = new Object();
  +        synchronized (lock) {
  +            while (true) {
  +                try {
  +                    lock.wait();
  +                }
  +                catch (Exception e) {
  +                    log.warn( "Main thread interupted: " + e, e );
  +                }
  +            }
  +        }
  +    }
   }
  
  
  

--
To unsubscribe, e-mail:   <mailto:commons-dev-unsubscribe@jakarta.apache.org>
For additional commands, e-mail: <mailto:commons-dev-help@jakarta.apache.org>