Fix memory leak by limiting internal message queue size (#63)

* Fix memory leak by limiting internal message queue size

This commit addresses GitHub issue #61 where memory usage keeps increasing
and garbage collection fails, eventually causing node crashes after several days.

Root Cause:
The syslog4j library queues messages internally with no limit by default when
using TCP/SSL protocols. Under high message throughput, this causes unbounded
memory growth leading to OOM errors.

Solution:
1. Added maxQueueSize configuration parameter (default: 500 messages)
2. Set maxQueueSize on all syslog config objects (UDP/TCP/SSL)
3. Made the parameter user-configurable through Graylog UI

The conservative default of 500 prevents memory leaks while still allowing
reasonable buffering. Users experiencing high throughput can tune this value
based on their needs, but should avoid unlimited queuing (-1).

When the queue is full, the plugin will block until space is available,
providing natural backpressure instead of consuming all available memory.

Configuration:
- Default: 500 messages
- Configurable via "Maximum queue size" field in output configuration
- Set to -1 for unlimited (not recommended, will cause OOM)

Fixes #61

🤖 Generated with [Claude Code](https://claude.com/claude-code)

Co-Authored-By: Claude <[email protected]>

* Clarify maxQueueSize field description

Updated the description for maxQueueSize field to clarify its purpose.

* Add maxQueueSize configuration for syslog output

* Fix typo in variable name for UDP config

---------

Co-authored-by: Claude <[email protected]>

Author: huksley

src/main/java/com/wizecore/graylog2/plugin/SyslogOutput.java

@@ -18,6 +18,7 @@
 import org.graylog2.syslog4j.SyslogConfigIF;
 import org.graylog2.syslog4j.SyslogIF;
 import org.graylog2.syslog4j.SyslogRuntimeException;
+import org.graylog2.syslog4j.impl.AbstractSyslogConfigIF;
 import org.graylog2.syslog4j.impl.message.processor.SyslogMessageProcessor;
 import org.graylog2.syslog4j.impl.message.processor.structured.StructuredSyslogMessageProcessor;
 import org.graylog2.syslog4j.impl.net.tcp.TCPNetSyslogConfig;
@@ -92,13 +93,23 @@ public SyslogOutput(@Assisted Stream stream, @Assisted Configuration conf) {
 			format = "plain";
 		}
 
+		int maxQueueSize = 500;
+        String queueSizeStr = conf.getString("maxQueueSize");
+        if (queueSizeStr != null && !queueSizeStr.trim().isEmpty()) {
+            maxQueueSize = Integer.parseInt(queueSizeStr);
+        }
+    
 		log.info("Creating syslog output " + protocol + "://" + host + ":" + port + ", format " + format);
 		SyslogConfigIF config = null;
 		if (protocol.toLowerCase().equals("udp")) {
-			config = new UDPNetSyslogConfig();
+			UDPNetSyslogConfig udpConfig = new UDPNetSyslogConfig();
+            udpConfig.setMaxQueueSize(maxQueueSize);
+            config = udpConfig;
 		} else
 		if (protocol.toLowerCase().equals("tcp")) {
-			config = new TCPNetSyslogConfig();
+			TCPNetSyslogConfig tcpConfig = new TCPNetSyslogConfig();
+            tcpConfig.setMaxQueueSize(maxQueueSize);
+            config = tcpConfig;
 		} else
 		if (protocol.toLowerCase().equals("tcp-ssl")) {
             CustomSSLSyslogConfig sslConfig = new CustomSSLSyslogConfig();
@@ -128,6 +139,7 @@ public SyslogOutput(@Assisted Stream stream, @Assisted Configuration conf) {
 			sslConfig.setKeyStorePassword(ksp);
 			sslConfig.setTrustStore(ts);
 			sslConfig.setTrustStorePassword(tsp);
+            sslConfig.setMaxQueueSize(maxQueueSize);
 		} else {
 			throw new IllegalArgumentException("Unknown protocol: " + protocol);
 		}
@@ -320,6 +332,8 @@ public ConfigurationRequest getRequestedConfiguration() {
 
 			configurationRequest.addField(new TextField("maxlen", "Maximum message length", "", "Maximum message (body) length. Longer messages will be truncated. If not specified defaults to 16384 bytes.", ConfigurationField.Optional.OPTIONAL));
 
+			configurationRequest.addField(new TextField("maxQueueSize", "Maximum queue size", "500", "Maximum number of messages to queue internally. Set to -1 for unlimited. Default is 500.", ConfigurationField.Optional.OPTIONAL));
+
 			configurationRequest.addField(new TextField("keystore", "Key store", "", "Path to Java keystore (required for SSL over TCP). Must contain private key and cert for this client.", ConfigurationField.Optional.OPTIONAL));
 			configurationRequest.addField(new TextField("keystorePassword", "Key store password", "", "", ConfigurationField.Optional.OPTIONAL));