diff --git a/flume-core/src/main/java/com/cloudera/flume/handlers/syslog/SyslogTcpSourceThreads.java b/flume-core/src/main/java/com/cloudera/flume/handlers/syslog/SyslogTcpSourceThreads.java
index aa51d6d..d139a32 100644
--- a/flume-core/src/main/java/com/cloudera/flume/handlers/syslog/SyslogTcpSourceThreads.java
+++ b/flume-core/src/main/java/com/cloudera/flume/handlers/syslog/SyslogTcpSourceThreads.java
@@ -59,7 +59,7 @@ public class SyslogTcpSourceThreads extends EventSource.Base {
 
   final public static int SYSLOG_TCP_PORT = 514;
   final int port;
-  final LinkedBlockingQueue<Event> eventsQ = new LinkedBlockingQueue<Event>();
+  final LinkedBlockingQueue<Event> eventsQ = new LinkedBlockingQueue<Event>(100000);
   final List<ReaderThread> readers = Collections
       .synchronizedList(new ArrayList<ReaderThread>());
   final AtomicLong rejects = new AtomicLong();