[rabbitmq-discuss] shovel with authentization

Tue Jan 28 15:14:56 GMT 2014

Hi, my conf of a shovel with authentization doesnt work. RabbitMQ 3.1.5
standalone.
Without authentization everything is ok.

Java code:
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("localhost");
        factory.setPort(5671);
        factory.setSaslConfig(DefaultSaslConfig.PLAIN);
	factory.setUsername("guest");
	factory.setPassword("guest");
        Connection conn = factory.newConnection();

Shovel def:
     {queue1_shovel,
      [{sources,      [{broker,"amqps://guest:guest@Server1"},
        {declarations, [
                {'exchange.declare', [
                    {exchange, <<"MyQ-exchange">>},
                    {type, <<"direct">>},
                    auto_delete
                    ]},
                {'queue.declare', [
                    {queue, <<"MyQ">>},
                    {arguments,[{<<"x-expires">>, long, 15000}]}
                ]},
                {'queue.bind', [
                    {exchange, <<"MyQ-exchange">>},
                    {queue,    <<"MyQ">>}
                ]}

        ]}]},
       {destinations, [{broker, "amqps://guest:guest@Server2"}]},
       {queue, <<"MyQ">>},
       {ack_mode, no_ack},
       {reconnect_delay, 5}
      ]}

The shovel seems to be running:
{queue1_shovel,
     {running,
         {source,
             {amqp_params_network,<<"guest">>,<<"guest">>,<<"/">>,"Server1",
                 undefined,0,0,0,infinity,[],
                 [#Fun<amqp_uri.7.32597394>,#Fun<amqp_uri.7.32597394>],
                 [],[]}},
         {destination,
             {amqp_params_network,<<"guest">>,<<"guest">>,<<"/">>,
                 "Server2",undefined,0,0,0,infinity,[],
                 [#Fun<amqp_uri.7.32597394>,#Fun<amqp_uri.7.32597394>],
                 [],[]}}},
     {{2014,1,28},{16,10,5}}},

I don't get any error from Java nor in log.

Sending a message on Server1's side is ok, but I will never receive on
Server2's.

Getting "guest:guest" off from brokers definitions and removing setUsername
and setPassword it starts working fine.

I tried it with a different user, but the same result...

Where can be a problem?

Thank you in advance!        

--
View this message in context: http://rabbitmq.1065348.n5.nabble.com/shovel-with-authentization-tp32914.html
Sent from the RabbitMQ mailing list archive at Nabble.com.