Added json format pub-sub messages for socketstream