Rakefile

require './lib/pubsub_redis'

namespace :ps do
  task :chat do
    puts 'starting chat client'

    PubSubRedis::ChatClient.new.run
  end

  task :broker do
    puts 'Broker started on default settings'
    puts 'localhost:20000'

    PubSubRedis::Broker.new.run
  end

  task :subscriber_one do
    puts 'sample subscriber one'
    puts "TOPICS: 'cars', 'money', 'girls'"

    listener = PubSubRedis::Subscriber.new do |subscriber|
      subscriber.enroll 'cars'
      subscriber.enroll 'money'
      subscriber.enroll 'girls'
    end

    listener.listen do |message|
      something = 1 + 1

      puts "[#{something}] MODIFIED MESSAGE #{message}"
    end
  end

  task :subscriber_two do
    puts 'sample subscriber two'
    puts "TOPICS: 'money'"

    listener = PubSubRedis::Subscriber.new
    listener.enroll 'money'

    listener.listen
  end

  task :publisher do
    puts 'sample Publisher'

    publisher = PubSubRedis::Publisher.new

    publisher.execute(topic: 'money', body: 'money, money, money')
    publisher.execute(topic: 'cars', body: 'I like cars!!')
  end
end