Class: RServiceBus2::Audit
- Inherits:
-
Object
- Object
- RServiceBus2::Audit
- Defined in:
- lib/rservicebus2/audit.rb
Overview
Audit Class
Instance Method Summary collapse
- #audit_incoming(obj) ⇒ Object
- #audit_outgoing(obj) ⇒ Object
- #audit_to_queue(obj) ⇒ Object
-
#initialize(mq) ⇒ Audit
constructor
A new instance of Audit.
Constructor Details
#initialize(mq) ⇒ Audit
Returns a new instance of Audit.
4 5 6 7 8 9 10 11 12 13 14 |
# File 'lib/rservicebus2/audit.rb', line 4 def initialize(mq) @mq = mq audit_queue_name = RServiceBus2.get_value('AUDIT_QUEUE_NAME') if audit_queue_name.nil? @sent_messages_to = RServiceBus2.get_value('sent_messages_to') @received_messages_to = RServiceBus2.get_value('received_messages_to') else @sent_messages_to = audit_queue_name @received_messages_to = audit_queue_name end end |
Instance Method Details
#audit_incoming(obj) ⇒ Object
24 25 26 |
# File 'lib/rservicebus2/audit.rb', line 24 def audit_incoming(obj) audit_to_queue(obj) unless @received_messages_to.nil? end |
#audit_outgoing(obj) ⇒ Object
20 21 22 |
# File 'lib/rservicebus2/audit.rb', line 20 def audit_outgoing(obj) audit_to_queue(obj) unless @sent_messages_to.nil? end |
#audit_to_queue(obj) ⇒ Object
16 17 18 |
# File 'lib/rservicebus2/audit.rb', line 16 def audit_to_queue(obj) @mq.send_msg(obj, @sent_messages_to) end |