23 replies

Consumer not receiving messages

Hi all, hate to jump in with questions, but saw this channel and figured I'd give it a shot. I have a queue set up on a worker as a producer/consumer combo between multiple environments. Meaning, my

wrangler.toml

wrangler.toml

looks something like this:

[[env.development.queues.producers]]
queue = "tasks-development"
binding = "QUEUE_TASKS"

[[env.development.queues.consumers]]
queue = "tasks-development"
max_batch_size = 10    
max_batch_timeout = 30 

[[env.staging.queues.producers]]
queue = "tasks-staging"
binding = "QUEUE_TASKS"

[[env.staging.queues.consumers]]
queue = "tasks-staging"
max_batch_size = 10    
max_batch_timeout = 30

[[env.development.queues.producers]]
queue = "tasks-development"
binding = "QUEUE_TASKS"

[[env.development.queues.consumers]]
queue = "tasks-development"
max_batch_size = 10    
max_batch_timeout = 30 

[[env.staging.queues.producers]]
queue = "tasks-staging"
binding = "QUEUE_TASKS"

[[env.staging.queues.consumers]]
queue = "tasks-staging"
max_batch_size = 10    
max_batch_timeout = 30

Where I have multiple consumer/producer pairs set, but the

binding

binding

is the same. I've found that locally, the queues are working great - as soon as I send messages to the queue, my consumer is receiving them. However, when I deployed with

wrangler

wrangler

, I am seeing the items enter the queue and get processed, but the

binding

binding

seems to be failing where my consumer is never getting a

MessageBatch

MessageBatch

to process. Any ideas would be greatly appreciated

Cloudflare Developers•3y ago•

23 replies

retti

Consumer not receiving messages

Hi all, hate to jump in with questions, but saw this channel and figured I'd give it a shot. I have a queue set up on a worker as a producer/consumer combo between multiple environments. Meaning, my

wrangler.toml

wrangler.toml

looks something like this:

[[env.development.queues.producers]]
queue = "tasks-development"
binding = "QUEUE_TASKS"

[[env.development.queues.consumers]]
queue = "tasks-development"
max_batch_size = 10    
max_batch_timeout = 30 

[[env.staging.queues.producers]]
queue = "tasks-staging"
binding = "QUEUE_TASKS"

[[env.staging.queues.consumers]]
queue = "tasks-staging"
max_batch_size = 10    
max_batch_timeout = 30

[[env.development.queues.producers]]
queue = "tasks-development"
binding = "QUEUE_TASKS"

[[env.development.queues.consumers]]
queue = "tasks-development"
max_batch_size = 10    
max_batch_timeout = 30 

[[env.staging.queues.producers]]
queue = "tasks-staging"
binding = "QUEUE_TASKS"

[[env.staging.queues.consumers]]
queue = "tasks-staging"
max_batch_size = 10    
max_batch_timeout = 30

Where I have multiple consumer/producer pairs set, but the

binding

binding

is the same. I've found that locally, the queues are working great - as soon as I send messages to the queue, my consumer is receiving them. However, when I deployed with

wrangler

wrangler

, I am seeing the items enter the queue and get processed, but the

binding

binding

seems to be failing where my consumer is never getting a

MessageBatch

MessageBatch

to process. Any ideas would be greatly appreciated

Continue the conversation

Join the Discord to ask follow-up questions and connect with the community

Cloudflare Developers

Welcome to the official Cloudflare Developers server. Here you can ask for help and stay updated with the latest news

87,367 Members

Join

Consumer not receiving messages

Consumer not receiving messages

Continue the conversation

Cloudflare Developers

Continue the conversation

Cloudflare Developers

Similar Threads