Class: OnStomp::Components::Scopes::HeaderScope

Inherits:

Object

• Object
• OnStomp::Components::Scopes::HeaderScope

show all

Includes:

Interfaces::FrameMethods

Defined in:

lib/onstomp/components/scopes/header_scope.rb

Overview

Instance Attribute Summary (collapse)

• - (Object) client readonly

  Returns the value of attribute client.

• - (Object) connection readonly

  Returns the value of attribute connection.

• - (Object) headers readonly

  Returns the value of attribute headers.

Instance Method Summary (collapse)

• - (HeaderScope) initialize(headers, client) constructor

  A new instance of HeaderScope.

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

  Wraps OnStomp::Client#transmit, applying the set of #headers to all frames befor they are delivered 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/header_scope.rb', line 9

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

7
8
9

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

def client
  @client
end

7
8
9

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

def connection
  @connection
end

7
8
9

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

def headers
  @headers
end

21
22
23
24

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

def transmit frame, cbs={}
  frame.headers.reverse_merge!(headers)
  client.transmit frame, cbs
end