Contents

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

    def before_consume(payload)
      payload
    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

6 entries across 6 versions & 1 rubygems

Version	Path
phobos-1.7.2	lib/phobos/handler.rb
phobos-1.7.1	lib/phobos/handler.rb
phobos-1.7.0	lib/phobos/handler.rb
phobos-1.6.1	lib/phobos/handler.rb
phobos-1.6.0	lib/phobos/handler.rb
phobos-1.5.0	lib/phobos/handler.rb