use this as a base for implementing new connections
called to cleanly get rid of connection
# File lib/activemessaging/adapters/base.rb, line 22 def disconnect end
receive a single message from any of the subscribed destinations check each destination once, then sleep for poll_interval adding options,optionally, so a poller can get certain messages (e.g. by priority)
# File lib/activemessaging/adapters/base.rb, line 43 def receive(options={}) end
called after a message is successfully received and processed
# File lib/activemessaging/adapters/base.rb, line 47 def received message, headers={} end
destination_name string, body string, headers hash send a single message to a destination
# File lib/activemessaging/adapters/base.rb, line 37 def send destination_name, message_body, message_headers={} end
destination_name string, headers hash subscribe to listen on a destination
# File lib/activemessaging/adapters/base.rb, line 27 def subscribe destination_name, message_headers={} end
called after a message is successfully received but unsuccessfully processed purpose is to return the message to the destination so receiving and processing and be attempted again
# File lib/activemessaging/adapters/base.rb, line 52 def unreceive message, headers={} end
Generated with the Darkfish Rdoc Generator 2.