Facing problem in redeclaring rabbit_mq exchange name

Facing problem in redeclaring rabbit_mq exchange name

Hi, I am new to elastic search. Please find below sample json format which is used to create index in elastic search by using rabbitmq-river plugin.In this code "vijay_exg" exchange is already exists in rabbitmq server.I want to retrieve the messages from this exchange.When I am trying to execute the below code it is generating error in elastic search log file

Re: Facing problem in redeclaring rabbit_mq exchange name

Thanks for your reply. Now I have created new exchange "vijay_exh1" as durable in rabbit MQ Server and made rabbit_mq queue as durable.

In the above sample code I made "exchange_durable" :true "queue_durable" : true, and started publishing messages in exchange "vijay_exh1" but I can't able to consume messages in elastic search and there is no error in elastic search log file.Please help me.

Hi, I am new to elastic search. Please find below sample json format which is used to create index in elastic search by using rabbitmq-river plugin.In this code "vijay_exg" exchange is already exists in rabbitmq server.I want to retrieve the messages from this exchange.When I am trying to execute the below code it is generating error in elastic search log file

Re: Facing problem in redeclaring rabbit_mq exchange name

C.K.R.VIJAY Krishna wrote:

> Thanks for your reply. Now I have created new exchange "vijay_exh1"
> as durable in rabbit MQ Server and made rabbit_mq queue as durable.
> In the above sample code I made "exchange_durable" :true
> "queue_durable" : true, and started publishing messages in exchange
> "vijay_exh1" but I can't able to consume messages in elastic search
> and there is no error in elastic search log file.Please help me.

If you're not getting errors in rabbit log or ES log, then it's
likely you're publishing messages that aren't routing properly within
rabbit.

Use the rabbit web interface or calls to:

rabbitmqctl list_queues -p / messages messages_unacknowledged name

to see if the vijay_test queue is accumulating messages. If it
isn't, and no other queue is catching them, then they're probably
getting dropped by the exchange.

at org.elasticsearch.action.ValidateActions.addValidationError(ValidateActions.java:29)

at org.elasticsearch.action.bulk.BulkRequest.validate(BulkRequest.java:375)

at org.elasticsearch.action.support.TransportAction.execute(TransportAction.java:55)

at org.elasticsearch.client.node.NodeClient.execute(NodeClient.java:92)

at org.elasticsearch.client.support.AbstractClient.bulk(AbstractClient.java:145)

at org.elasticsearch.action.bulk.BulkRequestBuilder.doExecute(BulkRequestBuilder.java:129)

at org.elasticsearch.action.ActionRequestBuilder.execute(ActionRequestBuilder.java:62)

at org.elasticsearch.river.rabbitmq.RabbitmqRiver$Consumer.run(RabbitmqRiver.java:291)

at java.lang.Thread.run(Thread.java:722).

Thanks & Regards,

Vijay

On Monday, February 18, 2013 9:56:13 AM UTC-5, Drew Raines wrote:

C.K.R.VIJAY Krishna wrote:

> Thanks for your reply. Now I have created new exchange "vijay_exh1"
> as durable in rabbit MQ Server and made rabbit_mq queue as durable.
> In the above sample code I made "exchange_durable" :true
> "queue_durable" : true, and started publishing messages in exchange
> "vijay_exh1" but I can't able to consume messages in elastic search
> and there is no error in elastic search log file.Please help me.

If you're not getting errors in rabbit log or ES log, then it's
likely you're publishing messages that aren't routing properly within
rabbit.

Use the rabbit web interface or calls to:

rabbitmqctl list_queues -p / messages messages_unacknowledged name

to see if the vijay_test queue is accumulating messages. If it
isn't, and no other queue is catching them, then they're probably
getting dropped by the exchange.

This issue highlights a common issue people have with bulk: newlines
are significant! If you have them in your json document, they need
to be properly escaped (which should happen automatically when you
encode using your favorite library). For example, take this json
object:

{"foo": "bar\nbaz"}

When encoded to a string, it should look like:

"{\"foo\":\"bar\\nbaz\"}"

And then to send it with bulk, add meta and the proper newline
separation. The literal string you would put in your rabbit msg
would look something like this:

Hi, I am new to elastic search. Please find below sample json format which is used to create index in elastic search by using rabbitmq-river plugin.In this code "vijay_exg" exchange is already exists in rabbitmq server.I want to retrieve the messages from this exchange.When I am trying to execute the below code it is generating error in elastic search log file