Support event drive for work-agent as a prototype (Consumer)

1. 1. Status feedback
   2. Re-sync the message from mqtt (restart the pod / reconnect)
   3. Update deletion strategy
   4. Need to collect how many messages we need for a normal process and what is the size for message

=========================

work-agent to integrate with cloudevents (TODO)