cocoon-cvs mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From un...@apache.org
Subject cvs commit: cocoon-2.1/src/blocks/jms/java/org/apache/cocoon/components/jms JMSConnectionImpl.java
Date Mon, 05 Jan 2004 17:15:16 GMT
unico       2004/01/05 09:15:16

  Modified:    src/blocks/jms/java/org/apache/cocoon/components/jms
                        JMSConnectionImpl.java
  Log:
  code formatting
  
  Revision  Changes    Path
  1.6       +64 -63    cocoon-2.1/src/blocks/jms/java/org/apache/cocoon/components/jms/JMSConnectionImpl.java
  
  Index: JMSConnectionImpl.java
  ===================================================================
  RCS file: /home/cvs/cocoon-2.1/src/blocks/jms/java/org/apache/cocoon/components/jms/JMSConnectionImpl.java,v
  retrieving revision 1.5
  retrieving revision 1.6
  diff -u -r1.5 -r1.6
  --- JMSConnectionImpl.java	15 Nov 2003 04:21:29 -0000	1.5
  +++ JMSConnectionImpl.java	5 Jan 2004 17:15:16 -0000	1.6
  @@ -100,11 +100,11 @@
    * @author <a href="mailto:haul@informatik.tu-darmstadt.de">haul</a>
    */
   public class JMSConnectionImpl extends AbstractLogEnabled 
  -                                implements Configurable, 
  -                                            Disposable, 
  -                                            ThreadSafe,
  -                                            Initializable,  
  -                                            JMSConnection {
  +                               implements Configurable, 
  +                                          Disposable, 
  +                                          ThreadSafe,
  +                                          Initializable,  
  +                                          JMSConnection {
   
       private boolean available = false;
       protected String topicFactoryName;
  @@ -121,6 +121,64 @@
       protected TopicConnectionFactory topicConnectionFactory;
   
       private Parameters jndiParams;
  +    
  +    
  +    public void configure(Configuration conf) throws ConfigurationException {
  +        Parameters parameters = Parameters.fromConfiguration(conf);
  +        this.jndiParams = Parameters.fromConfiguration(conf.getChild("jndi-info"));
  +        this.topicFactoryName =
  +                parameters.getParameter("topic-factory", null);
  +        this.topicName = parameters.getParameter("topic", null);
  +        this.durableSubscriptionID =
  +            parameters.getParameter(
  +                "durable-subscription-id",null);
  +
  +        this.ackModeName =
  +            parameters.getParameter("ack-mode", this.ackModeName).toLowerCase();
  +        // see if an ack mode has been specified. If it hasn't
  +        // then assume CLIENT_ACKNOWLEDGE mode.
  +        this.ackMode = Session.CLIENT_ACKNOWLEDGE;
  +        if (this.ackModeName.equals("auto")) {
  +            this.ackMode = Session.AUTO_ACKNOWLEDGE;
  +        } else if (this.ackModeName.equals("dups")) {
  +            this.ackMode = Session.DUPS_OK_ACKNOWLEDGE;
  +        } else if (!this.ackModeName.equals("client")) {
  +            // ignore all ack modes, to test no acking
  +            this.ackMode = -1;
  +        }
  +    }
  +    
  +    /* (non-Javadoc)
  +     * @see org.apache.avalon.framework.activity.Initializable#initialize()
  +     */
  +    public void initialize() throws Exception {
  +        try {
  +            this.context = setupContext();
  +            this.setupConnection();
  +            this.setupSession();
  +            this.available = true;
  +        } catch (NamingException e) {
  +            if (getLogger().isWarnEnabled()) {
  +                getLogger().warn("Cannot get Initial Context.  Is the JNDI server reachable?",e);
  +            }
  +        } catch (JMSException e) {
  +            if (getLogger().isWarnEnabled()) {
  +                getLogger().warn("Failed to initialize JMS.",e);
  +            }
  +        }
  +    }
  +
  +    /* 
  +     * @see org.apache.avalon.framework.activity.Disposable#dispose()
  +     */
  +    public void dispose() {
  +        try {
  +            this.disconnect();
  +        } catch (JMSException e) {
  +        } catch (NamingException e) {
  +        }
  +    }
  +    
   	/**
        * Register a new TopicListener for this connection.
        * 
  @@ -250,62 +308,5 @@
           this.session.close();
           this.connection.close();
       }
  -
  -    public void configure(Configuration conf) throws ConfigurationException {
  -			Parameters parameters = Parameters.fromConfiguration(conf);
  -			this.jndiParams = Parameters.fromConfiguration(conf.getChild("jndi-info"));
  -            this.topicFactoryName =
  -                    parameters.getParameter("topic-factory", null);
  -            this.topicName = parameters.getParameter("topic", null);
  -            this.durableSubscriptionID =
  -                parameters.getParameter(
  -                    "durable-subscription-id",null);
  -
  -            this.ackModeName =
  -                parameters.getParameter("ack-mode", this.ackModeName).toLowerCase();
  -            // see if an ack mode has been specified. If it hasn't
  -            // then assume CLIENT_ACKNOWLEDGE mode.
  -            this.ackMode = Session.CLIENT_ACKNOWLEDGE;
  -            if (this.ackModeName.equals("auto")) {
  -                this.ackMode = Session.AUTO_ACKNOWLEDGE;
  -            } else if (this.ackModeName.equals("dups")) {
  -                this.ackMode = Session.DUPS_OK_ACKNOWLEDGE;
  -            } else if (!this.ackModeName.equals("client")) {
  -                // ignore all ack modes, to test no acking
  -                this.ackMode = -1;
  -            }
  -    }
  -
  -    
  -    /* 
  -     * @see org.apache.avalon.framework.activity.Disposable#dispose()
  -     */
  -    public void dispose() {
  -        try {
  -            this.disconnect();
  -        } catch (JMSException e) {
  -        } catch (NamingException e) {
  -        }
  -    }
  -
  -	/* (non-Javadoc)
  -	 * @see org.apache.avalon.framework.activity.Initializable#initialize()
  -	 */
  -	public void initialize() throws Exception {
  -		try {
  -			this.context = setupContext();
  -			this.setupConnection();
  -			this.setupSession();
  -            this.available = true;
  -		} catch (NamingException e) {
  -            if (getLogger().isWarnEnabled()) {
  -                getLogger().warn("Cannot get Initial Context.  Is the JNDI server reachable?",e);
  -            }
  -        } catch (JMSException e) {
  -            if (getLogger().isWarnEnabled()) {
  -                getLogger().warn("Failed to initialize JMS.",e);
  -            }
  -		}
  -	}
   
   }
  
  
  

Mime
View raw message