File tree Expand file tree Collapse file tree 6 files changed +19
-18
lines changed Expand file tree Collapse file tree 6 files changed +19
-18
lines changed Original file line number Diff line number Diff line change 1
1
#!/ usr / bin / env escript
2
- % %! -pz ./_build/default/lib/amqp_client/ebin ./_build/default/lib/credentials_obfuscation/ebin ./_build/default/lib/jsx/ebin ./_build/default/lib/rabbit_common/ebin ./_build/default/lib/recon/ebin
2
+ % %! -pz ./_build/default/lib/amqp_client/ebin ./_build/default/lib/credentials_obfuscation/ebin ./_build/default/lib/jsx/ebin ./_build/default/lib/rabbit_common/ebin ./_build/default/lib/recon/ebin
3
3
4
4
-include_lib (" amqp_client/include/amqp_client.hrl" ).
5
5
@@ -12,9 +12,9 @@ main(Argv) ->
12
12
type = <<" fanout" >>}),
13
13
14
14
Message = case Argv of
15
- [] -> <<" info: Hello World!" >>;
16
- Msg -> list_to_binary (string :join (Msg , " " ))
17
- end ,
15
+ [] -> <<" info: Hello World!" >>;
16
+ Msg -> list_to_binary (string :join (Msg , " " ))
17
+ end ,
18
18
amqp_channel :cast (Channel ,
19
19
# 'basic.publish' {exchange = <<" logs" >>},
20
20
# amqp_msg {payload = Message }),
Original file line number Diff line number Diff line change 1
1
#!/ usr / bin / env escript
2
- % %! -pz ./_build/default/lib/amqp_client/ebin ./_build/default/lib/credentials_obfuscation/ebin ./_build/default/lib/jsx/ebin ./_build/default/lib/rabbit_common/ebin ./_build/default/lib/recon/ebin
2
+ % %! -pz ./_build/default/lib/amqp_client/ebin ./_build/default/lib/credentials_obfuscation/ebin ./_build/default/lib/jsx/ebin ./_build/default/lib/rabbit_common/ebin ./_build/default/lib/recon/ebin
3
3
4
4
-include_lib (" amqp_client/include/amqp_client.hrl" ).
5
5
@@ -21,8 +21,8 @@ main(Argv) ->
21
21
end ,
22
22
amqp_channel :cast (Channel ,
23
23
# 'basic.publish' {
24
- exchange = <<" direct_logs" >>,
25
- routing_key = Severity },
24
+ exchange = <<" direct_logs" >>,
25
+ routing_key = Severity },
26
26
# amqp_msg {payload = Message }),
27
27
io :format (" [x] Sent ~p :~p~n " , [Severity , Message ]),
28
28
ok = amqp_channel :close (Channel ),
Original file line number Diff line number Diff line change 1
1
#!/ usr / bin / env escript
2
- % %! -pz ./_build/default/lib/amqp_client/ebin ./_build/default/lib/credentials_obfuscation/ebin ./_build/default/lib/jsx/ebin ./_build/default/lib/rabbit_common/ebin ./_build/default/lib/recon/ebin
2
+ % %! -pz ./_build/default/lib/amqp_client/ebin ./_build/default/lib/credentials_obfuscation/ebin ./_build/default/lib/jsx/ebin ./_build/default/lib/rabbit_common/ebin ./_build/default/lib/recon/ebin
3
3
4
4
-include_lib (" amqp_client/include/amqp_client.hrl" ).
5
5
@@ -21,8 +21,8 @@ main(Argv) ->
21
21
end ,
22
22
amqp_channel :cast (Channel ,
23
23
# 'basic.publish' {
24
- exchange = <<" topic_logs" >>,
25
- routing_key = RoutingKey },
24
+ exchange = <<" topic_logs" >>,
25
+ routing_key = RoutingKey },
26
26
# amqp_msg {payload = Message }),
27
27
io :format (" [x] Sent ~p :~p~n " , [RoutingKey , Message ]),
28
28
ok = amqp_channel :close (Channel ),
Original file line number Diff line number Diff line change 1
1
#!/ usr / bin / env escript
2
- % %! -pz ./_build/default/lib/amqp_client/ebin ./_build/default/lib/credentials_obfuscation/ebin ./_build/default/lib/jsx/ebin ./_build/default/lib/rabbit_common/ebin ./_build/default/lib/recon/ebin
2
+ % %! -pz ./_build/default/lib/amqp_client/ebin ./_build/default/lib/credentials_obfuscation/ebin ./_build/default/lib/jsx/ebin ./_build/default/lib/rabbit_common/ebin ./_build/default/lib/recon/ebin
3
3
4
4
-include_lib (" amqp_client/include/amqp_client.hrl" ).
5
5
@@ -17,8 +17,8 @@ main(Argv) ->
17
17
end ,
18
18
amqp_channel :cast (Channel ,
19
19
# 'basic.publish' {
20
- exchange = <<" " >>,
21
- routing_key = <<" task_queue" >>},
20
+ exchange = <<" " >>,
21
+ routing_key = <<" task_queue" >>},
22
22
# amqp_msg {props = # 'P_basic' {delivery_mode = 2 },
23
23
payload = Message }),
24
24
io :format (" [x] Sent ~p~n " , [Message ]),
Original file line number Diff line number Diff line change 1
1
#!/ usr / bin / env escript
2
- % %! -pz ./_build/default/lib/amqp_client/ebin ./_build/default/lib/credentials_obfuscation/ebin ./_build/default/lib/jsx/ebin ./_build/default/lib/rabbit_common/ebin ./_build/default/lib/recon/ebin
2
+ % %! -pz ./_build/default/lib/amqp_client/ebin ./_build/default/lib/credentials_obfuscation/ebin ./_build/default/lib/jsx/ebin ./_build/default/lib/rabbit_common/ebin ./_build/default/lib/recon/ebin
3
3
4
4
-include_lib (" amqp_client/include/amqp_client.hrl" ).
5
5
@@ -12,8 +12,8 @@ main(_) ->
12
12
13
13
amqp_channel :cast (Channel ,
14
14
# 'basic.publish' {
15
- exchange = <<" " >>,
16
- routing_key = <<" hello" >>},
15
+ exchange = <<" " >>,
16
+ routing_key = <<" hello" >>},
17
17
# amqp_msg {payload = <<" Hello World!" >>}),
18
18
io :format (" [x] Sent 'Hello World!'~n " ),
19
19
ok = amqp_channel :close (Channel ),
Original file line number Diff line number Diff line change 1
1
#!/ usr / bin / env escript
2
- % %! -pz ./_build/default/lib/amqp_client/ebin ./_build/default/lib/credentials_obfuscation/ebin ./_build/default/lib/jsx/ebin ./_build/default/lib/rabbit_common/ebin ./_build/default/lib/recon/ebin
2
+ % %! -pz ./_build/default/lib/amqp_client/ebin ./_build/default/lib/credentials_obfuscation/ebin ./_build/default/lib/jsx/ebin ./_build/default/lib/rabbit_common/ebin ./_build/default/lib/recon/ebin
3
3
4
4
-include_lib (" amqp_client/include/amqp_client.hrl" ).
5
5
@@ -18,7 +18,8 @@ main(_) ->
18
18
receive
19
19
# 'basic.consume_ok' {} -> ok
20
20
end ,
21
- loop (Channel ).
21
+ loop (Channel ),
22
+ io :format (" GOOD BYE~n " ).
22
23
23
24
loop (Channel ) ->
24
25
receive
You can’t perform that action at this time.
0 commit comments