Packages

ulfnet_amqpx

1.1.0
1.1.0 1.0.0

Higher-level functionality on top of AMQP

HexDocs

Current section

Files

Jump to
Readme
2 Versions
4 Dependencies
0 Dependants
Files
Activity
ulfnet_amqpx lib amqpx publisher storage.ex
Raw

lib/amqpx/publisher/storage.ex 

defmodule AMQPX.Publisher.Storage do

  @callback init(opts :: any()) :: any()

  @callback store(integer(), %AMQPX.Publisher.Record{}, any()) :: any()

  @callback confirm(integer(), boolean(), any()) :: any()

  @callback pending(any()) :: list(%AMQPX.Publisher.Record{})

end