Class: RServiceBus::Audit

Inherits:
Object
  • Object
show all
Defined in:
lib/rservicebus/Audit.rb

Instance Method Summary collapse

Constructor Details

#initialize(mq) ⇒ Audit

Returns a new instance of Audit.



5
6
7
8
9
10
11
12
13
14
15
 
# File 'lib/rservicebus/Audit.rb', line 5

def initialize( mq )
    @mq = mq
    auditQueueName = RServiceBus.getValue('AUDIT_QUEUE_NAME')
    if auditQueueName.nil? then
            @forwardSentMessagesTo = RServiceBus.getValue('FORWARD_SENT_MESSAGES_TO')
            @forwardReceivedMessagesTo = RServiceBus.getValue('FORWARD_RECEIVED_MESSAGES_TO')
        else
            @forwardSentMessagesTo = auditQueueName
            @forwardReceivedMessagesTo = auditQueueName
    end
end

Instance Method Details

#auditIncoming(obj) ⇒ Object 



26
27
28
29
30
 
# File 'lib/rservicebus/Audit.rb', line 26

def auditIncoming( obj )
  unless @forwardReceivedMessagesTo.nil? then
    self.auditToQueue(obj)
  end
end

#auditOutgoing(obj) ⇒ Object 



21
22
23
24
25
 
# File 'lib/rservicebus/Audit.rb', line 21

def auditOutgoing( obj )
  unless @forwardSentMessagesTo.nil? then
    self.auditToQueue(obj)
  end
end

#auditToQueue(obj) ⇒ Object 



17
18
19
 
# File 'lib/rservicebus/Audit.rb', line 17

def auditToQueue( obj )
    @mq.sendMsg(obj, @forwardSentMessagesTo)
end