Add an option to make a persistent interceptor queue

README.md

@@ -1,6 +1,6 @@
 # Coyote
 
-Coyote is a RabbitMQ message sink. The default routing key is `#` so every message in the given `exchange` is routed to a ephemeral `interceptor` queue.
+Coyote is a RabbitMQ message sink. The default routing key is `#` so every message in the given `exchange` is routed to an `interceptor` queue.
 
 ## Install
 
@@ -31,15 +31,15 @@ USAGE:
     --exchange myexchange1,myexchange2=mykey2        # Messages with or without routing keys in multiple exchanges
 
 VERSION:
-   v0.14.0
+   v0.16.0
 
 COMMANDS:
    help, h  Shows a list of commands or help for one command
 
 GLOBAL OPTIONS:
    --url value       RabbitMQ url, must start with amqps:// or amqp://.
    --exchange value  Exchange & routing key combinations to listen messages.
-   --queue value     Interceptor queue name. (default: "interceptor")
+   --queue value     Interceptor queue name. If provided, interceptor queue will not be auto deleted.
    --store value     SQLite filename to store events.
    --insecure        Skips certificate verification. (default: false)
    --noprompt        Disables password prompt. (default: false)

coyote.go

@@ -112,8 +112,7 @@ func main() {
 			},
 			&cli.StringFlag{
 				Name:  "queue",
-				Value: "interceptor",
-				Usage: "Interceptor queue name.",
+				Usage: "Interceptor queue name. If provided, interceptor queue will not be auto deleted.",
 			},
 			&cli.StringFlag{
 				Name:  "store",
@@ -174,13 +173,20 @@ func main() {
 				log.Printf("💔 Terminating AMQP channel")
 			}()
 
+			var queueName string
+			persistent := ctx.IsSet("queue")
+			if persistent {
+				queueName = ctx.String("queue")
+			} else {
+				queueName = fmt.Sprintf("%s.%s", "coyote", uuid.NewString())
+			}
 			q, err := ch.QueueDeclare(
-				fmt.Sprintf("%s.%s", ctx.String("queue"), uuid.NewString()), // queue name
-				false, // is durable
-				true,  // is auto delete
-				true,  // is exclusive
-				false, // is no wait
-				nil,   // args
+				queueName,   // queue name
+				false,       // is durable
+				!persistent, // is auto delete
+				!persistent, // is exclusive
+				false,       // is no wait
+				nil,         // args
 			)
 			if err != nil {
 				return fmt.Errorf("%s %w", color.RedString("failed to declare a queue:"), err)

coyote_test.go

@@ -143,7 +143,7 @@ COMMANDS:
 GLOBAL OPTIONS:
    --url value       RabbitMQ url, must start with amqps:// or amqp://.
    --exchange value  Exchange & routing key combinations to listen messages.
-   --queue value     Interceptor queue name. (default: "interceptor")
+   --queue value     Interceptor queue name. If provided, interceptor queue will not be auto deleted.
    --store value     SQLite filename to store events.
    --insecure        Skips certificate verification. (default: false)
    --noprompt        Disables password prompt. (default: false)