retunrs a hq connection, and starts go routine that lisens to incoming WS messages grouping them to correct queue.

TODO make this automaticly set the lenght of the message.

parsing messsage to FLEX protocl.

TODO.

TODO.

Event stream is just a wrapper arround chan for nicer checking if chan is closed plus makes refactors easier.

represents connection to broker and ques for topics.

represent expected messae coming in from and coming to message broker lenght does not need to be provided if NewMesasge() is used.

Que struct representing the Que in the actuall message broker allows for lisineing to incoming event comming trough ws connection and groups them toghether to correct que.