Wrap receiving with custom logic

[0exp]

• See README.md
• See CHANGELOG.md

Example (concurrent receiving):

receive 'User', to_table: :users do
   wrap_receiving do |data, receiving|
      id = data.event_data[:id] if data.destroy? 
      id = data.event_data.values.first.first[:id] if data.update? # see README.md :D

      AnyLocking.lock("my-interesting-lock-#{id}", &receiving)
   end
end