2,995 questions
-3
votes
0
answers
43
views
Async Events telemetry tracing problem because of batching of events
I'm implementing Telemetry in my Spring Boot web app using OpenTelemetry instrumentation.
All is fine except when dealing with async events.
When I produce/publish, for example 100 events - all ...
0
votes
0
answers
55
views
Hot Chocolate GraphQL Subscription Provider RabbitMQ not connecting
I am using the Hot Chocolate GraphQl library to do real time pub/sub messaging, this works if i create the RabbitMQ connection and channel without using the Hot Chocolate library using the same .Net ...
- 43
1
vote
1
answer
651
views
Mosquitto MQTT: "Connection was lost" error when publishing a message
I am trying to test MQTT functionality and have installed Eclipse Mosquitto on my workstation.
To subscribe to a topic, I use the following command:
"C:\Program Files\mosquitto\mosquitto_sub"...
- 99
0
votes
1
answer
151
views
Do I need to setup anything else to ensure my GCP Pub/Sub Streaming Pull rate is optimal?
I have a GCP Pub/Sub Streaming Pull subscriber that has an Ack rate equal to the Pull rate. I am seeing a lot of latency on my end and I decided to investigate further. I find that the Publish to Ack ...
- 33
0
votes
0
answers
73
views
EventStore drops subscription constantly
Application is written in C# and running on .NET 8, it uses EventStore 23.10.0-jammy.
Code subscribes to event store, but constantly subscription is dropped with exception:
{
"Status":
...
- 2,373
0
votes
1
answer
91
views
Azure Logic App HTTP Trigger Event Grid Topic
I need help ,
I need to develop a Logic app which can be triggered from an API, API backend is a logic app as a backend and HTTP request body payload should be publish to a domain topic .
I am having ...
0
votes
0
answers
41
views
How to track active WebSocket subscriptions dynamically across instances using Redis while using Hazelcast for message distribution?
I have a Spring Boot application where we use Hazelcast to handle pub/sub messaging for WebSockets. However, our current approach has scalability issues:
Every STOMP message is sent to every ...
- 1
0
votes
1
answer
90
views
How to publish once to a topic and route them to different queues based on the topic in the Solace broker?
I want to publish a sale of a product. I just wanted to publish once to a topic like sale/124 where each number represents an id of a store. Then each queue connected to that store only had to ...
0
votes
0
answers
55
views
How to move turtlebot3 without diff drive plugin? (ROS2)
I'm trying to move my turtlebot burger model on gazebo without diff_drive_controller. I commented diff drive plugin from the sdf file. I wrote a code but my robot still not moving.
Here's my code:
#...
0
votes
0
answers
47
views
PyZMQ asyncio SUB socket not receiving last message even with CONFLATE set to 1
I have an async PUB socket as follows:
import asyncio
import zmq
import zmq.asyncio
async def serve(address: str):
context = zmq.asyncio.Context()
socket = context.socket(zmq.PUB)
socket....
- 1
2
votes
1
answer
197
views
Why does Google Pub/Sub deliver messages with the same orderingKey in parallel before calling ack()?
I am working with Google Cloud Pub/Sub, and I am trying to ensure that messages with the same orderingKey are processed in order, as stated in the official documentation. However, I notice that ...
- 67
1
vote
1
answer
49
views
Does acking a message in Google Pub/Sub also ack its duplicates?
I have a subscription in Google Pub/Sub where messages can be either acknowledged (acked) or not acknowledged (nacked). To handle the at-least-once delivery guarantee of Pub/Sub, I use an idempotent ...
1
vote
1
answer
37
views
Issue with TypeScript Generics in Apollo Server PubSub Implementation
I'm implementing subscriptions in Apollo Server using TypeScript and a PubSub class for event handling. However, I've encountered an issue when trying to use a named interface for the PubSub generic ...
- 469
0
votes
0
answers
23
views
Connect Dapr with Apache Pulsar Proxy
What is the way to use Dpar pubsub and connect to a Apache Pulsar proxy instead to a topic directly?
- 73
0
votes
2
answers
235
views
Why aren't nacked messages ending up in my dead letter topic?
So, the scenario is simple: I want to configure google's pubsub emulator to have a dead letter queue topic, and if a message results in an exception in the handler that message should be forwarded to ...
- 21
0
votes
0
answers
181
views
Could not autowire. No beans of 'PubSubTemplate' type found
enter image description here
Here i have used the pubsub inbound channel adapter for sending and receiving the message from publisher and subscriber. This code is taken from the google cloud pubsub ...
1
vote
1
answer
160
views
Why does redis report no subscribers to a channel after I subscribe to that channel without errors?
I am trying to send realtime feedback over websockets, and I'm doing that by sending data over redis from a rest-api server to a websocker server (both written in python/django). In the websocket ...
- 379
0
votes
1
answer
1k
views
Redis pub sub performance impact and limitations when using single channel with thousands of consumers
In our Spring boot apps, we want to use Redis pub-sub to publish messages to a channel that in normal conditions has around 500 listeners.
But on certain rare times/days, the listeners can be as large ...
- 306
0
votes
1
answer
261
views
Configuring Authentication for GCP Pub-Sub Push Subscription Using Terraform Google Provider
I am trying to configure GCP Pub Sub Push subscriptions, Total 3
The push subscriptions have been configured successfully, but i am not able to enable Authentication on the push subscription
...
- 2,357
0
votes
2
answers
162
views
How to avoid duplicate notifications when subscribing multiple times to the same Redis channel?
I have an issue where, if I subscribe multiple times to the same Redis channel, my subscribers start receiving duplicate messages.
Here is my subscription method:
public void ...
-1
votes
2
answers
58
views
Creating Hashmap for Storing References as Values for Pub-Sub
I need to create a hashmap that stores references to other objects as the values, with the names of those objects as the keys (HashMap<String, Consumer>).
The overall system is like a mini-...
0
votes
1
answer
61
views
Can I make my SwiftUI View aware of the circumstances that caused an update to a @Binding property?
Summary
I'm using SwiftUI to synchronize a property on a View with an observable object, but I'm losing critical details about the origin of the updates that get sent from the observable object to the ...
- 95
0
votes
1
answer
339
views
Many channels with few publications or few channels with many publications in Redis PubSub?
I am using Redis PubSub for a notification system in an application. I usually have around 1000 concurrent users. For each user I have a personal channel with the user's ID through which several ...
- 1,008
0
votes
2
answers
109
views
Pub/Sub benchmark: why the benchmark of killing connection each time is better than using single connection
I am a newbie of GCP Pub/Sub, and I try to test the benchmarh of publish message.
we have two scenario below:
both scenario will publish 6 messages.
Scenario 1: create pubsubClient, then publish 6 ...
- 11
0
votes
1
answer
1k
views
What options do I have to scale out Redis pub/sub?
I am implementing a real-time notification system with websockets and redis pub/sub. Basically, the client connects to the server through websockets and from the backend I subscribe to a specific ...
- 1,008