File tree 2 files changed +3
-3
lines changed
2 files changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -45,7 +45,7 @@ Tutorial five: Topics
45
45
46
46
dart receive_logs_topic.dart "info.*" "warn.*"
47
47
dart emit_log_topic.dart "info.connections" "Connected"
48
- dart emit_log_topic.dart "info.connections " "Connected "
48
+ dart emit_log_topic.dart "warn.connecctions " "A warning "
49
49
50
50
Tutorial six: RPC (Request/Response)
51
51
Original file line number Diff line number Diff line change @@ -3,7 +3,7 @@ import "package:dart_amqp/dart_amqp.dart";
3
3
4
4
void main (List <String > arguments) {
5
5
if (arguments.isEmpty) {
6
- print ("Usage: receive_logs_direct.dart <facility>.<routingKey> " );
6
+ print ("Usage: receive_logs_direct.dart <topic> [<topic>, ...] " );
7
7
return ;
8
8
}
9
9
@@ -20,7 +20,7 @@ void main (List<String> arguments) {
20
20
});
21
21
});
22
22
23
- List <String > routingKeys = arguments.sublist (0 , 2 );
23
+ List <String > routingKeys = arguments.sublist (0 );
24
24
client
25
25
.channel ()
26
26
.then ((Channel channel) {
You can’t perform that action at this time.
0 commit comments