Yaron
05/23/2023, 9:20 PMconst 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
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?