Class: OnStomp::Components::Subscription

Inherits:

Object

• Object
• OnStomp::Components::Subscription

show all

Defined in:

lib/onstomp/components/subscription.rb

Overview

Instance Attribute Summary (collapse)

• - (Object) callback readonly

  Returns the value of attribute callback.

• - (Object) frame readonly

  Returns the value of attribute frame.

Instance Method Summary (collapse)

• - (Object) call(m)

  Invokes the #callback, passing along the supplied MESSAGE frame.

• - (String) destination

  Returns the destination header of the associated SUBSCRIBE frame.

• - (String) id

  Returns the id header of the associated SUBSCRIBE frame.

• - (true, false) include?(m)

  Returns true if this message frame shares the same destination as this subscription, false otherwise.

• - (Subscription) initialize(fr, cb) constructor

  Creates a new subscription.

11
12
13
14

# File 'lib/onstomp/components/subscription.rb', line 11

def initialize(fr, cb)
  @frame = fr
  @callback = cb
end

7
8
9

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

def callback
  @callback
end

7
8
9

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

def frame
  @frame
end

23

# File 'lib/onstomp/components/subscription.rb', line 23

def call(m); callback.call(m); end

20

# File 'lib/onstomp/components/subscription.rb', line 20

def destination; frame[:destination]; end

17

# File 'lib/onstomp/components/subscription.rb', line 17

def id; frame[:id]; end

27
28
29

# File 'lib/onstomp/components/subscription.rb', line 27

def include? m
  self.destination == m[:destination]
end