wamblee.org Git - xmlrouter/blob - listener/src/main/java/org/wamblee/xmlrouter/listener/CompositeEventListener.java

   1 /*
   2  * Copyright 2005-2011 the original author or authors.
   3  *
   4  * Licensed under the Apache License, Version 2.0 (the "License");
   5  * you may not 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.
  15  */
  16 package org.wamblee.xmlrouter.listener;
  17
  18 import java.util.ArrayList;
  19 import java.util.Iterator;
  20 import java.util.List;
  21 import java.util.logging.Level;
  22 import java.util.logging.Logger;
  23
  24 import javax.print.attribute.standard.Destination;
  25 import javax.xml.transform.dom.DOMSource;
  26
  27 import org.wamblee.concurrency.ReadLock;
  28 import org.wamblee.concurrency.WriteLock;
  29 import org.wamblee.xmlrouter.common.Id;
  30 import org.wamblee.xmlrouter.config.Transformation;
  31
  32 public class CompositeEventListener implements EventListener {
  33
  34     private static final Logger LOGGER = Logger
  35         .getLogger(CompositeEventListener.class.getName());
  36     private List<EventListener> loggers;
  37
  38     public CompositeEventListener() {
  39         loggers = new ArrayList<EventListener>();
  40     }
  41
  42     /**
  43      * Adds a logger.
  44      *
  45      * @param aLogger
  46      *            Logger
  47      */
  48     @WriteLock
  49     public void addLogger(EventListener aLogger) {
  50         loggers.add(aLogger);
  51     }
  52
  53     /**
  54      * Removes a logger.
  55      *
  56      * @param aLogger
  57      *            Logger
  58      * @return True iff the logger was removed.
  59      */
  60     @WriteLock
  61     public boolean removeLogger(EventListener aLogger) {
  62         Iterator<EventListener> logger = loggers.iterator();
  63         while (logger.hasNext()) {
  64             EventListener value = logger.next();
  65             if (value == aLogger) {
  66                 logger.remove();
  67                 return true;
  68             }
  69         }
  70         return false;
  71     }
  72
  73     @Override
  74     @ReadLock
  75     public void delivered(String aDocumentType, Id<DOMSource> aEventId,
  76         DOMSource aEvent, List<Transformation> aSequence,
  77         Id<Destination> aDestination, String aDestinationName,
  78         boolean aSuccessFlag) {
  79         for (EventListener logger : loggers) {
  80             try {
  81                 logger.delivered(aDocumentType, aEventId, aEvent, aSequence,
  82                     aDestination, aDestinationName, aSuccessFlag);
  83             } catch (Exception e) {
  84                 LOGGER.log(Level.WARNING, "Logger threw exception", e);
  85             }
  86         }
  87     }
  88
  89     @Override
  90     @ReadLock
  91     public void notDelivered(String aDocumentType, Id<DOMSource> aEventId,
  92         DOMSource aEvent) {
  93         for (EventListener logger : loggers) {
  94             try {
  95                 logger.notDelivered(aDocumentType, aEventId, aEvent);
  96             } catch (Exception e) {
  97                 LOGGER.log(Level.WARNING, "Logger threw exception", e);
  98             }
  99         }
 100     }
 101
 102 }