Stack Overflow
Stack Overflow

Questions tagged [queueing]

57 questions
10
votes
1 answer

Best practice for error handling with Spring JMS

I'm working on a message based service that queues all incoming requests and handles them later. What is the best practice for handling errors. For example malformed messages or communication errors when sending the information to the next system.…
Kristoffer
  • 1,633
  • 3
  • 19
  • 25
5
votes
1 answer

rabbitmq AMQP::consume()

AMQP function consume() is a blocking function with a callback, Is it possible to set a timeout for consume() function, so after specific amount of time it doesn't block anymore and the code execution completes ?
AhlyM
  • 510
  • 1
  • 6
  • 16
4
votes
3 answers

How does RabbitMQ decide when it is time to delete a message?

I am trying to understand the logic for message deletion in RabbitMQ. My goal is to make messages persist even if there is not a client connected to read them, so that when clients reconnect the messages are waiting for them. I can use durable, lazy…
Mnebuerquo
  • 5,759
  • 5
  • 45
  • 52
3
votes
1 answer

Nodejs - Fire multiple API calls while limiting the rate and wait until they are all done

My issues Launch 1000+ online API that limits the number of API calls to 10 calls/sec. Wait for all the API calls to give back a result (or retry), it can take 5 sec before the API sends it data Use the combined data in the rest of my app What I…
sneyders
  • 33
  • 1
  • 3
3
votes
2 answers

What is the best way to cancel a task that is in a blocking state?

I have tasks running that call a method that reads from RabbitMQ. When there is nothing in the queue, the method simply blocks. So the tasks have a "running" status, but aren't actually doing anything. Is there any way to gracefully end these…
Evil August
  • 411
  • 6
  • 18
2
votes
1 answer

How to determine payload type for DBMS_AQ.DEQUEUE_ARRAY

I am attempting to use the function DBMS_AQ.DEQUEUE_ARRAY in Oracle 10.2.0.4.0. to browse the contents of a queue. Is there a way to determine the type to use for the message array? Is there some "generic" type I could be using? What I'm attempting…
Greg
  • 75
  • 1
  • 5
2
votes
2 answers

Is it safe or advisable to re-enqueue a Runnable with the same Executor if a problem occurs and I want to retry?

I just wrote this code in my runnable's run() method: try { dbConnection = MyApp.datasource.getConnection(); } catch (SQLException e) { logger.log(Level.SEVERE, "Could not obtain a DB connection! Re-enqueuing this task. Message: " +…
Avi Flax
  • 50,872
  • 9
  • 47
  • 64
2
votes
1 answer

MSMQ triggered powershell - fires but does nothing for forwarded message

This is on Windows Server 2008 R2 Enterprise (64 bit) I want to execute a powershell script when a message arrives in a particular queue. It works as expected if I log on to the server and use a utility to move/copy a message into the queue. The…
wysiwyg
  • 21
  • 5
2
votes
3 answers

Where are possible locations of queueing/buffering delays in Linux multicast?

We make heavy use of multicasting messaging across many Linux servers on a LAN. We are seeing a lot of delays. We basically send an enormous number of small packages. We are more concerned with latency than throughput. The machines are all…
Matt
  • 952
  • 2
  • 8
  • 17
1
vote
1 answer

How can I use Python's concurrent.futures to queue tasks across multiple processes each with their own thread pool?

I'm working on a library function that uses concurrent.futures to spread network I/O across multiple threads. Due to the Python GIL I'm experiencing a slowdown on some workloads (large files), so I want to switch to multiple processes. However,…
Andrew Gorcester
  • 19,595
  • 7
  • 57
  • 73
1
vote
1 answer

connection to two RabbitMQ servers

I'm using python with pika, and have the following two similar use cases: Connect to RabbitMQ server A and server B (at different IP addrs with different credentials), listen on exchange A1 on server A; when a message arrives, process it and send…
Dan H
  • 14,044
  • 6
  • 39
  • 32
1
vote
1 answer

AnyLogic: two customer classes having different priorities

I know the basics of AnyLogic/Process Modeling Library and am about to teach simulation of basic queues with AnyLogic, transitioning from Simul8 that I 've used for many years. I have agents of two types, 1 and 2, sent to respective queues 1 and 2,…
Thanos
  • 11
  • 1
1
vote
1 answer

How can I put matrix R in a loop and generate new values of matrix R>

I have a matrix R which has the diagonal matrix 0 and the sum of the rows should always be one. How can I update the matrix in the way that only the values which create the sum = 1 should change after iteration. How can I do it with a for loop? R =…
Amra Feta
  • 21
  • 4
1
vote
0 answers

Meteor - fetch data once and observe changes afterwards

I am developing real-time interactive visualization, using meteor and react on the front-end. The visualization which is fairly complicate to initiate, but relatively easy to update with atomic changes. Thus, I need to fetch the data once, transform…
karlitos
  • 1,604
  • 3
  • 27
  • 59
1
vote
0 answers

Kue.js worker processing concurrency

I am trying to replace AWS SQS with Kue.js in a node application. My concern is, if there are n no of items added in a queue. How many items in the queue will be processed concurrently? Is it like.... processor will process the each item one at a…
Anirudh
  • 41
  • 5
1
2 3 4