Skip to content

Commit 8beb0fa

Browse files
Add -p for delivery_mode to CLI (#21)
* Add -p for delivery_mode (1 = transient, 2 = persistent) --------- Co-authored-by: Christina <christina@84codes.com>
1 parent 63a5a9f commit 8beb0fa

File tree

2 files changed

+9
-2
lines changed

2 files changed

+9
-2
lines changed

shard.yml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
name: amqpcat
2-
version: 1.0.1
2+
version: 1.0.2
33

44
authors:
55
- Carl Hörberg <carl@cloudamqp.com>

src/cli.cr

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -38,7 +38,14 @@ p = OptionParser.parse do |parser|
3838
parser.on("-q QUEUE", "--queue=QUEUE", "Queue to consume from") { |v| queue = v }
3939
parser.on("", "--queue-type=QUEUE_TYPE", "Queue type (classic, quorum or stream)") { |v| queue_type = v }
4040
parser.on("-c", "--publish-confirm", "Confirm publishes") { publish_confirm = true }
41-
parser.on("-o OFFSET", "--offset OFFSET", "Stream queue: Offset to start reading from ") do |v|
41+
parser.on("-p VALUE", "--persistent=VALUE", "Delivery mode, 1 = transient, 2 = persistent") do |v|
42+
props.delivery_mode = case v
43+
when "1" then 1_u8
44+
when "2" then 2_u8
45+
else abort "Error: delivery_mode must be 1 or 2, got: #{v.inspect}"
46+
end
47+
end
48+
parser.on("-o OFFSET", "--offset OFFSET", "Stream queue: Offset to start reading from ") do |v|
4249
if %w[first next last].includes? v
4350
offset = v
4451
elsif /^\d/.match v

0 commit comments

Comments
 (0)