Class: Connfu::Events

Inherits:

Object

• Object
• Connfu::Events

Defined in:

lib/connfu/events.rb

Overview

This class is used to send Message instances between transport (listener) and dispatcher layers

Instance Method Summary

• #get ⇒ Object

  Returns a message from the queue.

• #initialize ⇒ Events constructor

  Initializer.

• #put(event) ⇒ Object

  Inserts a message in the queue.

Constructor Details

#initialize ⇒ Events

Initializer

# File 'lib/connfu/events.rb', line 9

def initialize
  @queue = Queue.new
end

Instance Method Details

#get ⇒ Object

Returns a message from the queue. It waits until there’s at least one message in the queue and acts as a FIFO queue.

Returns

Connfu::Message instance

# File 'lib/connfu/events.rb', line 19

def get
  @queue.pop
end

#put(event) ⇒ Object

Inserts a message in the queue

Parameters

• event Connfu::Message instance

# File 'lib/connfu/events.rb', line 28

def put(event)
  @queue << event
end