Hi, I love the idea of Queues in cloudflare, I wro...
# queues-beta
y
Hi, I love the idea of Queues in cloudflare, I wrote one, and I can't get it to work, or at least can't test it successfully I wrote a producer like so: [[queues.producers]] queue = "twitter-mentions-queue" binding = "TWITTER_MENTIONS_QUEUE"
Copy code
const queueTweet = async (tweetId: string, prompt: string, env: any) => {
  const log = {tweetId, prompt};
  await env.TWITTER_MENTIONS_QUEUE.send(log);
  console.log('added to queue', log) // Console log is fired successfully
}
And a consumer like this [[queues.consumers]] queue = "twitter-mentions-queue" max_batch_size = 10 max_batch_timeout = 5
Copy code
async queue(batch: MessageBatch<Error>, env: Environment): Promise<void> {
    for (const message of batch.messages) {
      console.log('Received', message); // This never runs, looked for it in tail, also the ui shows zero queue messages always
    }
  },
Any ideas why I can't see messages?