Class Skynet::MessageQueue
In: lib/skynet/skynet_message_queue.rb
Parent: Object

This class is the interface to the Skynet Message Queue.

Methods

adapter   adapter_class   ansi_clear   get_worker_version   increment_worker_version   list   message_fields   message_queue_proxy_class   message_queue_proxy_class   mq   new   print_stats   set_worker_version   start_or_connect   version_active?  

Included Modules

SkynetDebugger

Public Class methods

Public Instance methods

get_worker_version()

Retrieves the current worker version

increment_worker_version()

Increments the current worker version (causing workers to restart)

set_worker_version(version)

Sets the current worker version (causing workers to restart)

version_active?(version,queue_id=0)

Is this version still active in the queue?

[Validate]