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:48 UTC
svn commit: r1156898 - in /incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume: sink/AbstractEventSink.java source/AbstractEventSource.java

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

URL: http://svn.apache.org/viewvc?rev=1156898&view=rev
Log:
- Updated AbstractEvent{Source,Sink} to use new EventDeliveryException.

Modified:
    incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/sink/AbstractEventSink.java
    incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/source/AbstractEventSource.java

Modified: incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/sink/AbstractEventSink.java
URL: http://svn.apache.org/viewvc/incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/sink/AbstractEventSink.java?rev=1156898&r1=1156897&r2=1156898&view=diff
==============================================================================
--- incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/sink/AbstractEventSink.java (original)
+++ incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/sink/AbstractEventSink.java Fri Aug 12 00:47:47 2011
@@ -3,7 +3,7 @@ package org.apache.flume.sink;
 import org.apache.flume.core.Context;
 import org.apache.flume.core.Event;
 import org.apache.flume.core.EventSink;
-import org.apache.flume.core.MessageDeliveryException;
+import org.apache.flume.core.EventDeliveryException;
 import org.apache.flume.lifecycle.LifecycleException;
 
 abstract public class AbstractEventSink implements EventSink {
@@ -16,7 +16,7 @@ abstract public class AbstractEventSink 
 
   @Override
   abstract public void append(Context context, Event<?> event)
-      throws InterruptedException, MessageDeliveryException;
+      throws InterruptedException, EventDeliveryException;
 
   @Override
   public void close(Context context) throws InterruptedException,

Modified: incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/source/AbstractEventSource.java
URL: http://svn.apache.org/viewvc/incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/source/AbstractEventSource.java?rev=1156898&r1=1156897&r2=1156898&view=diff
==============================================================================
--- incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/source/AbstractEventSource.java (original)
+++ incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/source/AbstractEventSource.java Fri Aug 12 00:47:47 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;
 
 abstract public class AbstractEventSource implements EventSource {
 
@@ -14,7 +14,7 @@ abstract public class AbstractEventSourc
 
   @Override
   abstract public Event<?> next(Context context) throws InterruptedException,
-      MessageDeliveryException;
+      EventDeliveryException;
 
   @Override
   public void close(Context context) throws InterruptedException {