I can certainly share germane pieces from it, Oleg.
Background: NiFi version is 0.7.1. RabbitMQ is 3.6.6. Erlang is 17.5-1.
>From nifi-app.log:
java.lang.IllegalStateException: Failed to establish connection with AMQP
Broker: com.rabbitmq.client.ConnectionFactory@78......
.
. lots of stack trace lines
.
at java.lang.Thread.run(Thread.java:745) [na:1.8.0_111]
Caused by: com.rabbitmq.client.Authentication.FailureException: ACCESS
REFUSED - Login was refused using authentication PLAIN. For details see the
broker logfile.
>From the rmq log file:
accepting AMQP connection <0.13753.9> (127.0.0.1:54318 -> 127.0.0.1:5673)
=ERROR REPORT==== 20-Mar-2017:10:46:30 ===
closing AMQP connection <0.20511.61> (127.0.0.1:48902 -> 127.0.0.1:5673):
{bad header,<< 22,3,3,0,195,1,0,0>>}
I had recently upgraded my NiFi from 0.6.x to 0.7.1. My broker log shows
successful connections without the error report when I was still 0.6.x.
Since I upgraded I have not been able to connect with success.
Thanks in advance for your help. I am very interested in why I seem to be
getting this bad header message now. -Jim
On Mon, Mar 20, 2017 at 10:00 AM, Oleg Zhurakousky <
[email protected]> wrote:
> James, any chance you can provide stack trace from the logs?
>
> Cheers
> Oleg
>
> > On Mar 20, 2017, at 15:34, James McMahon <[email protected]> wrote:
> >
> > Good morning. I am using a NiFi 0.7 code base. I recently upgraded to
> that from a 0.6.x version. I'm limited to that 0.7.x baseline now. I
> realize it is old(er), but I have no choice in the matter.
> >
> > I had a PublishAMQP processor that had been working without issue to
> connect to RabbitMQ but is now failing with this error:
> >
> > Failed to establish connection with AMQP Broker: com.rabbitmq.client.
> ConnectionFactory@45cd2c16
> >
> > I can determine why this is now happening. RabbitMQ appears to be
> started and running fine. I'm connecting to host localhost, and a specific
> port that seems available. I get the same error if I (temporarily) turn off
> my firewall entirely.
> >
> > I am attempting to employ a StandardSSLContextService that Enables
> without error.
> >
> > How can I troubleshoot this error and figure out why I cannot connect to
> rabbitMQ using PublishAMQP? Thanks in advance for any help you can offer.
> -Jim
>
