Toggle Sidebar
Toggle Theme
Conduit
v0.12.10
Guides
Modules
Exceptions
Mix Tasks
Conduit
Message
Conduit.Message
Top
Summary
Types
assigns/0
body/0
content_encoding/0
content_type/0
correlation_id/0
created_at/0
created_by/0
destination/0
headers/0
message_id/0
private/0
source/0
status/0
t/0
user_id/0
Functions
ack/1
assign/3
assigns/2
delete_header/2
get_fields/1
get_header/2
get_private/2
merge_fields/3
merge_headers/3
nack/1
put_body/2
put_content_encoding/2
put_content_type/2
put_correlation_id/2
put_created_at/2
put_created_by/2
put_destination/2
put_header/3
put_headers/2
put_message_id/2
put_new_correlation_id/2
put_new_destination/2
put_new_message_id/2
put_new_source/2
put_private/3
put_source/2
put_user_id/2
take/2
Broker
Conduit.Broker
Conduit.Broker.DSL
Top
Summary
Functions
configure/1
exchange/2
incoming/2
outgoing/1
pipe_through/1
pipeline/2
plug/2
publish/2
queue/2
subscribe/3
Subscriber
Conduit.Subscriber
Top
Summary
Callbacks
process/2
Plugs
Conduit.Plug
Top
Summary
Types
next/0
opts/0
t/0
Callbacks
__build__/2
call/3
init/1
run/2
Conduit.Plug.AckException
Top
Summary
Functions
call/3
init/1
run/2
Conduit.Plug.Builder
Top
Summary
Types
plug/0
Functions
compile/2
plug/2
Conduit.Plug.CorrelationId
Top
Summary
Functions
call/3
init/1
run/2
Conduit.Plug.CreatedAt
Top
Summary
Functions
call/3
init/1
run/2
Conduit.Plug.CreatedBy
Top
Summary
Functions
call/3
init/1
run/2
Conduit.Plug.DeadLetter
Top
Summary
Functions
call/3
init/1
run/2
Conduit.Plug.Decode
Top
Summary
Functions
call/3
init/1
run/2
Conduit.Plug.Encode
Top
Summary
Functions
call/3
init/1
run/2
Conduit.Plug.Format
Top
Summary
Functions
call/3
init/1
run/2
Conduit.Plug.LogIncoming
Top
Summary
Functions
call/3
init/1
run/2
Conduit.Plug.LogOutgoing
Top
Summary
Functions
call/3
init/1
run/2
Conduit.Plug.MessageActions
Top
Summary
Functions
ack/3
nack/3
put_assigns/3
put_body/3
put_content_encoding/3
put_content_type/3
put_correlation_id/3
put_created_by/3
put_destination/3
put_headers/3
put_message_id/3
put_new_correlation_id/3
put_new_destination/3
put_new_message_id/3
put_new_source/3
put_private/3
put_source/3
put_user_id/3
Conduit.Plug.MessageId
Top
Summary
Functions
call/3
init/1
run/2
Conduit.Plug.NackException
Top
Summary
Functions
call/3
init/1
run/2
Conduit.Plug.Parse
Top
Summary
Functions
call/3
init/1
run/2
Conduit.Plug.Retry
Top
Summary
Functions
call/3
init/1
run/2
Conduit.Plug.Unwrap
Top
Summary
Functions
call/3
init/1
run/2
Conduit.Plug.Wrap
Top
Summary
Functions
call/3
init/1
run/2
Adapter
Conduit.Adapter
Top
Summary
Types
broker/0
config/0
opts/0
subscribers/0
topology/0
Callbacks
publish/3
publish/4
start_link/4
Content Types
Conduit.ContentType
Top
Summary
Functions
format/3
parse/3
Callbacks
format/2
parse/2
Conduit.ContentType.ErlangBinary
Top
Summary
Functions
format/2
parse/2
Conduit.ContentType.JSON
Top
Summary
Functions
format/2
parse/2
Conduit.ContentType.Text
Top
Summary
Functions
format/2
parse/2
Encodings
Conduit.Encoding
Top
Summary
Functions
decode/3
encode/3
Callbacks
decode/2
encode/2
Conduit.Encoding.GZip
Top
Summary
Functions
decode/2
encode/2
Conduit.Encoding.Identity
Top
Summary
Functions
decode/2
encode/2
Testing
Conduit.Test
Top
Summary
Functions
assert_message_publish/1
assert_message_publish/2
assert_message_publish/3
assert_message_publish/4
assert_message_published/1
assert_message_published/2
assert_message_published/3
refute_message_publish/1
refute_message_publish/2
refute_message_publish/3
refute_message_publish/4
refute_message_published/1
refute_message_published/2
refute_message_published/3
Conduit.TestAdapter
Top
Summary
Functions
publish/3
publish/4
Config Structs
Conduit.Pipeline
Top
Summary
Types
name/0
plugs/0
t/0
Functions
new/2
Conduit.PublishRoute
Top
Summary
Types
name/0
opts/0
pipelines/0
t/0
Functions
new/3
Conduit.SubscribeRoute
Top
Summary
Types
name/0
opts/0
pipelines/0
subscriber/0
t/0
Functions
new/4
Conduit.Topology.Exchange
Top
Summary
Types
name/0
opts/0
t/0
Functions
new/2
Conduit.Topology.Queue
Top
Summary
Types
name/0
opts/0
t/0
Functions
new/2
Utils
Conduit.Util
Top
Summary
Types
attempt_function/0
Functions
retry/2
wait_until/2
Conduit v0.12.10
Conduit
View Source
A message queue framework, with support for middleware and multiple adapters.