[SOLVED] Using Queue in Azure Storage

Using Queue in Azure Storage

I am try to solve 1 problem with using AzureStorage.Queue in .NET.

First, I have 2 project, 1 project Web API, 1 project for WebJob. (All write in .NET Core 2.2)

My project API when Create new product, It will insert 1 message store Id of product to Message Queue in Azure (Queue name : product)
At same time in my project Web Job, I have 1 function using [QueueTrigger["product"]] to listen when new message inserted in my "product" queue. But I dont know why after message inserted to "product" queue, my message automatic deleted and inserted into another queue name "product-poison" ?
I am using same connection string to Azure Storage in 2 Project. I Have try to use different connection string but result is the same.

Thanks for supporting me.

Solution

Your queue trigger function consumed the message generate by your API project, and it seems the function did not consume it with a correct format.

Here is an article tells why poison-queue has been generate: Poison messages

When a queue trigger function fails, Azure Functions retries the function up to five times for a given queue message, including the first try. If all five attempts fail, the functions runtime adds a message to a queue named -poison.