Contents

module Karafka
  # Namespace for all elements related to requests routing
  module Routing
    # Karafka framework Router for routing incoming messages to proper controllers
    # @note Since Kafka does not provide namespaces or modules for topics, they all have "flat"
    #  structure so all the routes are being stored in a single level array
    class Router
      # @param topic [String] topic based on which we find a proper route
      # @return [Karafka::Router] router instance
      def initialize(topic)
        @topic = topic
      end

      # Builds a controller instance that should handle message from a given topic
      # @return [Karafka::BaseController] base controller descendant instance object
      def build
        controller = route.controller.new
        controller.topic = route.topic
        controller.parser = route.parser
        controller.worker = route.worker
        controller.interchanger = route.interchanger
        controller.responder = route.responder

        controller
      end

      private

      # @return [Karafka::Routing::Route] proper route details
      # @raise [Karafka::Topic::NonMatchingTopicError] raised if topic name does not match
      #   any route defined by user using routes.draw
      def route
        App.routes.find { |route| route.topic == @topic } ||
          raise(Errors::NonMatchingRouteError, @topic)
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
karafka-0.5.0	lib/karafka/routing/router.rb