I am working on socket for chatting. Here is my socket code in nodejs file which is working well. The outer socket io.emit working good and emits the message to all the users which are connected t...

I'm trying to find a way to re-order messages within a topic partition and send ordered messages to a new topic. I have Kafka publisher that sends String messages of the following format: {system_...

To implement your own custom actor in Akka (Java binding) you extend the UntypedActor base class. This requires you to define your own onReceive(...) method: @Override public void onReceive(Object...

Q1 I know the fundamental different between event based vs request based/driven architecture. Question is if the Request-based always done in synchronously while the Event-based is always done in ...

I am currently having a connection issue trying to connect to an AWS SQS Queue using Spring Cloud and Spring Boot. I believe I have everything configured fine but am getting: 2015-07-01 18:12:11...

My application basically backup the SMS and MMS to cloud server. I used below URI to retrieve data from database. SMS- Uri uri = Uri.parse("content://sms/"); MMS-Uri uri = Uri.parse(...

I am writing a chrome extension but the sendResponse method does not work. chrome.runtime.onMessage.addListener( function(request, sender, sendResponse) { if(!request.method){ return false; } ...

my company has a messaging system which sends real-time messages in JSON format, and it's not built on AWS, and will not have any VPN connection with AWS. our team is trying to use AWS SQS to rece...

I want to know if JMS API uses any protocol to transfer messages or if uses its own. If the former, which protocol? I have read many articles over the net but I couldn't find an answer for this.

In my application I am able to send an SMS programatically to a particular mobile number when the user clicks submit button. Then there is a response message from that mobile number now I want to r...

I'm looking for reactive state libraries like Mobx for Python, i.e. on server-side rather than client-side of a web application. Mobx is similar to classic reactive libraries like RxPY, but has a ...

I'm actually working on a chat app, the messages are stored in Firestore, I want the receiver of the message to get a notification when a message is sent by the sender. I know this only way to achi...

I need to send MMS. Into my hero this code looks ugly but works: Intent sendIntent = new Intent("android.intent.action.SEND_MSG"); sendIntent.putExtra("address", toText); sendIntent.putExtra(I...

I have created an app using socket... I am able to manage the conversation between two persons using socket connection. Here is the code for it User model const schema = new Mongoose.Schema({ f...

I have read an article "Microservices" by Martin Fowler and find it difficult to understand smart endpoints and dumb pipes. Please explain these terms, examples are welcome.

For testing purpose, I need to simulate client for generating 100,000 messages per second and send them to kafka topic. Is there any tool or way that can help me generate these random messages?

I'm having a recurrent issue with Kafka: I partition messages by customer id, and sometimes it happens that a customer gets a huge amount of messages. As a result, the messages of this customer and...

I want to use a messaging protocol that works fine over 3G, but not over some corporate firewalls. How can my app force the use of the cellular network when it fails to connect over WiFi even in th...

I have multiple distributed competing consumers each pulling messages off the same (transactional) queue. I want to implement each consumer as an Idempotent Receiver so I never process the same mes...

i have a background in enterprise distributed systems using Messaging technologies such as RabbitMQ and others, though i am relatively new to Actor Model. with that said, i am wondering if it is a...

I need my iOS app to read the text messages sent from an external device and perform certain tasks based on the received message without any major user intervention. I am totally aware that the con...

It seems like most of the messaging systems I've looked at have basic, if any, support for priority message queues. For example, the AMQP only specifies a minimum of 2 priorities. RabbitMQ, an AMQP...

I have multiple RabbitMQ nodes running on different machines. After installing each node I failed to specify a common cookie for each of them to use so I had to go back and manually change the file...

I'm trying to implement a Spring Boot-based Kafka consumer that has some very strong message delivery guarentees, even in a case of an error. messages from a partition must be processed in order, ...

As far as I know, Apache Kafka is asynchronous messaging platform, where as Apache Camel is a platform implementing the enterprise integration patterns. So, what are the practical difference...