I have events published from axon to a fanout exchange in rabbitmq. I have a listener to update the read store (neo4j) but I have also have other stores like elasticsearch that need to be updated to provide searching.
I am thinking to use a nodejs server to listen to one of the other queues and update elasticsearch. The event that I received from axon is of the following structure.
$342c42ff-582d-4e3c-bb97-b6b5e71788b62015-04-24T16:52:30.964+01:00$384eb99e-47ee-89e9-ffff-4929279dcf8c2com.xx.group.domain.events.GroupCreatedEvent[<com.xxx.group.domain.events.GroupCreatedEvent>384eb99e-47ee-89e9-ffff-4929279dcf8cxxx Everattxxx.comNotes for the group4sdadasdatrue38e3facf-99f2-4080-b862-3ac366b35afc</com.xxx.group.domain.events.GroupCreatedEvent>
Clearly I am interested in serializedpayload but why am I getting invalid structure from the event?