Questions tagged [messaging]
The messaging tag has no usage guidance.
71
questions
0
votes
1answer
36 views
Architecture question about Instant Messaging Platform with MQTT
I'm starting a project to build an instant messaging application for mobile devices.
Although not the complete list of components these are the main data flows I'm concerned about:
Mobile app ...
1
vote
0answers
21 views
Consumer triggered entity data agregation
I am currently using RabbitMQ to aggregate the output of various data sources.
Functionally the process is the following:
The user enters a product name.
The request is sent to the different sources ...
0
votes
0answers
102 views
Design Decision - MassTransit or NetMQ
We work in a traveling company.
We sell tickets for domestic flights, international flights, trains, and buses.
Currently, each of these products has its own team members and they use different ...
0
votes
0answers
59 views
Is one to one mapping necessary between Write Applications and Read Applications
Introduction: We have a bunch of micro services (about 40) to serve our customers.
To facilitate scaling and audit-ability of selected few micro services we have decided to redesign them using CQRS ...
2
votes
2answers
91 views
Pros and cons of consuming events in batches
Suppose I have a message broker that allows consumers to specify a batch size. What are the advantages and disadvantages of consuming events in batches compared to consume them one by one?
The ...
-1
votes
1answer
55 views
buffering messages and send after reconnect
I'm looking for a solution for this, buffering messages in an array and send them after web-socket reconnect. I can check the socket client and push messages to an array when connection is lost and ...
-1
votes
2answers
68 views
Using Apache Kafka for rare events [closed]
There are multiple microservices which are responsible for storing data dependent from user, e.g. user preferences on some products, user orders, etc. There is a scenario when user is deleted from ...
0
votes
1answer
168 views
What's the use of event sourcing and asynchronous message queues for sending commands
In short: Out of order commands end up with out of order events, so does the ordering of the events matter in such situations?
Since we are uncertain about the order of commands when an asynchronous ...
0
votes
0answers
30 views
Notification system on app using Firebase
I have to build an app that manages orders between customers who submit the orders and riders who deliver them. Riders work in shifts, so when a customer submits an order, only the riders that are ...
0
votes
0answers
206 views
Using signalR for streaming alongside a microservice architecture
I have a cluster of micro services with an exposed search API serving a client app. I want to "stream" in real time the aggregated results of a complex search. The search will be kicked of by the ...
2
votes
2answers
71 views
Syncing two Notifications and Merging them Into One
I am running into this issue:
Suppose that there are two independent services, A and B, and both process messages from C.
Suppose that I have a service X that needs to know if a message m from C was ...
2
votes
1answer
100 views
How to design document exchange system
I am trying to come up with a design of document exchange system.
System should be for business-to-business communication.
Description:
There will be possibly 100+ clients(consumers) - they will have ...
0
votes
1answer
161 views
Scheduling operations in a micro service
I'm trying to realize a service that executes operations at a certain time, those operations are specified by another service by messaging, here's the scenario:
The service A receives a request to ...
0
votes
1answer
117 views
Passing Keys instead of Messages
Recently I stood up a Redis server and tested the idea of storing application 'states' that only existed in our application and were never stored in our database. Don't know if we will ultimately do ...
4
votes
1answer
329 views
How is caching used within messaging apps?
I'm actually studying about web development.
I was just asking why a lot of web apps and chats(Whatsapp, Telegram, Discord, and a lot, a lot more!) are using cache.
I mean, after learning cache ...
1
vote
2answers
396 views
Message Broker in Client-Server-Applications
I'm currently planning an architecture for a system that should consist of multiple microservices. We definitely want to make use of a message broker (probably RabbitMQ).
A simplified diagram of my ...
1
vote
1answer
418 views
Design scalable solution with queue
Assuming the following scenario:
A web application that receives inputs from the user and process the inputs through an algorithm which takes between 5 to 25 minutes (depending on the inputs) and ...
0
votes
1answer
450 views
RabbitMQ: how to achieve scalable one-to-one communication?
I'm trying to use RabbitMQ for two-way one-to-one communication between clients and servers. So, Client 1 should be able to communicate only with Server 1, and vice versa:
The servers stay always ...
-5
votes
1answer
81 views
What happens to media files when a WhatsApp user recalls the message? [closed]
WhatsApp has the "Delete For Everyone" feature that makes it easy to delete messages you did not intend to send to the other user.
For text messages, this recall is easy, but what about Video, Photo ...
0
votes
4answers
495 views
How to guarantee HTTP message delivery in fault tolerant way
When an application A communicates with an external/3rd party system B, there is always a chance that B is down.
Say that A raises an event that should be sent as a message to B via HTTP, what is the ...
0
votes
1answer
114 views
Security and performance considerations when creating chat system on a Flask backend
I am building a website with the Flask framework. One functionality of the site will be that users can send messages to each other.
I created a prototype of this using Flask WTF forms. The basic ...
6
votes
1answer
2k views
CQRS-Event Sourcing: how to process events in the expected order inside the read model
I'm looking for some insights about how to handle the read model in a CQRS Event Sourcing application, in order to do the best to ensure data consistency.
The missing point is how to be sure (...
-2
votes
3answers
481 views
Platform independant ways of passing messages between executibles
I am working on an a data collector which could be called an API of some sorts, which is based on .Net Core 2.1 .
It's job is to receive and pull (ask for) data from data collectors(executable, DLL,...
3
votes
2answers
751 views
CQRS async query from command handler
In a CQRS/async microservices context, I have a command handler e.g. SendOrderConfirmationEmailCommandHandler implemented in a communications service.
This depends on information from the orders ...
1
vote
2answers
458 views
RabbitMQ as backbone for services written in different languages
I'm seeking advice from people using RabbitMQ to connect services written in different languages. Currently my organization is using RabbitMQ exclusively with C# and it's all working quite well. In ...
3
votes
0answers
336 views
Designing CRUD Messaging communication
There are endless resources on creating CRUD for REST resources but I can't find much on doing the same for Messaging.
Given two services A and B where A receives incoming requests that initiates the ...
2
votes
1answer
256 views
How to convey object hierarchy when object is converted to json for updates?
I have some classes being serialized via frugal (this is an open source extension of Thrift). The primary reason this is relevant is that the serialization process is out of my control and needs to ...
1
vote
1answer
2k views
How can I handle multi-producer to particular single-consumer in Kafka?
I'm evaluating the Kafka. It provides some nice features which I want to use, especially durability be default and the access to past messages for new consumers, whenever the consumer wants to reach ...
3
votes
0answers
96 views
How to broadcast message to all non connected clients
I plan to have server which consumes all data sent from clients. I want to use messaging system (RabbitMQ) to avoid all troubles with discovering services, recoveries and so on. Client just publish ...
0
votes
2answers
33 views
Organizing specific human messaging in the web applicaiton code
Python (Flask) web application has a big portion of email/SMS messages generated by templates, translated by Flask-Babel.
To my eye, having literal constants for the message in views, among other ...
0
votes
1answer
963 views
WCF: Send events between services
I recently worked in a larger project where I touched the topic of distributed systems in the c# world the first time.
I found that
wcf is fantastic for remote procedure calls, but how do you add ...
0
votes
1answer
650 views
Design Pattern similar to ESB
Background
I am trying to write a simulator where multiple AI agents are competing and/or collaborating to achieve the goal of maximizing some utility function.
Each agent has the ability to ...
0
votes
1answer
189 views
AMQP protocol and protocols in general
Recently I was reading the AMQP protocol specification from the official website, however, because this is my first protocol that I am trying to study in depth so couple of generic questions about ...
4
votes
1answer
709 views
distributed application design - using message broker
Background
I'm trying to design a layer/component in my distributed application that will communicate between component A and component B.
Right now, this "communication" is accomplished by ...
1
vote
0answers
226 views
Why are most ReactiveX implementations push-based?
Feel free to correct my history, but as far as I understand it, Rx and the Reactive Manifesto trace their roots back to C# and its Reactive Extensions, which is uses push (callback-based) messaging, ...
2
votes
1answer
370 views
Multi-instance Microservice Grid: Preventing Duplication Of Effort When Resolving Cached Resources
Background:
We are in the process of converting a traditional multi-service Windows Service (WS) application into an Azure Service Fabric microservices grid running on a Service Bus messaging layer.
...
1
vote
3answers
397 views
Durable messaging over HTTP
I need to send messages from a Windows Service to a Azure Service Fabric Stateful service. The network connection is not very reliable, and there must not be lost data. I was hoping I could use ...
-1
votes
1answer
120 views
How to explain to a trainee how a computer receives external messages [closed]
I got a trainee in the company I work for. We are currently working on a JS interface that communicates through websocket with a C/Lang server.
My trainee asked me a very good question this morning.
...
5
votes
1answer
1k views
Design verification - chat application architecture
So for my newest hobby project, I want to create a simple chat application where users can just log in with a nickname (no passwords) and talk to anybody on the network.
Off the top of my head, I'm ...
2
votes
2answers
429 views
Notification system design on mobile apps using AWS SNS
To simplify the use case, let's say I have a mobile app available for Android and iOS, similar to Instagram, where users can upload photos that can be commented, liked or disliked by other users.
...
1
vote
1answer
363 views
Patterns for cross application/service event aggregator/messaging
We've got a spaghetti mess of an application that I've been tasked with rebuilding. I really want to make the new code much more flexible, and also more distributed.
On a basic level the application ...
-1
votes
1answer
97 views
SMS for messaging between applications [closed]
What would be the issues or advantages to using SMS messaging for inter-application messaging? more or less reliable than http? etc.
0
votes
2answers
632 views
How can an update message from a rabbitmq broker reach all relevant clients via multiple websocket servers?
Lets say I have multiple websocket servers that maintain many connections to clients to send updates. These websocket servers will be pulling said updates from a rabbitmq broker, and broadcasting them ...
2
votes
1answer
143 views
What are good conventions/standards for application messaging through stdin and stdout?
I'm designing and application that spawns another processes to handle some specialized work. The application and the process it spawns will communicate through standard input and standard output (and ...
4
votes
2answers
661 views
Master-Slave Cluster - How to make sure the master is really dead for the slave to take over?
I have a in-house messaging system, similar to a message broker. We have one master message broker and one slave message broker. A message broker just receives messages and sends them to all nodes. ...
4
votes
1answer
1k views
How to implement a (truly) global variable in a Rails app
How can I best implement a global counter in a Rails API app? (A central component in a system with several.)
Basically I have a transaction id I need to increment and roll over past a maximum value. ...
19
votes
1answer
9k views
Does Akka obsolesce JMS/AMQP message brokers? [closed]
I spent the last week deep diving into the Akka docs and finally understand what actor systems are, and the problems that they solve.
My understanding (and experience with) traditional JMS/AMQP ...
2
votes
1answer
668 views
Is message-oriented middleware applicable for intra-application communication?
I recently developed an application in LabVIEW, but although I'm pretty happy with its design I realised that I might be able to improve one part of it by making the various components of this ...
4
votes
1answer
2k views
Alan Kay: “The Big Idea is Messaging” [duplicate]
Alan Kay said "OO" was about messaging, not objects and drew a parallel to biological cells.
His views are enticing, but vague. The way I understand it is something like a Cellular Automata.
In a ...
7
votes
1answer
10k views
Architecture for a mobile (Android) chat application
I want to develop a chat application that reminds a bit whatsapp, I am doing it as a learning project. I am currently doing it on Android just because I am doing an Android course.
The requirements ...
