Packages

khafra_search

0.3.0
0.3.3 0.3.1 0.3.0 0.2.1 0.2.0 0.1.6 0.1.5 0.1.4 0.1.3 0.1.2 0.1.1

A search deployment helper library. Aims to easy deployment and monitoring of distributed Manticore & Sphinx in a Linux environment

HexDocs

Current section

Files

Jump to
Readme
11 Versions
9 Dependencies
Dependants
Files
Activity
khafra_search lib khafra queue manage_table_consumer.ex
Raw

lib/khafra/queue/manage_table_consumer.ex 

defmodule Khafra.Queue.ManageTableConsumer do

  use Lapin.Connection



  require Logger



  def handle_deliver(_channel, message) do

    case :erlang.binary_to_term(message.payload) do

      {:record_op, record, operation} ->

        operation.(record)



      {:record_op, operation} ->

        operation.()



      other ->

        Logger.debug(fn -> "Unhandled message: #{inspect(other)}" end)

    end



    :ok

  end

end