feat(publisher): create publisher consumer if it does not exist yet (…

feat(publisher): create publisher consumer if it does not exist yet (… #1289