Class: Moleculer::Transporters::Redis

Inherits:

Base

• Object
• Base
• Moleculer::Transporters::Redis

Defined in:

lib/moleculer/transporters/redis.rb

Overview

The Moleculer Redis transporter

Defined Under Namespace

Classes: Publisher, Subscriber

Instance Method Summary

• #initialize(config) ⇒ Redis constructor

  A new instance of Redis.

• #publish(packet) ⇒ Object
• #start ⇒ Object
• #stop ⇒ Object
• #subscribe(channel, &block) ⇒ Object

Constructor Details

#initialize(config) ⇒ Redis

Returns a new instance of Redis.

# File 'lib/moleculer/transporters/redis.rb', line 190

def initialize(config)
  @config = config
end

Instance Method Details

#publish(packet) ⇒ Object

# File 'lib/moleculer/transporters/redis.rb', line 198

def publish(packet)
  publisher.publish(packet)
end

#start ⇒ Object

# File 'lib/moleculer/transporters/redis.rb', line 202

def start
  publisher.connect
  subscriber.connect
end

#stop ⇒ Object

# File 'lib/moleculer/transporters/redis.rb', line 207

def stop
  publisher.disconnect
  subscriber.disconnect
end

#subscribe(channel, &block) ⇒ Object

# File 'lib/moleculer/transporters/redis.rb', line 194

def subscribe(channel, &block)
  subscriber.subscribe(channel, &block)
end