Contents

# frozen_string_literal: true

require_relative "base"

module Moleculer
  module Transporters
    ##
    # The fake transporter is designed to be used in testing. It is simply an in memory queue and should not be used
    # in production.
    class Fake < Base
      def initialize(config)
        super(config)
        # in this case we want to use a class var as this needs to behave like a singleton to mimic how a global
        # transporter functions
        @@subscriptions ||= {} # rubocop:disable Style/ClassVars
        @logger           = config.logger.get_child("[FAKE.TRANSPORTER]")
      end

      def subscribe(channel, &block)
        @@subscriptions[channel] ||= []
        @@subscriptions[channel] << block
      end

      def publish(packet)
        @logger.debug "publishing packet to '#{packet.topic}'", packet.to_h
        @logger.debug "processing #{@@subscriptions[packet.topic].length} callbacks for '#{packet.topic}'"
        @@subscriptions[packet.topic].each { |c| c.call(packet) }
      end

      def start
        true
      end

      def stop
        true
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
moleculer-0.3.0	lib/moleculer/transporters/fake.rb