Questions tagged [message-bus]
The message-bus tag has no usage guidance.
68
questions
0
votes
2
answers
31
views
How to wait for subscription forwarding on publisher side when connecting to XPUB-XSUB proxy?
I'm trying to create message bus with ZeroMQ using XPUB-XSUB proxy.
Number of subscribers and publishers will vary as they come and go. Goal is that there could be number of daemons that can ...
0
votes
2
answers
83
views
How to listen to the serialized Azure Message Bus message in c#?
I am using the Azure Message Bus to communicate with my microservices. I am able to send the message under the topic Account Updated from service A. However, the message is not being read by another ...
0
votes
1
answer
25
views
Microservices architecture domain context
We have two microservices a person service and a resource service.
The person services stores the general person details, name, address contact information etc.
The resource service would store ...
0
votes
1
answer
105
views
MassTransit 6.3.2 Consumer is never called when using IBusControl.ConnectConsumer
When I attach consumers during intial message bus config, the consumers are called as expected.
When I attach the consumers after bus config, using ConnectConsumer the consumers are never called; The ...
0
votes
1
answer
66
views
name of channel in rabitmq consumer using celery
I have setup, where we are using celery and RabbitMQ to schedule our task based on data.
When we create multiple consumer to same queue, it create bindings and web portal shows the consumer IP in ...
0
votes
1
answer
206
views
MessageBus pattern to do an initial sync
I have two (micro)services A and B where service B is interested in data of service A. Let's say service A has a table of products with a lot of fields. Service B wants to store a table of products ...
1
vote
0
answers
434
views
Why does RabbitMQ becomes unresponsive?
RabbitMQ 3.7.13 on Microsoft Windows Server 2012 R2 Standard 32GB RAM 48GB page file
Very low utilization - 10 queues , 20 clients , hundreds of messages per day , < 1MB size
Ran fine for 1 year ...
1
vote
1
answer
65
views
Performance gains when using the exact same encryption/decryption mechanism for everyone participating in message-exchange via nats-server?
Essentially what the subject says. I was wondering if there are there benefits to be gained performance-wise by using the same encryption/decryption mechanism when clients communicate via messages ...
0
votes
2
answers
633
views
problem with masstransit dynamic event publish ( json event )
we need publish multiple event as json string from DB. publish this json event by masstransit like this:
using var scope = _serviceScopeFactory.CreateScope();
var sendEndpointProvider = ...
0
votes
1
answer
425
views
AvaloniaUI - MVVM/ReactiveUI - compatability with standard ReactiveUI
Avalonia UI has an own implementation/version of ReactiveUI. How compatible is this library with the standard ReactiveUI library ?
In other words, can I create my models and viewmodels in a standard ...
0
votes
1
answer
291
views
RabbitMQ Best Practices for High Availability on Cloud
I'm planning to deploy RabbitMQ on Kubernetes Engine Cluster. I see there are two kinds of location types i.e. 1. Region 2. Zone
Could someone help me understand what kind of benefits I can think of ...
6
votes
1
answer
1k
views
One topic per event producer VS One topic shared across multiple producers messaging architecture
This is a bit of general question because it would apply not only to my scenario (with Azure Service Bus) but to any event bus in the context of publish/subscribers with events.
The question is: Is ...
0
votes
1
answer
226
views
Service Fabric pub/sub messaging between stateless services
Whats the best way to implement loosely coupled micro services in Service Fabric using asynchronous messaging. I want service A to publish a message and Service B to receive it. Can I use rabbitmq or ...
4
votes
2
answers
9k
views
C# Azure: How to read body from Microsoft.Azure.ServiceBus.Message?
I have trouble with the Microsoft.Azure.ServiceBus.Message class. I want to create a Message object containing a payload object and then read this object back from it. In my current example I am not ...
0
votes
1
answer
99
views
MVC5 Portable Area, how do you use message bus?
I spent several hours reading through many different examples and documentation for setting up a portable area with ASP.NET MVC, with the intent of sharing a common login page with authentication for ...
5
votes
2
answers
3k
views
Message bus and Message queue understanding
I would like to know if my understanding of Message Bus and Message Queue workings is correct.
First thing first, I need to clear the naming, a service bus is used interchangeably with message bus? ...
1
vote
1
answer
1k
views
Is it a good practice to create a channel for each user in redis message bus
We are using redis message bus and handling messages using a channel. But if our application is deployed in multiple instances then the request and response is passed to all the instances. To avoid ...
3
votes
1
answer
474
views
How to scale out a chat application with SignalR
How would you scale out a chat application (say something like WhatsApp or Telegram) which is using SignalR? Is it even possible or SignalR isn't a solution for this kind of applications?
0
votes
1
answer
188
views
Message Bus message documentation using Swashbuckle.AspNetCore?
I am looking into using the Swashbuckle.AspNetCore v4.0.1 NuGet package in my ASP.Net Core project to generate a SwaggerUI documentation endpoint for my web API that will be used by various teams ...
11
votes
2
answers
11k
views
How to register a generic consumer adapter in MassTransit if I have a list of message types
I am successfully using MassTransit for a silly sample application where I publish an message (an event) from a Publisher console application and I receive it at two different consumers which are also ...
1
vote
3
answers
2k
views
RabbitMQ+MassTransit: how to cancel queued message from processing?
In some exceptional situations I need somehow to tell consumer on receiving point that some messages shouldn’t be processed. Otherwise two systems will become out-of-sync (we deal with some outdates ...
1
vote
1
answer
87
views
Watchdog for Messaging Bus
So I started to work in a semiconductor company as a working student and they gave me the task to write a watchdog for the tibco messaging bus. It should show the workload of the messaging bus, if it ...
1
vote
2
answers
5k
views
Implementation of Message Bus C# microservices
We have few micro services created in .net core 1.0, we are following CQRS pattern and we are also using swagger which list all api's, we have a requirement were in we need to implement Message Bus(...
1
vote
2
answers
1k
views
Using Azure Service Bus to communicate between 2 organizations
We wish to decouple the systems between 2 separate organizations (as an example: one could be a set of in house applications and the other a set of 3rd party applications). Although we could do this ...
0
votes
2
answers
511
views
Postal.js subscription not receiving post from other react component
I have two decoupled components running on the one page and would like to use Postal.js to send a message when one is clicked to the other.
When the first component is clicked it publishes a post:
...
2
votes
1
answer
726
views
Redis messagebus vs. d-bus: what is happening at a low level? Basically the same thing?
I'm honestly surprised I haven't seen this discussed before. My impression is that Redis uses normal internet packet exchange to a server and gets the results back but that d-bus uses unix sockets (...
1
vote
0
answers
300
views
Understanding Enterprise Integration Messaging Patterns
I'm currently reading Enterprise Integration Patterns: Messaging book.
But I've still difficulties to understand patterns and their applications, especially when looking at existing implementations ...
2
votes
0
answers
293
views
Basic message_bus gem setup on Rails 5.04
I'm attempting to setup MessageBus gem ( https://github.com/SamSaffron/message_bus ) on a fresh install of Rails 5.04
So far I've
run bundle,
added message-bus.js and included it in the application....
0
votes
1
answer
572
views
Liferay 7 MessageListener osgi module
When I worked with the liferay 6.1 I created an application that received the message.
Java class:
public class MailMessageBus implements MessageListener
\src\main\webapp\WEB-INF\src\META-INF\...
1
vote
1
answer
273
views
Spring state machine as a message bus
I am currently checking spring state machine as an implementation of a custom service bus.
I have 2 questions :
How do I configure a transition based on timer where the time will be based on the ...
3
votes
3
answers
3k
views
STL Container for storing multiple types of values?
I have a Message structure that I am using with a message bus, and I'd like to send data with messages. The problem is that the data will vary in type; maybe for one message I'll just want to send one ...
2
votes
2
answers
1k
views
Liferay 7 message Bus
In Liferay 6.2 we used to configure Custom mail in messaging-spring.xml and do entery in service.properties.. To achieve the same in Liferay 7 OSGI module portlet, can anyone guide me how could I ...
0
votes
1
answer
2k
views
How to retrieve Dead Letter Queue count?
Question
How do i get the dead letter queue length without receiving each message and counting how many message I received?
My Current Implementation
public int GetDeadLetterQueueCount()
{
...
2
votes
2
answers
4k
views
Using RxJS to implement MessageBus for communication between angularjs modules
Can I create a pub/sub message message queue with RxJS inside angulajs application. I have for example two modules:
ModuleA
ModuleB
They exists as separate npm package but connected in ModuleC - it's ...
0
votes
1
answer
98
views
MessageBus.callbackInterval does not work in production
I've been using the message_bus gem for a few months as a more simplified alternative to a websocket solution. The default MessageBus.callbackIntervalis too wide, so I want to narrow it. I've done ...
4
votes
1
answer
5k
views
How to enable clustering of RabbitMQ Docker containers
I have an issue when trying to enable clustering using the official RabbitMQ Docker image - https://hub.docker.com/_/rabbitmq/. I'm using docker-compose to start my infrastructure, and I cannot get ...
1
vote
1
answer
142
views
How to publish Threshold event of combined connections to Message Bus?
What's the topic of connection threshold events? How do I listen to connection count threshold events over the message bus, and how do I figure out what is the current connection count?
0
votes
1
answer
197
views
ActiveMQ message bus logging handler python
I want to publish message to ActiveMQ when I do LOG.debug or LOG.info,
I have to add handler to logging.
If is there any other pythonic way to do this?
5
votes
1
answer
3k
views
NotImplementedError (only partial hijack is supported.) using message_bus
I'm just adding the gem to the gemfile and writing to the js console:
MessageBus.subscribe('/my_channel', function(data){
alert(data);
});
it throws:
Started POST "/message-bus/...
1
vote
1
answer
2k
views
Publishing on a specific partition of a topic using pykafka
How is it possible in pykafkato publish a message on a specific partition of a topic. In the following piece of code test topic has four partitions and I'm intending to write each message in one of ...
2
votes
1
answer
2k
views
How can I stop MassTransit creating exchange bindings for error messages
I'm trying to listen to the error queue to process failed messages but I can't seem to get MassTransit not to set bindings on message that i want it to listen to within the configuration. The ...
3
votes
1
answer
519
views
ObserveOnDispatcher dose not invoke the handler in UI thread
I have a message bus class which use Rx to push multiple threads events in WPF application.
My problem ObserveOnDispatcher does not invoke the event handler in the UI thread.
Code:
private void ...
2
votes
1
answer
1k
views
Message Bus versus Quasar/HTTP for internal Microservice Calls
I am looking to optimize a microservice architecture that currently uses HTTP/REST for internal node-to-node communication.
One option is implementing backpressure capability into the services, (eg) ...
4
votes
3
answers
8k
views
Publish-Subscribe and a Message bus Python
I'm trying to create a central logging system for some of my python modules.
I want to be able to send messages from a number of modules with logs, then central logger takes them and does the ...
0
votes
1
answer
280
views
Using message bus as replacement for regular message passing between actors (e.g., in scala)
I have a Java web-service that I am going to reimplement from scratch in Scala. I have an actor-based design for the new code, with around 10-20 actors. One of the use-cases has a flow like this:
...
5
votes
1
answer
6k
views
Command Bus/Dispatcher and Handler registration without Dependency Injection
I am trying to implement a consumable library that has read/write Application services for each Domain in the context of CQRS. A Command Bus (or Dispatcher, or whatever it can be called in this case) ...
2
votes
0
answers
131
views
WCF - How to automatically subscribe endpoint address behind load balancer?
I've created a mini message bus which runs operations on its clients (e.g. clear their cache). I'm trying to make it dynamic so every new application added will automatically subscribe its endpoint to ...
0
votes
2
answers
2k
views
Lightweight Message Bus with broadcasting and routing capabilities?
I am trying to find the most light-weight message bus (queue?) that can handle the following:
Producer A subscribes to the bus. The bus is specified via a well known form of identification (like a ...
0
votes
1
answer
100
views
In Android it is better to use bounded service for communicating with a fragment or a service with a eventbus system (MessageBus) is enough?
Im building an Android App in Xamarin that plays music.
I have a service that plays the music and a fragment that display the playlist, some times i want a small feedback from the service and so far i ...
2
votes
1
answer
902
views
DDD Bounded Context Communication Message Bus
I am integrating different bounded contexts with Windows Service Bus and have some questions:
1) How to detected duplicates in other bounded contexts? Store the last processed message sequence? I ...