misha_cafex v0.0.6 Cafex.Consumer.LogConsumer

A simple Cafex.Consumer implementation.

It just print the message into logger output.

Summary

Types

options()

state()

Functions

consume(message, state)

Callback implementation for Cafex.Consumer.consume/2

init(args)

Callback implementation for Cafex.Consumer.init/1

terminate(state)

Callback implementation for Cafex.Consumer.terminate/1

Types

options :: [{:level, Logger.level}]

state :: options

Functions

consume(message, state)

Specs

consume(Cafex.Protocol.Message.t, state) :: {:ok, state}

Callback implementation for Cafex.Consumer.consume/2.

init(args)

Specs

init(opts :: options) :: {:ok, state}

Callback implementation for Cafex.Consumer.init/1.

terminate(state)

Callback implementation for Cafex.Consumer.terminate/1.