incubator-kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jun...@apache.org
Subject svn commit: r1211747 - /incubator/kafka/trunk/core/src/main/scala/kafka/producer/async/ProducerSendThread.scala
Date Thu, 08 Dec 2011 02:38:47 GMT
Author: junrao
Date: Thu Dec  8 02:38:46 2011
New Revision: 1211747

URL: http://svn.apache.org/viewvc?rev=1211747&view=rev
Log:
trivial change to catch all throwables in ProducerSendThread

Modified:
    incubator/kafka/trunk/core/src/main/scala/kafka/producer/async/ProducerSendThread.scala

Modified: incubator/kafka/trunk/core/src/main/scala/kafka/producer/async/ProducerSendThread.scala
URL: http://svn.apache.org/viewvc/incubator/kafka/trunk/core/src/main/scala/kafka/producer/async/ProducerSendThread.scala?rev=1211747&r1=1211746&r2=1211747&view=diff
==============================================================================
--- incubator/kafka/trunk/core/src/main/scala/kafka/producer/async/ProducerSendThread.scala
(original)
+++ incubator/kafka/trunk/core/src/main/scala/kafka/producer/async/ProducerSendThread.scala
Thu Dec  8 02:38:46 2011
@@ -47,7 +47,7 @@ private[async] class ProducerSendThread[
         tryToHandle(remainingEvents)
       }
     }catch {
-      case e: Exception => error("Error in sending events: ", e)
+      case e => error("Error in sending events: ", e)
     }finally {
       shutdownLatch.countDown
     }



Mime
View raw message