Publisher abstraction for sending message using several message broker

publisher.rb

class Publisher
  attr_accessor :strategy
  
  def initialize(strategy)
    @strategy = strategy
  end
  
  def publish(data)
    @strategy.call(data)
  end
  
  class Strategy
    def call(data)
      raise NotImplementedError, "#{self.class} has no implementation method '#{__method__}'"
    end
  end
  
  # in case you want to add more strategy, just inherit call method from Strategy class and write your own logic
  # to call the producer from message broker
  
  class KafkaStrategy < Strategy
    def call(data)
      # implement some logic for sending message using Apache Kafka here...
    end
  end
  
  class GooglePubSubStrategy < Strategy
    def call(data)
      # implement some logic for sending message using Google Pub Sub here...
    end
  end
end