Packages

elsa

0.2.0
1.0.0-rc.3 1.0.0-rc.2 1.0.0-rc.1 0.12.3 0.12.2 0.12.1 0.12.0 0.11.1 0.11.0 0.10.1 0.10.0 0.9.0 0.8.1 0.8.0 0.7.1 0.7.0 0.6.0 0.5.0 0.4.1 0.4.0 0.3.0 0.2.0 0.1.0

Elsa is a full-featured Kafka library written in Elixir and extending the :brod library with additional support from the :kafka_protocol Erlang libraries to provide capabilities not available in :brod.

HexDocs

Current section

Files

Jump to
Readme
23 Versions
1 Dependency
Dependants
Files
Activity
elsa lib elsa consumer message_handler.ex
Raw

lib/elsa/consumer/message_handler.ex 

defmodule Elsa.Consumer.MessageHandler do

  @callback init(term()) :: {:ok, term()}

  @callback handle_messages(term(), term()) :: {:ack, term()} | {:no_ack, term()}

  @callback handle_messages(term()) :: :ack | :no_ack



  defmacro __using__(_opts) do

    quote do

      @behaviour Elsa.Consumer.MessageHandler



      def init(args) do

        {:ok, args}

      end



      def handle_messages(messages, state) do

        result = handle_messages(messages)

        {result, state}

      end



      def handle_messages(messages) do

        :ack

      end



      defoverridable Elsa.Consumer.MessageHandler

    end

  end

end