Comments (7)
Hi @esatterwhite if you call
hemera.act(
{
topic: 'stats',
cmd: 'registeredActions',
maxMessages$: -1
},
function(err, resp) {
// is called multiple times
}
)
you will receive multiple responses with the different actions from the services. You have to aggregate by yourself.
If you still get only the actions from one service then it could be a race condition or the plugin is not configured properly.
from hemera.
Oh interesting. Is there a way to know when all of the services have responded?
from hemera.
This a pull mechanism. If you think that all service should send their information to a specific subscriber at startup, feel free to create PR.
from hemera.
Oh interesting. Is there a way to know when all of the services have responded?
You can't know it. You are able to start new services at any time. I prefer to implement a solution as suggested above.
from hemera.
@esatterwhite I implemented here #218 please review
from hemera.
After the PR you can just call
hemera.ready(() => {
hemera.sendActionStats({
topic: 'process.stats'
})
})
in your services to inform your subscriber about new updates. This requires of course that your service process.stats
is ready before the others.
from hemera.
Feature was published with [email protected]
from hemera.
Related Issues (20)
- Logging id HOT 15
- Direct communication ? HOT 3
- Does hemera.close() killall running jobs? HOT 2
- TypeError when defining custom Pino logger HOT 1
- Why https://hemerajs.github.io/hemera/docs/reference.html contains not documentation for add() function. HOT 3
- Adding hemera to Docusaurus users page HOT 3
- Unsubscribe by RegExp HOT 9
- Unable to subscribe to NATS topic when the publisher is not running on Hemera HOT 1
- Client Timeout HOT 3
- hemera-ajv doesnt seem to be working correctly HOT 4
- Hemera-blipp has old hemera version HOT 3
- Have you looked into ts-nats? HOT 3
- How to reply from middleware or extension? HOT 5
- Looking for maintainers and collaborators HOT 5
- NATS disconnection question HOT 1
- Calling reply.send inside async middleware doesn't stop the chain HOT 2
- Typescript support HOT 1
- hemera-zipkin package missing HOT 3
- Any way to unregister an extension? HOT 2
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 hemera.