Написать структуру json, на обмен сообщениями между очередью событий и кончным обработчиком, входящий и исходящий json
