Read complete messages from socket before processing
Merge pull request #4 from uber/message_size

Read complete messages from socket before processing