added changes

Author: janithb

pom.xml

@@ -37,8 +37,8 @@
 			<organizationUrl>http://audit4j.org</organizationUrl>
 			<email>[email protected]</email>
 			<roles>
-				<role>owner</role>
-				<role>developer</role>
+				<role>Architect</role>
+				<role>Developer</role>
 			</roles>
 			<timezone>+05:30</timezone>
 		</developer>

src/main/java/org/audit4j/core/TroubleshootManager.java

@@ -49,7 +49,7 @@ public static void troubleshootEvent(AuditEvent event) {
             throw new TroubleshootException(
                     "Invalid Audit event type,\n Audit4j: Audit Event should not null, This event will not be logged by the Audit4j.");
         } else if (event.getActor() == null) {
-            if (Context.getConfigContext().getMetaData().getClass().equals(DummyMetaData.class)) {
+            if (Context.getConfigContext().getMetaData() == null || Context.getConfigContext().getMetaData().getClass().equals(DummyMetaData.class)) {
                 event.setActor(CoreConstants.DEFAULT_ACTOR);
                 Log.warn("Audit4j:WARN If you are not parsing the actor to the AuditEvent,\n"
                         + "Audit4j:WARN you should make a your own AuditMetaData implementation. \n"

src/main/java/org/audit4j/core/util/TimelyBufferedArrayList.java renamed to src/main/java/org/audit4j/core/util/ConcurrentTimelyBufferedArrayList.java

@@ -18,80 +18,99 @@
 
 package org.audit4j.core.util;
 
+import java.io.Serializable;
 import java.util.AbstractList;
 import java.util.ArrayList;
 import java.util.List;
 import java.util.RandomAccess;
 import java.util.Timer;
 import java.util.TimerTask;
+import java.util.concurrent.CopyOnWriteArrayList;
 
 /**
  * The Class CircularTimelyBufferedArrayList.
- *
- * @param <E> the element type
+ * 
+ * @param <E>
+ *            the element type
  * @author <a href="mailto:[email protected]">Janith Bandara</a>
  */
-public class TimelyBufferedArrayList<E> extends AbstractList<E> implements RandomAccess{
+public class ConcurrentTimelyBufferedArrayList<E> extends AbstractList<E> implements RandomAccess, Serializable,
+        Cloneable {
+
+    /**
+     * asdas
+     */
+    private static final long serialVersionUID = 8870953621895891238L;
 
     /** The buff. */
-    private final List<E> buff = new ArrayList<E>();
-    
+    private final List<E> buff = new CopyOnWriteArrayList<E>();
+
     /** The listener. */
     private final BufferedListener<E> listener;
 
     /**
      * Instantiates a new circular timely buffered array list.
-     *
-     * @param timeInMills the time in mills
-     * @param listener the listener
+     * 
+     * @param timeInMills
+     *            the time in mills
+     * @param listener
+     *            the listener
      */
-    public TimelyBufferedArrayList(final int timeInMills, final BufferedListener<E> listener) {
+    public ConcurrentTimelyBufferedArrayList(final int timeInMills, final BufferedListener<E> listener) {
         this.listener = listener;
         Timer time = new Timer();
         ScheduleConsumer consumer = new ScheduleConsumer();
         time.schedule(consumer, 0, timeInMills);
     }
 
-    /* (non-Javadoc)
+    /*
+     * (non-Javadoc)
+     * 
      * @see java.util.AbstractList#get(int)
      */
     @Override
     public E get(int index) {
         return buff.get(index);
     }
 
-    /* (non-Javadoc)
+    /*
+     * (non-Javadoc)
+     * 
      * @see java.util.AbstractList#add(java.lang.Object)
      */
     @Override
     public boolean add(E e) {
         return buff.add(e);
     }
 
-    /* (non-Javadoc)
+    /*
+     * (non-Javadoc)
+     * 
      * @see java.util.AbstractCollection#size()
      */
     @Override
     public int size() {
         return buff.size();
     }
 
-    /* (non-Javadoc)
+    /*
+     * (non-Javadoc)
+     * 
      * @see java.util.AbstractCollection#isEmpty()
      */
     @Override
     public boolean isEmpty() {
         return buff.isEmpty();
     }
-    
+
     @Override
     public void clear() {
         buff.clear();
     }
 
     /**
      * Gets the buffered.
-     *
+     * 
      * @return the buffered
      */
     public List<E> getBuffered() {
@@ -102,40 +121,42 @@ public List<E> getBuffered() {
 
     /**
      * The Class ScheduleConsumer.
-     *
+     * 
      * @author <a href="mailto:[email protected]">Janith Bandara</a>
      */
     public class ScheduleConsumer extends TimerTask {
 
-        /* (non-Javadoc)
+        /*
+         * (non-Javadoc)
+         * 
          * @see java.util.TimerTask#run()
          */
         @Override
         public void run() {
             if (!isEmpty()) {
                 listener.accept(getBuffered());
-            }  
+            }
         }
 
     }
 
     /**
-     * The listener interface for receiving buffered events.
-     * The class that is interested in processing a buffered
-     * event implements this interface, and the object created
-     * with that class is registered with a component using the
-     * component's addBufferedListener method. When
-     * the buffered event occurs, that object's appropriate
-     * method is invoked.
-     *
-     * @param <E> the element type
+     * The listener interface for receiving buffered events. The class that is
+     * interested in processing a buffered event implements this interface, and
+     * the object created with that class is registered with a component using
+     * the component's addBufferedListener method. When the buffered event
+     * occurs, that object's appropriate method is invoked.
+     * 
+     * @param <E>
+     *            the element type
      */
     public interface BufferedListener<E> {
-        
+
         /**
          * Accept.
-         *
-         * @param buffered list
+         * 
+         * @param buffered
+         *            list
          */
         void accept(List<E> buffered);
     }

src/test/java/org/audit4j/core/util/ConcurrentTimelyBufferedArrayListTest.java

@@ -0,0 +1,24 @@
+package org.audit4j.core.util;
+
+import java.util.List;
+
+import org.audit4j.core.util.ConcurrentTimelyBufferedArrayList.BufferedListener;
+import org.junit.Test;
+
+public class ConcurrentTimelyBufferedArrayListTest {
+
+    @Test
+    public void testList() {
+        ConcurrentTimelyBufferedArrayList<String> list = new ConcurrentTimelyBufferedArrayList<>(10,
+                new BufferedListener<String>() {
+                    @Override
+                    public void accept(List<String> buffered) {
+                        System.out.println(buffered.toString());
+                    }
+                });
+        
+        list.add("1");
+        list.add("2");
+        list.add("3");
+    }
+}