Skip to content
This repository has been archived by the owner on Feb 8, 2023. It is now read-only.

rabbitio out panic: "send on closed channel" on SIGTERM #36

Open
abc94e4f31 opened this issue Feb 11, 2021 · 0 comments
Open

rabbitio out panic: "send on closed channel" on SIGTERM #36

abc94e4f31 opened this issue Feb 11, 2021 · 0 comments
Labels

Comments

@abc94e4f31
Copy link

abc94e4f31 commented Feb 11, 2021

Panic: "send on closed channel" on SIGTERM

$ rabbitio out -b 222 -p 500 -u amqp://user:user@host:post/vhost -e exchange_name -r name -q name -d ./data                                                                                                                                  
2029/10/11 11:21:23 RabbitMQ connected: amqp://user:user@host:port/vhost
2029/10/11 11:21:23 Bind to Exchange: "exchange_name" and Queue: "name", Messaging waiting: 935577                  
2029/10/11 11:21:23 Wrote 32815 bytes to data/1_messages_222.tgz
2029/10/11 11:21:23 Wrote 32800 bytes to data/2_messages_222.tgz
....
2029/10/11 11:21:24 Wrote 32869 bytes to data/23_messages_222.tgz
2029/10/11 11:21:24 Wrote 32804 bytes to data/24_messages_222.tgz
^C Interruption, saving last memory bits..
2029/10/11 11:21:24 Wrote 32804 bytes to data/25_messages_222.tgz
panic: send on closed channel

goroutine 34 [running]:
github.com/meltwater/rabbitio/rmq.(*RabbitMQ).Consume 
        /home/user/go/src/github.com/meltwater/rabbitio/rmq/consume.go:141         
created by github.com/meltwater/rabbitio/cmd.glob..func2
        /home/user/go/src/github.com/meltwater/rabbitio/cmd/out.go:50
Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.
Labels
Projects
None yet
Development

No branches or pull requests

2 participants