Class: RosettaQueue::Gateway::StompAdapterProxy

Inherits:
Object
  • Object
show all
Defined in:
lib/rosetta_queue/adapters/stomp.rb

Instance Method Summary collapse

Constructor Details

#initialize(adapter, msg) ⇒ StompAdapterProxy

Returns a new instance of StompAdapterProxy.



78
79
80
# File 'lib/rosetta_queue/adapters/stomp.rb', line 78

def initialize(adapter, msg)
  @adapter, @msg = adapter, msg
end

Instance Method Details

#ackObject



82
83
84
# File 'lib/rosetta_queue/adapters/stomp.rb', line 82

def ack
  @adapter.ack(@msg)
end