Необходимо доработать существующую прогу, чтобы она могла исполнять следующий функционал:

Внимание! Это Java SDK

1. Слушать поток по ключевым словам

2. Полученные контент объекты сохранять в монгодб (так же создать коннект к Mongo и Rabbit)

3. В rabbitmq на каждый такой полученный объект создавать задачу со ссылкой или айди на полученный объект в Mongo.


Туда надо добавить задание (которое прослушает другой сервис и исполнит его).

В Rabbit добавляем задачу, в формате: задачаИД;айди_поста_добавленного_в_монгу.


P.S. Первый пункт выполнен, поток имеется ввиду поток данных с streaming_api_vk.