Contents

module Phobos
  module Handler
    def self.included(base)
      base.extend(ClassMethods)
    end

    def consume(payload, metadata)
      raise NotImplementedError
    end

    module ClassMethods
      def start(kafka_client)
      end

      def stop
      end

      def around_consume(payload, metadata)
        yield
      end
    end
  end
end

Version data entries

8 entries across 8 versions & 1 rubygems

Version	Path
phobos-1.4.2	lib/phobos/handler.rb
phobos-1.4.1	lib/phobos/handler.rb
phobos-1.4.0	lib/phobos/handler.rb
phobos-1.3.0	lib/phobos/handler.rb
phobos-1.2.1	lib/phobos/handler.rb
phobos-1.2.0	lib/phobos/handler.rb
phobos-1.1.0	lib/phobos/handler.rb
phobos-1.0.0	lib/phobos/handler.rb