diff --git a/lib/lumberjack/server.rb b/lib/lumberjack/server.rb
index 4b753a1f..58c2ebdd 100644
--- a/lib/lumberjack/server.rb
+++ b/lib/lumberjack/server.rb
@@ -241,7 +241,7 @@ def window_size(size)
     end
 
     def data(sequence, map, &block)
-      block.call(map)
+      block.call(map, @fd.peeraddr[3])
       if (sequence - @last_ack) >= @window_size
         @fd.syswrite(["1A", sequence].pack("A*N"))
         @last_ack = sequence