Class: Qup::Subscriber

Inherits:

Consumer

• Object
• Consumer
• Qup::Subscriber

Defined in:

lib/qup/subscriber.rb

Overview

Public: Receives Messages from a Topic

All Subscribers to a Topic will receive each Message that is published to the Topic.

Instance Attribute Summary

• #name ⇒ Object readonly

  Public: The name of this subscriber.

Instance Method Summary

• #initialize(topic, queue) ⇒ Subscriber constructor

  Public: Create a new Subscriber on a Topic.

• #unsubscribe ⇒ Object

  Public: Remove the Subscriber from the Topic.

Methods inherited from Consumer

#acknowledge, #consume

Constructor Details

#initialize(topic, queue) ⇒ Subscriber

Public: Create a new Subscriber on a Topic

Returns a Subscriber

# File 'lib/qup/subscriber.rb', line 14

def initialize( topic, queue )
  super( queue )
  @topic = topic
  @name  = @queue.name
end

Instance Attribute Details

#name ⇒ Object (readonly)

Public: The name of this subscriber

# File 'lib/qup/subscriber.rb', line 9

def name
  @name
end

Instance Method Details

#unsubscribe ⇒ Object

Public: Remove the Subscriber from the Topic

This just means to destroy the Queue that it is attached to

# File 'lib/qup/subscriber.rb', line 24

def unsubscribe
  @queue.destroy
end