module FayeServer

Attributes

messaging_server[RW]

messaging_server_options[RW]

messaging_server_port[RW]

messaging_server_thread[RW]

Public Instance Methods

publish(options={}) click to toggle source

Publish a message to a given channel Requres a :channel, and a :message

# File lib/faye-server/faye_server.rb, line 27
def publish(options={})
        raise 'No Channel Provided' if !options[:channel]
        raise 'No Message Provided' if !options[:message]
        self.messaging_server.get_client.publish(options[:channel], options[:message])
end

start(options={}) click to toggle source

Starts the Faye Server in a new thread

# File lib/faye-server/faye_server.rb, line 5
def start(options={})
        raise 'Already Running' if self.messaging_server and self.messaging_server_thread.status
        self.messaging_server_thread = Thread.new do
                self.messaging_server = Faye::RackAdapter.new(self.messaging_server_options)
                self.messaging_server.listen(self.messaging_server_port)
        end
end

stop() click to toggle source

Stops Faye Server Somtimes Thin will return that it is wating on a client connection and you need to hit “ctrl-c”

# File lib/faye-server/faye_server.rb, line 15
def stop
        raise 'Not Running' if !self.messaging_server or !self.messaging_server_thread.status
        self.messaging_server.stop
        if self.messaging_server_thread == 'dead'
                true
        else
                false
        end
end