You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
If the RabbitMQ broker is newly created and the remote interface initialization is never called, the remote worker can not be activated successfully.
It prints out the message:
Set the consuming queue: server channel error 404,
message: NOT_FOUND - no queue 'incoming_queue' in vhost '/'
It shows that the corresponding queue does not exist.
In the current implementation, the queue is only declared in the remote interface initialization steps instead of declaring in the remote worker.
Once the initialization is called, the durable queue would exist even if the RabbitMQ broker is restarted.
To solve the problem, the queue should be declared in the remote worker, too.
Repeated declaration would be fine based on the description from the RabbitMQ website:
Before a queue can be used it has to be declared.
Declaring a queue will cause it to be created if it does not already exist.
The declaration will have no effect if the queue does already exist
and its attributes are the same as those in the declaration.
The text was updated successfully, but these errors were encountered:
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.
If the
RabbitMQ broker
is newly created and theremote interface
initialization is never called, theremote worker
can not be activated successfully.It prints out the message:
It shows that the corresponding queue does not exist.
In the current implementation, the queue is only declared in the
remote interface
initialization steps instead of declaring in theremote worker
.Once the initialization is called, the durable queue would exist even if the
RabbitMQ broker
is restarted.To solve the problem, the queue should be declared in the
remote worker
, too.Repeated declaration would be fine based on the description from the RabbitMQ website:
The text was updated successfully, but these errors were encountered: