svn commit: r1391673 - in /logging/log4j/log4j2/trunk/flume-ng/src/main/java/org/apache/logging/log4j/flume/appender: FlumeAvroManager.java FlumeEmbeddedManager.java FlumeEvent.java

[ggregory]

Author: ggregory
Date: Fri Sep 28 21:58:37 2012
New Revision: 1391673

URL: http://svn.apache.org/viewvc?rev=1391673&view=rev
Log:
Add missing '@Override' annotations (Java 5 level)

Modified:
    
logging/log4j/log4j2/trunk/flume-ng/src/main/java/org/apache/logging/log4j/flume/appender/FlumeAvroManager.java
    
logging/log4j/log4j2/trunk/flume-ng/src/main/java/org/apache/logging/log4j/flume/appender/FlumeEmbeddedManager.java
    
logging/log4j/log4j2/trunk/flume-ng/src/main/java/org/apache/logging/log4j/flume/appender/FlumeEvent.java

Modified: 
logging/log4j/log4j2/trunk/flume-ng/src/main/java/org/apache/logging/log4j/flume/appender/FlumeAvroManager.java
URL: 
http://svn.apache.org/viewvc/logging/log4j/log4j2/trunk/flume-ng/src/main/java/org/apache/logging/log4j/flume/appender/FlumeAvroManager.java?rev=1391673&r1=1391672&r2=1391673&view=diff
==============================================================================
--- 
logging/log4j/log4j2/trunk/flume-ng/src/main/java/org/apache/logging/log4j/flume/appender/FlumeAvroManager.java
 (original)
+++ 
logging/log4j/log4j2/trunk/flume-ng/src/main/java/org/apache/logging/log4j/flume/appender/FlumeAvroManager.java
 Fri Sep 28 21:58:37 2012
@@ -118,6 +118,7 @@ public class FlumeAvroManager extends Fl
         return current;
     }
 
+    @Override
     public synchronized void send(FlumeEvent event, int delay, int retries)  {
         if (delay == 0) {
             delay = DEFAULT_RECONNECTION_DELAY;

Modified: 
logging/log4j/log4j2/trunk/flume-ng/src/main/java/org/apache/logging/log4j/flume/appender/FlumeEmbeddedManager.java
URL: 
http://svn.apache.org/viewvc/logging/log4j/log4j2/trunk/flume-ng/src/main/java/org/apache/logging/log4j/flume/appender/FlumeEmbeddedManager.java?rev=1391673&r1=1391672&r2=1391673&view=diff
==============================================================================
--- 
logging/log4j/log4j2/trunk/flume-ng/src/main/java/org/apache/logging/log4j/flume/appender/FlumeEmbeddedManager.java
 (original)
+++ 
logging/log4j/log4j2/trunk/flume-ng/src/main/java/org/apache/logging/log4j/flume/appender/FlumeEmbeddedManager.java
 Fri Sep 28 21:58:37 2012
@@ -126,6 +126,7 @@ public class FlumeEmbeddedManager extend
             new FactoryData(name, agents, properties, batchSize, dataDir));
     }
 
+    @Override
     public void send(FlumeEvent event, int delay, int retries) {
         source.send(event);
     }

Modified: 
logging/log4j/log4j2/trunk/flume-ng/src/main/java/org/apache/logging/log4j/flume/appender/FlumeEvent.java
URL: 
http://svn.apache.org/viewvc/logging/log4j/log4j2/trunk/flume-ng/src/main/java/org/apache/logging/log4j/flume/appender/FlumeEvent.java?rev=1391673&r1=1391672&r2=1391673&view=diff
==============================================================================
--- 
logging/log4j/log4j2/trunk/flume-ng/src/main/java/org/apache/logging/log4j/flume/appender/FlumeEvent.java
 (original)
+++ 
logging/log4j/log4j2/trunk/flume-ng/src/main/java/org/apache/logging/log4j/flume/appender/FlumeEvent.java
 Fri Sep 28 21:58:37 2012
@@ -156,6 +156,7 @@ public class FlumeEvent extends SimpleEv
      * Set the body in the event.
      * @param body The body to add to the event.
      */
+    @Override
     public void setBody(byte[] body) {
         if (body == null || body.length == 0) {
             super.setBody(new byte[0]);