lib/activemessaging/adapters/reliable_msg.rb
# destination_name string, headers hash
# subscribe to listen on a destination
# use '/destination-type/name' convetion, like stomp
destination_name string, headers hash
subscribe to listen on a destination
use '/destination-type/name' convetion, like stomp
destination_name string headers hash subscribe to listen on a destination use ' / destination - type / name ' convetion like stomp
def subscribe destination_name, message_headers={}
          get_or_create_destination(destination_name, message_headers)
          if subscriptions.has_key? destination_name
            subscriptions[destination_name].add
          else
            subscriptions[destination_name] = Subscription.new(destination_name, message_headers)
          end
        end
def subscribe destination_name , message_headers = { } get_or_create_destination ( destination_name , message_headers ) if subscriptions . has_key? destination_name subscriptions [ destination_name ] . add else subscriptions [ destination_name ] = Subscription . new ( destination_name , message_headers ) end end
destination_name string, headers hash
subscribe to listen on a destination
use '/destination-type/name' convetion, like stomp
destination_name string headers hash subscribe to listen on a destination use ' / destination - type / name ' convetion like stomp
destination_name
message_headers