You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ju...@apache.org on 2011/12/08 03:38:47 UTC
svn commit: r1211747 -
/incubator/kafka/trunk/core/src/main/scala/kafka/producer/async/ProducerSendThread.scala
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
}