Use blocking collections and observation on service side

[ForNeVeR]

http://stackoverflow.com/questions/3030649/how-to-use-iobservable-iobserver-with-concurrentqueue-or-concurrentstack