I have a AWS Lambda with limited concurrency set that is consuming messages from a AWS SQS of type FIFO, and I just learned that the "messages in flight"-property of the queue does not reflect the ...

I am trying to build a message queue using Redis. Whenever client sends new data, they are added to a list. Here is the code for it $client->lPush("my_queue", $data); Now there is a separate...

I'm currently working on a project where I have a lot of tasks that can be parallelized. I'm using redis to store data, and I'd also like to use to handle my jobs queue to. At first, I've used the...

Considering a stream of different events the recommended way would be one big topic containing all events multiple topics for different types of events Which option would be better? I underst...

When I look over the tutorial of Robot Operating system (ROS), I found most example codes set the publisher's queue size to a larger value such as 1000. I think this leads to losing real-time respo...

We've got an application which will be using RabbitMQ and have several different queues for passing messages between tiers. Initially, I was planning to use multiple direct exchanges, with one for...

Is there any way to implement request-response pattern with mosca MQTT to "check reply from the client and re publish if i dont receive expected reply within expected time". I believe this is pos...

All of the examples of Kafka | producers show the ProducerRecord's key/value pair as not only being the same type (all examples show <String,String>), but the same value. For example: produc...

What is the best way to go over a JMS queue and get all the messages in it? How can count the number of messages in a queue? Thanks.

I am using Hornetq 2.0 i dont understand how can i know how many message are sitting on the queue at the moment. This is a very useful feature so i can know at runtime if my consumer consume messa...

I'm trying to create a FIFO using the CLI, But I get an error aws sqs create-queue --queue-name my-queue.fifo --attributes FifoQueue=true --region us-east-1 An error occurred (InvalidAttributeNam...

In AWS SQS FIFO's Queues; when the visibility timeout of a readed message, in which possition of the queue will be the message? For example: I have these messages in queue: '[A, B, C, D]' (order...

I'm new to Azure Service Bus and have just followed the MS guide at the link below, to get 2 .NET Core console apps running. One as a Sender and the other as the Receiver/Consumer. https://learn.m...

I was once asked on an interview, how would you deal with messages coming in out of order in a message queue. It has been a while and I have not found a definitive answer and I was wondering if an ...

I have an application where I need to store some data in a database (mysql for instance) and then publish some data in a message queue. My problem is: If the application crashes after the storage i...

Am new to Bull.I have tried running bull based on their documentation code. The Process are starting but my job is not getting completed, or am not sure whether its triggering complete event or not...

I am toying a bit with POSIX queues and I encountered a problem. When creating a new queue I can specify for example the size of the message and how many messages there can be in the queue. My norm...

I am working for a while with ZeroMQ. I read already some whitepapers and a lot from the guide, but one question remained open to me: Lets say we use PUB-SUB. Where or on which system are the mess...

I have four current consumers listening to the same queue on Amazon AWS. When pulling message down from the queue, it appears sometimes the same message is consumed by two different consumers. Plea...

We have a really simple Kafka 0.8.1.1 set up in our development lab. It's just one node. Periodically, we run into this error: [2015-08-10 13:45:52,405] ERROR Controller 0 epoch 488 initiated stat...

I want process messages in few threads but i'm getting error during execute this code: from __future__ import with_statement import pika import sys from pika.adapters.blocking_connection import Bl...

My question has some similarities to this question: Why do we need message brokers like RabbitMQ over a database like PostgreSQL? In my current (semi-professional) project I'm also at the point t...

I'm trying to design a real-time monitoring & control system that's modular, so it can distributed, and expanded/reconfigured for different hardware & networks. I've quickly come to the co...

I was wondering which of my two methods is more appropriate, or is there event another one? (1) Direct Direct communication between GATEWAY and μSERVICE A UI sends HTTP request to GATEWAY GATE...

I am working on redis SMQ persistence. My questions here is, While publisher publishing the messages, consumer has stopped suddenly. When consumer connects again, is it possible to subscribe messag...