Stack Exchange Network

Stack Exchange network consists of 174 Q&A communities including Stack Overflow, the largest, most trusted online community for developers to learn, share their knowledge, and build their careers.

Visit Stack Exchange

Questions tagged [messaging]

The tag has no usage guidance.

0
votes
1answer
49 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
47 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 ...
-4
votes
1answer
46 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
129 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
101 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 ...
0
votes
0answers
49 views

How to scale a group messaging system?

I am working on a group messaging system. There can be any number of users in a single group. A user can have any number of groups. It's like twitter, a user can follow any number of users and a user ...
0
votes
0answers
67 views

Kafka alternative for small IOT business

we are a small IOT business located in Germany. We have around 1000 installations of our sensor package with 1-4 sensors each. The measurements of these sensors are forwarded to our server and we ...
3
votes
1answer
309 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
132 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
276 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
211 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 ...
1
vote
0answers
158 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 ...
1
vote
0answers
50 views

Designing a configurable delay pattern on JMS (tibco maas) stack

My java app is a consumer to maas topic(say PRIMARY) on which upstream systems publishes their messages. Some of the pushed messages now needs some delay(say 10 min) before my app starts processing it....
2
votes
1answer
155 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 ...
0
votes
0answers
133 views

Are JMS connection pools actually beneficial?

Is there any tangible benefit to pooling JMS connections? ActiveMQ provides a specific PooledConnectionFactory but I can't see any references in JEE specifications to a javax.jms.ConnectionFactory ...
1
vote
1answer
1k 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 ...
2
votes
0answers
76 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
660 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
337 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
117 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
418 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
206 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, ...
1
vote
1answer
201 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
364 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
116 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. ...
4
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
295 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
244 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
95 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
451 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
102 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 ...
5
votes
2answers
530 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
868 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. ...
14
votes
1answer
8k 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
564 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 ...
3
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 ...
1
vote
0answers
576 views

How do I better manage my Service Bus Quotas in Azure?

I'm trying to determine how best to accomplish the following scenario using the Azure Service Bus. I have millions of devices (desktop software, mobile phone apps, etc) that need to have messages sent ...
13
votes
1answer
4k views

Why is Akka being marketed as reactive? Is Actor Model reactive?

As far as I understand the Actor Model and the Reactive Programming are separate concepts. Actor Model does not seem to be inherently reactive to me. However the Akka framework which is an Actor ...
8
votes
2answers
4k views

How to determine if a message should be a command message or event message?

Two enterprise integration patterns are the command message and the event message. I am working on a system in which we use messaging not only for integration with other systems, but for internal ...
1
vote
1answer
594 views

Data Transformation Pipeline

I have create some kind of data pipeline to transform coordinate data into more useful information. Here is the shell of pipeline: public class PositionPipeline { protected List<...
0
votes
1answer
113 views

Dependencies between services in pipeline [closed]

I am working on creating a new data processing system, where there are multiple steps each fulfilled by different services. For example, there is a scheduling service that kicks of something, an ...
4
votes
2answers
205 views

Difference between sending a message and emitting it

Halfway through the RabbitMQ tutorial, I noticed that the tutorial stops referring to producers "sending" messages and starts using the verb "emit" instead — and pretty consistently, too; after the ...
0
votes
0answers
167 views

Refactoring expansive message architecture

I am currently working with a system that acts like a message bus. A message comes in to the service (WCF Windows Service hosted). The system then uses a service locator pattern to look up which ...
3
votes
2answers
1k views

Messaging technologies between applications ?

Recently, I had to create a program to send messages between two winforms executable. I used a tool with simple built-in functionalities to prevent having to figure out all the ins and outs of this ...
4
votes
1answer
85 views

Tooling and support for message format specifications

How do most companies define and manage message format specifications? Is it common for companies to create custom tools for creating and working with these documents? At work we have a lot of ...
3
votes
1answer
902 views

How to get JMS to front end

I currently have a web application and I would like to add a messaging feature to it. In order to do that, I use JMS(actually OpenMQ, the implementation provided with Glassfish 3). The problem is that ...
3
votes
2answers
764 views

Choosing right technology for messaging system

I'm working on a messaging system for two years now, the system was written by a long ago gone team and involves emails and document processing. The basic process is: Receive an email, parse it, save ...
-1
votes
1answer
121 views

Which of the following data duplication options across shards is recommended?

High performance mysql book suggests that for sharding a blog application, one may want to put comments data across 2 shards: first, on the shard of a person posting comment, and on the shard where ...