You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flume.apache.org by es...@apache.org on 2011/08/12 02:47:51 UTC
svn commit: r1156899 - in /incubator/flume/branches/flume-728/flume-ng-core/src: main/java/org/apache/flume/sink/ main/java/org/apache/flume/source/ test/java/org/apache/flume/sink/ test/java/org/apache/flume/source/

Author: esammer
Date: Fri Aug 12 00:47:51 2011
New Revision: 1156899

URL: http://svn.apache.org/viewvc?rev=1156899&view=rev
Log:
- Updated to logger, null, and seq gen sources / sinks to conform to the changed interface (and exception).

Modified:
    incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/sink/LoggerSink.java
    incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/sink/NullSink.java
    incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/source/SequenceGeneratorSource.java
    incubator/flume/branches/flume-728/flume-ng-core/src/test/java/org/apache/flume/sink/TestLoggerSink.java
    incubator/flume/branches/flume-728/flume-ng-core/src/test/java/org/apache/flume/source/TestSequenceGeneratorSource.java

Modified: incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/sink/LoggerSink.java
URL: http://svn.apache.org/viewvc/incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/sink/LoggerSink.java?rev=1156899&r1=1156898&r2=1156899&view=diff
==============================================================================
--- incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/sink/LoggerSink.java (original)
+++ incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/sink/LoggerSink.java Fri Aug 12 00:47:51 2011
@@ -2,7 +2,7 @@ package org.apache.flume.sink;
 
 import org.apache.flume.core.Context;
 import org.apache.flume.core.Event;
-import org.apache.flume.core.MessageDeliveryException;
+import org.apache.flume.core.EventDeliveryException;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
@@ -13,7 +13,7 @@ public class LoggerSink extends Abstract
 
   @Override
   public void append(Context context, Event<?> event)
-      throws InterruptedException, MessageDeliveryException {
+      throws InterruptedException, EventDeliveryException {
 
     logger.info("event:{}", event);
   }

Modified: incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/sink/NullSink.java
URL: http://svn.apache.org/viewvc/incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/sink/NullSink.java?rev=1156899&r1=1156898&r2=1156899&view=diff
==============================================================================
--- incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/sink/NullSink.java (original)
+++ incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/sink/NullSink.java Fri Aug 12 00:47:51 2011
@@ -2,13 +2,13 @@ package org.apache.flume.sink;
 
 import org.apache.flume.core.Context;
 import org.apache.flume.core.Event;
-import org.apache.flume.core.MessageDeliveryException;
+import org.apache.flume.core.EventDeliveryException;
 
 public class NullSink extends AbstractEventSink {
 
   @Override
   public void append(Context context, Event<?> event)
-      throws InterruptedException, MessageDeliveryException {
+      throws InterruptedException, EventDeliveryException {
 
     /* We purposefully do absolutely nothing. */
 

Modified: incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/source/SequenceGeneratorSource.java
URL: http://svn.apache.org/viewvc/incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/source/SequenceGeneratorSource.java?rev=1156899&r1=1156898&r2=1156899&view=diff
==============================================================================
--- incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/source/SequenceGeneratorSource.java (original)
+++ incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/source/SequenceGeneratorSource.java Fri Aug 12 00:47:51 2011
@@ -2,7 +2,7 @@ package org.apache.flume.source;
 
 import org.apache.flume.core.Context;
 import org.apache.flume.core.Event;
-import org.apache.flume.core.MessageDeliveryException;
+import org.apache.flume.core.EventDeliveryException;
 import org.apache.flume.core.SimpleEvent;
 
 public class SequenceGeneratorSource extends AbstractEventSource {
@@ -11,7 +11,7 @@ public class SequenceGeneratorSource ext
 
   @Override
   public Event<?> next(Context context) throws InterruptedException,
-      MessageDeliveryException {
+      EventDeliveryException {
 
     Event<Long> event = new SimpleEvent<Long>();
 

Modified: incubator/flume/branches/flume-728/flume-ng-core/src/test/java/org/apache/flume/sink/TestLoggerSink.java
URL: http://svn.apache.org/viewvc/incubator/flume/branches/flume-728/flume-ng-core/src/test/java/org/apache/flume/sink/TestLoggerSink.java?rev=1156899&r1=1156898&r2=1156899&view=diff
==============================================================================
--- incubator/flume/branches/flume-728/flume-ng-core/src/test/java/org/apache/flume/sink/TestLoggerSink.java (original)
+++ incubator/flume/branches/flume-728/flume-ng-core/src/test/java/org/apache/flume/sink/TestLoggerSink.java Fri Aug 12 00:47:51 2011
@@ -1,7 +1,7 @@
 package org.apache.flume.sink;
 
 import org.apache.flume.core.Context;
-import org.apache.flume.core.MessageDeliveryException;
+import org.apache.flume.core.EventDeliveryException;
 import org.apache.flume.core.util.EventBuilder;
 import org.apache.flume.lifecycle.LifecycleException;
 import org.junit.Before;
@@ -21,7 +21,7 @@ public class TestLoggerSink {
    */
   @Test
   public void testAppend() throws InterruptedException, LifecycleException,
-      MessageDeliveryException {
+      EventDeliveryException {
 
     Context context = new Context();
 

Modified: incubator/flume/branches/flume-728/flume-ng-core/src/test/java/org/apache/flume/source/TestSequenceGeneratorSource.java
URL: http://svn.apache.org/viewvc/incubator/flume/branches/flume-728/flume-ng-core/src/test/java/org/apache/flume/source/TestSequenceGeneratorSource.java?rev=1156899&r1=1156898&r2=1156899&view=diff
==============================================================================
--- incubator/flume/branches/flume-728/flume-ng-core/src/test/java/org/apache/flume/source/TestSequenceGeneratorSource.java (original)
+++ incubator/flume/branches/flume-728/flume-ng-core/src/test/java/org/apache/flume/source/TestSequenceGeneratorSource.java Fri Aug 12 00:47:51 2011
@@ -3,7 +3,7 @@ package org.apache.flume.source;
 import org.apache.flume.core.Context;
 import org.apache.flume.core.Event;
 import org.apache.flume.core.EventSource;
-import org.apache.flume.core.MessageDeliveryException;
+import org.apache.flume.core.EventDeliveryException;
 import org.apache.flume.lifecycle.LifecycleException;
 import org.junit.Assert;
 import org.junit.Before;
@@ -20,7 +20,7 @@ public class TestSequenceGeneratorSource
 
   @Test
   public void testNext() throws InterruptedException, LifecycleException,
-      MessageDeliveryException {
+      EventDeliveryException {
 
     Context context = new Context();