Can't add dynamic shovel bettwen two vhost

[jonkiszp]

Describe the bug

I can't set up a connection between two vhosts. If I execute the command I get the following error.

Reproduction steps

rabbitmqctl set_parameter shovel my-shovel
'{"src-protocol": "amqp091", "src-uri": "amqp:///test", "src-queue": "old_data_sensors", "dest-protocol": "amqp091", "dest-uri": "amqp://", "dest-queue": "old_data_sensors"}'

Expected behavior

2023-10-26 12:16:05.950651+02:00 [error] <0.3650.0> Shovel 'my-shovel' failed to connect (URI: amqp:///test): access to target virtual host was refused
2023-10-26 12:16:05.950762+02:00 [error] <0.3650.0> Shovel 'my-shovel' has no more URIs to try for connection
2023-10-26 12:16:05.950851+02:00 [error] <0.3650.0> Shovel 'my-shovel' could not connect to source: error failed_to_connect_using_provided_uris
2023-10-26 12:16:05.951022+02:00 [error] <0.3599.0> supervisor: {<0.3599.0>,rabbit_shovel_dyn_worker_sup}
2023-10-26 12:16:05.951022+02:00 [error] <0.3599.0> errorContext: child_terminated
2023-10-26 12:16:05.951022+02:00 [error] <0.3599.0> reason: shutdown
2023-10-26 12:16:05.951022+02:00 [error] <0.3599.0> offender: [{pid,<0.3650.0>},
2023-10-26 12:16:05.951022+02:00 [error] <0.3599.0> {id,{<<"/">>,<<"my-shovel">>}},
2023-10-26 12:16:05.951022+02:00 [error] <0.3599.0> {mfargs,
2023-10-26 12:16:05.951022+02:00 [error] <0.3599.0> {rabbit_shovel_worker,start_link,
2023-10-26 12:16:05.951022+02:00 [error] <0.3599.0> [dynamic,
2023-10-26 12:16:05.951022+02:00 [error] <0.3599.0> {<<"/">>,<<"my-shovel">>},
2023-10-26 12:16:05.951022+02:00 [error] <0.3599.0> [{<<"dest-uri">>,
2023-10-26 12:16:05.951022+02:00 [error] <0.3599.0> [{encrypted,
2023-10-26 12:16:05.951022+02:00 [error] <0.3599.0> <<"Gd6ZKvkUoPDBVAYIL+CPwTm/1MHGbsTVZVdts/pGHitceOeMD8YcfnXWK5G4KM6em7BETPH9XSpyv14bzGsSLfJPuI02a1IY2AAppgfmGaQ=">>}]},
2023-10-26 12:16:05.951022+02:00 [error] <0.3599.0> {<<"src-uri">>,
2023-10-26 12:16:05.951022+02:00 [error] <0.3599.0> [{encrypted,
2023-10-26 12:16:05.951022+02:00 [error] <0.3599.0> <<"EKZA8nz7CACj1wgh9ShXzsoeA33eanFHveBuGFcKN7xHxIvv76r/L1HgKDyIjDate1sBzKUS752PZcgQ+9XA3+pnf/Eg4Jf7B60MAZ5GQvg=">>}]},
2023-10-26 12:16:05.951022+02:00 [error] <0.3599.0> {<<"dest-protocol">>,<<"amqp091">>},
2023-10-26 12:16:05.951022+02:00 [error] <0.3599.0> {<<"dest-queue">>,<<"old_data_sensors">>},
2023-10-26 12:16:05.951022+02:00 [error] <0.3599.0> {<<"src-protocol">>,<<"amqp091">>},
2023-10-26 12:16:05.951022+02:00 [error] <0.3599.0> {<<"src-queue">>,<<"old_data_sensors">>}]]}},
2023-10-26 12:16:05.951022+02:00 [error] <0.3599.0> {restart_type,{permanent,5}},
2023-10-26 12:16:05.951022+02:00 [error] <0.3599.0> {shutdown,4294967295},
2023-10-26 12:16:05.951022+02:00 [error] <0.3599.0> {child_type,worker}]

If I do it via the manager, before adding, I receive the following message:

Message

Validation failed

user "admin" may not connect to vhost "test"

I don't know how to configure it correctly.

[michaelklishin]

@jonkiszp consider using Discussions for questions, they are no longer a hot new GitHub feature.

2023-10-26 12:16:05.950651+02:00 [error] <0.3650.0> Shovel 'my-shovel' failed to connect (URI: amqp:///test): access to target virtual host was refused

is pretty specific: the user used by Shovel (if the URI really is amqp:///test, the user is guest — we highly recommend against such shortcuts) does not have access to the virtual host.

See Managing Users and Permissions. You need to grant the user you intend to use sufficient (or full) permissions to the target virtual host.

If the URI is amqp://, I suspect that the virtual host could be parsed to an empty string. Consider using full URIs.

[jonkiszp]

I used the advice and I still have the problem

rabbitmqctl set_parameter shovel my-shovel
'{"src-protocol": "amqp091", "src-uri": "amqp://admin:my-password@localhost:5672/test", "src-queue": "old_data_sensors", "dest-protocol": "amqp091", "dest-uri": "amqp://admin:my-password@localhost:5672/", "dest-queue": "old_data_sensors"}'

error:

2023-10-26 12:56:15.004921+02:00 [error] <0.9982.0> Shovel 'my-shovel' failed to connect (URI: amqp://localhost:5672/test): ACCESS_REFUSED - Login was refused using authentication mechanism PLAIN. For details see the broker logfile.

[michaelklishin]

The message is pretty specific: this Shovel fails to authenticate (except that the URI it actually used was amqp://localhost:5672/test, so guest:guest, and not what you expect)