Comments (2)
Bulk processing of messages can be achieved at the application level. Open a subscription with client ack mode and when a message is received push it onto a local queue for the next processing batch. After a batch has been processed send an acknowledgement for the last message processed. The client sees the performance benefit of sending one ack for many messages and the server could potentially perform ack handling of many messages as a single transaction.
I'm not sure it's possible for stompit, by its design, to deliver a list of messages to a subscription callback. How can it know when multiple messages are received at once? The library only reads a frame header then control is passed to the subscription callback where that reads the frame body. It's for the application to read a message and then either process it immediately or defer it.
from stompit.
Thanks @gdaws, I don't even know if stompit polls or gets data pushed to it so I have no idea how it would be done internally. I'll just write a simple wrapper function and use that as a handler.
from stompit.
Related Issues (20)
- Error: Unexpected ACK received for message-id [ID:b-23774631- HOT 3
- Error: Unexpected ACK received for message-id. How to resolve? HOT 2
- Cannot send any message when applying the heavy load in sequential in for loop
- Connection refused 127.0.0.1:61613 HOT 3
- How to remove activemq queues and scheduled jobs?
- How to get scheduled id from client when scheduling message to activemq?
- How to set type in message headers
- Unable to use priority in activeMq using stompit in nodejs HOT 1
- Use of Heartbeat in activeMQ HOT 1
- Message gets redelivered in loop during the time of high CPU processing on the client side HOT 3
- Is there a way to programmatically delete an ActiveMQ Job Schedule? HOT 1
- Disconnect hangs after unsubscribe HOT 1
- The connection is closing when thousands of messages are ready to subscribe in queue HOT 1
- Max size of message
- Setting AMQ_SCHEDULED_DELAY doesn't work
- Async usage?
- Cannot read properties of undefined (reading 'send')
- Get properties of message
- How to keep the connection open and also set connection timeout?
Recommend Projects
-
React
A declarative, efficient, and flexible JavaScript library for building user interfaces.
-
Vue.js
🖖 Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
-
Typescript
TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
-
TensorFlow
An Open Source Machine Learning Framework for Everyone
-
Django
The Web framework for perfectionists with deadlines.
-
Laravel
A PHP framework for web artisans
-
D3
Bring data to life with SVG, Canvas and HTML. 📊📈🎉
-
Recommend Topics
-
javascript
JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
-
web
Some thing interesting about web. New door for the world.
-
server
A server is a program made to process requests and deliver data to clients.
-
Machine learning
Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
-
Visualization
Some thing interesting about visualization, use data art
-
Game
Some thing interesting about game, make everyone happy.
Recommend Org
-
Facebook
We are working to build community through open source technology. NB: members must have two-factor auth.
-
Microsoft
Open source projects and samples from Microsoft.
-
Google
Google ❤️ Open Source for everyone.
-
Alibaba
Alibaba Open Source for everyone
-
D3
Data-Driven Documents codes.
-
Tencent
China tencent open source team.
from stompit.