From 9122befdfb4df290aae5a33dd0e69c870a58dda4 Mon Sep 17 00:00:00 2001
From: Shay Banon <kimchy@gmail.com>
Date: Thu, 4 Oct 2012 20:33:25 +0200
Subject: [PATCH] add logging on the size of message received

---
 src/main/java/org/elasticsearch/bulk/udp/BulkUdpService.java | 1 +
 1 file changed, 1 insertion(+)

diff --git a/src/main/java/org/elasticsearch/bulk/udp/BulkUdpService.java b/src/main/java/org/elasticsearch/bulk/udp/BulkUdpService.java
index 7fac387cae9..78ca2ff4295 100644
--- a/src/main/java/org/elasticsearch/bulk/udp/BulkUdpService.java
+++ b/src/main/java/org/elasticsearch/bulk/udp/BulkUdpService.java
@@ -176,6 +176,7 @@ public class BulkUdpService extends AbstractLifecycleComponent<BulkUdpService> {
         @Override
         public void messageReceived(ChannelHandlerContext ctx, MessageEvent e) throws Exception {
             ChannelBuffer buffer = (ChannelBuffer) e.getMessage();
+            logger.trace("received message size [{}]", buffer.readableBytes());
             try {
                 bulkProcessor.add(new ChannelBufferBytesReference(buffer), false, null, null);
             } catch (Exception e1) {