Smart publish

[Gsantomaggio]

Implement a smart publish, the interface accepts only one message:

func (producer *Producer) Publish(messages message.StreamMessage)

Internally the producer has to:

• aggregate the messages given batch size
• send messages given a timeout: 100 milliseconds
• split the messages in case the frame is to big