Packages

brook

0.4.2
0.6.0 0.5.1 0.5.0 0.4.10 0.4.9 0.4.8 0.4.7 0.4.6 0.4.5 0.4.4 0.4.3 0.4.2 0.4.1 0.4.0 0.3.2 0.3.1 0.3.0 0.2.1 0.2.0 0.1.3 0.1.2 0.1.1

Brook provides an event stream client interface for distributed applications. Brook sends and receives messages with the event stream via a driver module and persists an application-specific view of the event stream via a storage module.

HexDocs

Current section

Files

Jump to
Readme
22 Versions
3 Dependencies
Dependants
Files
Activity
brook lib brook driver kafka handler.ex
Raw

lib/brook/driver/kafka/handler.ex 

defmodule Brook.Driver.Kafka.Handler do

  @moduledoc """

  Implements the Elsa message handler behaviour for

  the Brook Kafka driver.

  """

  use Elsa.Consumer.MessageHandler

  require Logger



  @doc """

  Takes a list of Kafka messages consumed by Elsa and

  processes each with Brook.

  """

  @spec handle_messages([term()]) :: :ack

  def handle_messages(messages, state) do

    messages

    |> Enum.map(fn message -> message.value end)

    |> Enum.each(&Brook.Event.process(state.instance, &1))



    {:ack, state}

  end

end