Skip to content

Commit

Permalink
fix: Avoid queue missing error
Browse files Browse the repository at this point in the history
Declare queue in the remote worker source code to avoid queue missing
error when the new RabbitMQ broker is created and the remote worker
is activated right after it.

Close #209.
  • Loading branch information
marktwtn committed Dec 6, 2019
1 parent 26e64ce commit 9d1a6d2
Showing 1 changed file with 3 additions and 0 deletions.
3 changes: 3 additions & 0 deletions src/remote_worker.c
Original file line number Diff line number Diff line change
Expand Up @@ -47,6 +47,9 @@ int main(int argc, char *const *argv)
if (!connect_broker(&conn, hostIP))
goto fail;

if (!declare_queue(&conn, 1, "incoming_queue"))
goto fail;

if (!set_consuming_queue(&conn, 1, "incoming_queue"))
goto fail;

Expand Down

0 comments on commit 9d1a6d2

Please sign in to comment.