Subscribe to queue and call a function f with meta-information and payload.

Example: (subscribe (fn [meta payload] [meta payload]) “statements” {:host “broker” :user “groot” :password “iamgroot”}) (subscribe “statements” {:host “broker”})