/*

  * 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: SubscriptionDigester.java 155459 2005-02-26 13:24:44Z dirkv $

  */

 package org.apache.commons.messagelet.model;

 import org.apache.commons.digester.Digester;

 /** <p><code>MessengerDigester</code> is a digester of Messenger objects so 

   * that JMS Messengers can be created from an XML config file.</p>

   *

   * @author <a href="mailto:jstrachan@apache.org">James Strachan</a>

   * @version $Revision: 155459 $

   */

 public class SubscriptionDigester extends Digester {

     // default implementation classes

     private String subscriptionsClass = "org.apache.commons.messagelet.model.SubscriptionList";

     private String subscriptionClass = "org.apache.commons.messagelet.model.Subscription";

     private String listenerClass = "org.apache.commons.messagelet.impl.MessageServletDispatcher";

     private String bridgeClass = "org.apache.commons.messagelet.BridgeMDO";

     private String distributeBridgeClass = "org.apache.commons.messagelet.DistributeBridgeMDO";

     private String stopWatchClass = "org.apache.commons.messenger.tool.StopWatchMessageListener";

     private String consumerThreadClass = "org.apache.commons.messagelet.ConsumerThread";

     public SubscriptionDigester() {

     }

     // Implementation methods

     //-------------------------------------------------------------------------    

     /** Configure the parsing rules that will be used to process 

      * the cache config file

      */

     protected void configure() {

         if (configured) {

             return;

         }

         else {

             configured = true;

         }

         String path = "subscriptions";

         addObjectCreate( path, subscriptionsClass, "className" );

         addSetProperties( path );

         path = "subscriptions/subscription";

         addObjectCreate( path, subscriptionClass, "className" );

         addSetProperties( path );        

         addSetNext( path, "addSubscription",

            "org.apache.commons.messagelet.model.Subscription"

         );        

         addCallMethod( "subscriptions/subscription/servlet", "setServlet", 0);

         path = "subscriptions/subscription/consumerThread";

         addObjectCreate( path, consumerThreadClass, "className" );

         addSetProperties( path );

         addSetNext( path, "setConsumerThread",

            consumerThreadClass

         );

         path = "subscriptions/subscription/listener";

         addObjectCreate( path, listenerClass, "className" );

         addSetProperties( path );

         addSetNext( path, "setMessageListener",

            "javax.jms.MessageListener"

         );

         path = "subscriptions/subscription/stopWatch";

         addObjectCreate( path, stopWatchClass, "className" );

         addSetProperties( path );

         addSetNext( path, "setMessageListener",

            "javax.jms.MessageListener"

         );

         path = "subscriptions/subscription/bridge";

         addObjectCreate( path, bridgeClass, "className" );

         addSetProperties( path );

         addSetNext( path, "setMessageListener",

            "javax.jms.MessageListener"

         );

         path = "subscriptions/subscription/distributeBridge";

         addObjectCreate( path, distributeBridgeClass, "className" );

         addSetProperties( path );

         addSetNext( path, "setMessageListener",

            "javax.jms.MessageListener"

         );

         addCallMethod("subscriptions/subscription/distributeBridge/subject", "addOutputSubject", 0);        

     }

 }