Class: OnStomp::Components::Scopes::ReceiptScope

Inherits:

Object

• Object
• OnStomp::Components::Scopes::ReceiptScope

show all

Includes:

Interfaces::FrameMethods

Defined in:

lib/onstomp/components/scopes/receipt_scope.rb

Overview

Instance Attribute Summary (collapse)

• - (Object) callback readonly

  Returns the value of attribute callback.

• - (Object) client readonly

  Returns the value of attribute client.

• - (Object) connection readonly

  Returns the value of attribute connection.

Instance Method Summary (collapse)

• - (ReceiptScope) initialize(callback, client) constructor

  A new instance of ReceiptScope.

• - (OnStomp::Components::Frame) transmit(frame, cbs = {})

  Wraps OnStomp::Client#transmit, applying the #callback as a receipt handler for all frames before they are sent to the broker.

Methods included from Interfaces::FrameMethods

#abort, #ack, #beat, #begin, #commit, #disconnect, #nack, #send, #subscribe, #unsubscribe

9
10
11
12
13

# File 'lib/onstomp/components/scopes/receipt_scope.rb', line 9

def initialize callback, client
  @callback = callback
  @client = client
  @connection = client.connection
end

7
8
9

# File 'lib/onstomp/components/scopes/receipt_scope.rb', line 7

def callback
  @callback
end

7
8
9

# File 'lib/onstomp/components/scopes/receipt_scope.rb', line 7

def client
  @client
end

7
8
9

# File 'lib/onstomp/components/scopes/receipt_scope.rb', line 7

def connection
  @connection
end

21
22
23
24

# File 'lib/onstomp/components/scopes/receipt_scope.rb', line 21

def transmit frame, cbs={}
  cbs[:receipt] ||= callback
  client.transmit frame, cbs
end