Commit d541e967 authored by guus's avatar guus

Capping queue size (OF-77)

git-svn-id: http://svn.igniterealtime.org/svn/repos/openfire/trunk@11376 b35dd754-fafc-0310-a699-88a17e54d16e
parent 99029394
...@@ -49,7 +49,7 @@ public class OutgoingServerSocketReader { ...@@ -49,7 +49,7 @@ public class OutgoingServerSocketReader {
/** /**
* Queue that holds the elements read by the XMPPPacketReader. * Queue that holds the elements read by the XMPPPacketReader.
*/ */
private BlockingQueue<Element> elements = new LinkedBlockingQueue<Element>(); private BlockingQueue<Element> elements = new LinkedBlockingQueue<Element>(10000);
public OutgoingServerSocketReader(XMPPPacketReader reader) { public OutgoingServerSocketReader(XMPPPacketReader reader) {
this.reader = reader; this.reader = reader;
......
...@@ -56,7 +56,7 @@ public class OutgoingSessionPromise implements RoutableChannelHandler { ...@@ -56,7 +56,7 @@ public class OutgoingSessionPromise implements RoutableChannelHandler {
/** /**
* Queue that holds the packets pending to be sent to remote servers. * Queue that holds the packets pending to be sent to remote servers.
*/ */
private BlockingQueue<Packet> packets = new LinkedBlockingQueue<Packet>(); private BlockingQueue<Packet> packets = new LinkedBlockingQueue<Packet>(10000);
/** /**
* Pool of threads that will create outgoing sessions to remote servers and send * Pool of threads that will create outgoing sessions to remote servers and send
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment