QPID Rejecting messages with "No Sink found for qualifier MsgQualifier" errors

In OPDK version 15.04, after upgrading from a previous version or performing a fresh install, the qpid services might start logging errors similar to the following:

2015-06-18 16:25:04,460 Dispatcher-2-Conn-14 WARN c.a.a.m.MessageConsumer - MessageConsumer.process() : Sending message batch to the DLQ. com.apigee.analytics.persistence.api.PersistenceException: No Sink found for qualifier MsgQualifier{queueName='ax-q-axgroup001-consumer-group-001', groupName='axgroup001', cg=consumer-group-001}. Rejecting messages
 at com.apigee.analytics.persistence.api.AbstractPersistenceService.persist(AbstractPersistenceService.java:58) ~[persistence-service-api-1.0.0.jar:na]
 at com.apigee.analytics.persistence.api.PersistenceDelegateService.persist(PersistenceDelegateService.java:86) ~[persistence-service-api-1.0.0.jar:na]
 at com.apigee.analytics.messageconsumer.MessageConsumer.process(MessageConsumer.java:163) [message-consumer-service-1.0.0.jar:na]
 at com.apigee.analytics.messageconsumer.MessageConsumer.onMessage(MessageConsumer.java:123) [message-consumer-service-1.0.0.jar:na]
 at com.apigee.queueclient.amqp.qpid.ConsumerImpl$ConsumerMessageListener.onMessage(ConsumerImpl.java:282) [queue-client-1.0.0.jar:na]
 at org.apache.qpid.client.BasicMessageConsumer.notifyMessage(BasicMessageConsumer.java:744) [qpid-client-0.28.jar:na]
 at org.apache.qpid.client.BasicMessageConsumer_0_10.notifyMessage(BasicMessageConsumer_0_10.java:141) [qpid-client-0.28.jar:na]
 at org.apache.qpid.client.BasicMessageConsumer.notifyMessage(BasicMessageConsumer.java:718) [qpid-client-0.28.jar:na]
 at org.apache.qpid.client.BasicMessageConsumer_0_10.notifyMessage(BasicMessageConsumer_0_10.java:187) [qpid-client-0.28.jar:na]
 at org.apache.qpid.client.BasicMessageConsumer_0_10.notifyMessage(BasicMessageConsumer_0_10.java:53) [qpid-client-0.28.jar:na]
 at org.apache.qpid.client.AMQSession$Dispatcher.notifyConsumer(AMQSession.java:3394) [qpid-client-0.28.jar:na]
 at org.apache.qpid.client.AMQSession$Dispatcher.dispatchMessage(AMQSession.java:3333) [qpid-client-0.28.jar:na]
 at org.apache.qpid.client.AMQSession$Dispatcher.access$900(AMQSession.java:3120) [qpid-client-0.28.jar:na]
 at org.apache.qpid.client.AMQSession.dispatch(AMQSession.java:3113) [qpid-client-0.28.jar:na] at org.apache.qpid.client.message.UnprocessedMessage.dispatch(UnprocessedMessage.java:54) [qpid-client-0.28.jar:na]
 at org.apache.qpid.client.AMQSession$Dispatcher.run(AMQSession.java:3256) [qpid-client-0.28.jar:na]
 at java.lang.Thread.run(Thread.java:745) [na:1.7.0_65] 

There is a Jira to address this in 15.07. In the meantime, perform the following actions:

-Run the following sript:

${APIGEE_ROOT}/apigee4/share/installer/apigee-postgres-register.sh 

-Restart qpid services

It's also worth noting the the OPDK Documentation mentions the following points about the procedure:

The restart is required to create new consumer group queues in existing consumer group QPIDs. On occasion, queue creation can take up to 15-20 minutes. Checks mentioned in #11 should be repeated a few times till the confirmation is obtained. (This is referring to running the qpid-stat -q command until you see the Consumer group in the QPid.)

Version history
Last update:
‎08-13-2015 03:16 PM
Updated by: