message-queue Questions

2

Solved

During long term operations our C++ Win32 application shows a modal status dialog with a process bar, which is updated irregular every few seconds or so. Starting with Windows 7 we realized that Wi...
Malevolent asked 9/8, 2011 at 13:56

9

I'm wondering if there is a tool or lib that can move messages between queues? Currently, i'm doing something like below public static void ProcessQueueMessage([QueueTrigger("myqueue-poison")] str...
Genuine asked 21/10, 2015 at 6:15

1

Solved

Suppose we have the following scenario: Service Bus Queue with 10,000 messages Azure Functions (on Consumption plan) with function set up as a trigger for the SB Queue An external (out of our con...
Beatrizbeattie asked 15/4, 2020 at 14:52

3

Solved

No matter how much I read about those two patterns I just can't see the difference.
Denominator asked 10/11, 2011 at 20:6

2

Solved

I don't have much of a socket programming experience but I tried read a little about it. I am quite familiar with MDB and messaging queues. Someone has told me that queue(e.g. MDB) is "Not much mor...
Stanfordstang asked 19/5, 2012 at 18:59

3

Solved

I am using python langauge to send & receive messages using Azure bus service queue. I am getting "The lock supplied is invalid.Either the lock expired, or the message has already been removed...
Chiropractic asked 19/6, 2019 at 10:4

5

Solved

I need to limit the rate of consuming messages from rabbitmq queue. I have found many suggestions, but most of them offer to use prefetch option. But this option doesn't do what I need. Even if I ...
Karyoplasm asked 24/3, 2015 at 6:54

5

Solved

I have made the changes in server.properties file in Kafka 0.8.1.1 i.e. added log.cleaner.enable=true and also enabled cleanup.policy=compact while creating the topic. Now when I am testing it, I p...
Bassesalpes asked 15/12, 2015 at 5:19

4

I'm learning the messaging system and got confused by those terminology. All the messaging system below provides loose coupling between services with different sets of features. queue - FIFO, pu...

4

Solved

I am trying to understand the differences between something like Kafka and something like Camel. To my understanding Camel would provide much more abstraction for developers without having to worry...
Circumspection asked 15/1, 2018 at 17:37

2

Solved

I am trying to make a class that will be able to send data and then receive them. Right now, it is working only for the first send/receive and with another attempt to .send() it will throw an erro...
Godgiven asked 1/3, 2018 at 18:43

5

Solved

Suppose I have a RabbitMQ instance and a set of pods that pick messages from RabbitMQ and process them. How do I make Kubernetes increase the number of pods as the queue size increases? (I'm menti...
Zeba asked 22/5, 2016 at 17:1

5

I'm trying to write a client and server which are going to exchange data by using POSIX message queue. I tried to do it by looking at the examples I saw in the Internet and the documents of the cou...
Mclin asked 27/2, 2014 at 21:57

9

Solved

I am currently facing a problem for which I am pretty sure there is an official name, but I don't know what to search the web for. I hope that if I describe the problem and the solution I have in m...

2

Solved

When a new consumer/brorker is added or goes down, Kafka triggers a rebalance operation. Is Kafka Rebalancing a blocking operation. Are Kafka consumers blocked while a rebalancing operation is in p...

3

i am implementing sqs in my Node js project. what i am doing is sending msg in SQS and receiving it. but when i receive it is just ResponseMetadata object "ResponseMetadata": { "RequestId": "865...
Amoebocyte asked 31/1, 2020 at 15:11

2

I have read a few discussions and forums but still fail to understand which one is better rabbitmq vs activemq. I have heard the delay in rabbitmq is more because all traffic is first diverte...
Snoddy asked 21/10, 2017 at 20:29

1

I would like to know how my Selenium framework can dequeue a message sitting in a message queue. I have built an application to send a JSON string containing k/v pairs to a message queue. My archit...
Brockington asked 19/8, 2020 at 9:41

2

Solved

I have a simple messanger config: framework: messenger: failure_transport: failed transports: async: dsn: '%env(MESSENGER_TRANSPORT_DSN)%' retry_strategy: max_retries: 2 delay: 10000 fail...
Iridaceous asked 28/5, 2020 at 16:22

1

I have an application that does not recieve ordinary HTTP requests through a controller, instead it listens to and receives messages (AMQP protocol) in order to initiate it's logic flow. My applic...

1

Solved

I try to implement Bull queue in Typescript and NestJS, my code: @Injectable() export class MailService { constructor( @InjectQueue('mail') private readonly mailQueue: Queue ) {} async addToQ...

3

Solved

I am confused between the concept of Message Queue (e.g., ActiveMQ, RabbitMQ, ZeroMQ) and EventBus (e.g., Guava Event Bus, Akka EventBus) I think MQ and eventBus both use the pub/sub pattern. MQ s...
Annadiane asked 21/6, 2014 at 10:58

7

Solved

And are there any? To me, MB knows both subscribers and publishers and acts as a mediator, notifying subscribers on new messages (effectively a "push" model). MQ, on the other hand, is more of a "p...
Melone asked 17/10, 2011 at 12:45

16

Solved

I've been asked to evaluate RabbitMQ instead of Kafka but found it hard to find a situation where a message queue is more suitable than Kafka. Does anyone know use cases where a message queue...
Involve asked 10/2, 2017 at 4:30

2

Solved

I need a task queue so that some of the heavy operations can be moved out of the uwsgi context without affecting the users. Since we're already using uwsgi app server, it'd be desirable if uwsgi sp...
Hoyos asked 8/3, 2014 at 13:57

© 2022 - 2024 — McMap. All rights reserved.