Questions tagged [message-bus]

The tag has no usage guidance.

Filter by
Sorted by
Tagged with
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 ...
Afkaaja's user avatar
  • 47
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 ...
saurav.rox's user avatar
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 ...
Chris's user avatar
  • 43
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 ...
gsn1074's user avatar
  • 127
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 ...
Nilesh's user avatar
  • 20.7k
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 ...
Diego Frehner's user avatar
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 ...
BaltoStar's user avatar
  • 8,295
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 ...
XDS's user avatar
  • 3,854
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 = ...
Jb_Dda's user avatar
  • 41
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 ...
Geertie's user avatar
  • 267
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 ...
Balajee Venkatesh's user avatar
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 ...
diegosasw's user avatar
  • 14.1k
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 ...
Patola's user avatar
  • 547
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 ...
Claus Appel's user avatar
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 ...
chrisbyte's user avatar
  • 1,493
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? ...
user avatar
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 ...
Abinash Panda's user avatar
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?
amiry jd's user avatar
  • 27.1k
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 ...
Ryan Renne's user avatar
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 ...
diegosasw's user avatar
  • 14.1k
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 ...
Tenek's user avatar
  • 437
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 ...
NECben067's user avatar
  • 427
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(...
PaTHP's user avatar
  • 325
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 ...
Raj Rao's user avatar
  • 8,946
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: ...
Matt Hough's user avatar
  • 1,059
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 (...
Guido's user avatar
  • 21
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 ...
Trent's user avatar
  • 5,815
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....
jmastuba's user avatar
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\...
a.gaykevich's user avatar
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 ...
pohes's user avatar
  • 11
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 ...
Accumulator's user avatar
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 ...
Matrix Panchal's user avatar
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() { ...
Dan Cundy's user avatar
  • 2,699
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 ...
hackp0int's user avatar
  • 4,084
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 ...
Cjoerg's user avatar
  • 1,285
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 ...
Adrian Oprea's user avatar
  • 2,410
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?
Jeffrey's user avatar
  • 115
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?
Nilesh's user avatar
  • 20.7k
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/...
Alter Lagos's user avatar
  • 12.2k
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 ...
ahj's user avatar
  • 745
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 ...
Kevin Smith's user avatar
  • 13.9k
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 ...
Bassam Alugili's user avatar
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) ...
Robert Christian's user avatar
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 ...
akalikin's user avatar
  • 1,101
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: ...
Mahdi's user avatar
  • 1,788
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) ...
MonkeyJamboree's user avatar
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 ...
BornToCode's user avatar
  • 9,665
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 ...
Ashkan Kh. Nazary's user avatar
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 ...
CDrosos's user avatar
  • 2,428
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 ...
morleyc's user avatar
  • 2,259