Permalink
Browse files

add logging on the size of message received

  • Loading branch information...
kimchy committed Oct 4, 2012
1 parent 8ea019a commit 9122befdfb4df290aae5a33dd0e69c870a58dda4
Showing with 1 addition and 0 deletions.
  1. +1 −0 src/main/java/org/elasticsearch/bulk/udp/BulkUdpService.java
@@ -176,6 +176,7 @@ protected void doClose() throws ElasticSearchException {
@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) {

0 comments on commit 9122bef

Please sign in to comment.