/* 
    P/P   *  Method: org.apache.roller.weblogger.business.referrers.QueuedReferrerProcessingJob__static_init
          */
     1  /*
     2  * Licensed to the Apache Software Foundation (ASF) under one or more
     3  *  contributor license agreements.  The ASF licenses this file to You
     4  * under the Apache License, Version 2.0 (the "License"); you may not
     5  * use this file except in compliance with the License.
     6  * You may obtain a copy of the License at
     7  *
     8  *     http://www.apache.org/licenses/LICENSE-2.0
     9  *
    10  * Unless required by applicable law or agreed to in writing, software
    11  * distributed under the License is distributed on an "AS IS" BASIS,
    12  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
    13  * See the License for the specific language governing permissions and
    14  * limitations under the License.  For additional information regarding
    15  * copyright in this work, please see the NOTICE file in the top level
    16  * directory of this distribution.
    17  */
    18  /*
    19   * QueuedReferrerProcessingJob.java
    20   *
    21   * Created on December 20, 2005, 3:08 PM
    22   */
    23  
    24  package org.apache.roller.weblogger.business.referrers;
    25  
    26  import org.apache.roller.weblogger.business.WebloggerFactory;
    27  
    28  
    29  /**
    30   * Same as the ReferrerProcessingJob, except that we add a little logic that
    31   * tries to lookup incoming referrers from the ReferrerQueueManager.
    32   *
    33   * @author Allen Gilliland
    34   */
    35  public class QueuedReferrerProcessingJob extends ReferrerProcessingJob {
    36      
    37      public QueuedReferrerProcessingJob() {
                 /* 
    P/P           *  Method: void org.apache.roller.weblogger.business.referrers.QueuedReferrerProcessingJob()
                  * 
                  *  Postconditions:
                  *    this.inputs == null
                  *    this.referrer == null
                  */
    38          super();
    39      }
    40      
    41      
    42      public void execute() {
    43          
                 /* 
    P/P           *  Method: void execute()
                  * 
                  *  Preconditions:
                  *    org/apache/roller/weblogger/business/WebloggerFactory.webloggerProvider != null
                  *    org/apache/roller/weblogger/business/WebloggerFactory.webloggerProvider.webloggerInstance != null
                  *    (soft) org/apache/roller/weblogger/business/jpa/JPARefererManagerImpl.log != null
                  *    (soft) org/apache/roller/weblogger/business/jpa/JPAUserManagerImpl.log != null
                  *    (soft) org/apache/roller/weblogger/business/jpa/JPAWeblogManagerImpl.log != null
                  *    (soft) org/apache/roller/weblogger/business/referrers/ReferrerProcessingJob.mLogger != null
                  *    (soft) org/apache/roller/weblogger/config/WebloggerRuntimeConfig.log != null
                  * 
                  *  Presumptions:
                  *    getWeblogger(...).refererQueueManager != null
                  *    refQueue.referrerQueue != null
                  *    refQueue.referrerQueue@48 != null
                  * 
                  *  Postconditions:
                  *    this.referrer == null
                  */
    44          ReferrerQueueManager refQueue =
    45                  WebloggerFactory.getWeblogger().getReferrerQueueManager();
    46          
    47          // check the queue for any incoming referrers
    48          referrer = refQueue.dequeue();
    49          
    50          // work until the queue is empty
    51          while(referrer != null) {
    52              super.execute();
    53              
    54              // check if there are more referrers to process
    55              referrer = refQueue.dequeue();
    56          }
    57          
    58      }
    59      
    60  }