3,007 questions
1
vote
0
answers
31
views
Setting to increase GCP Pub/Sub subscription send throughput
I am trying to figure out the source of latency in my application as I am seeing a number of un-acked messages per unit time on the dashboard for my GCP Pub/Sub subscription. My application simply ...
- 13
0
votes
1
answer
59
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 ...
- 13
0
votes
1
answer
76
views
Why am I getting several seconds latency delay with my GCP Pub/Sub subscription/subscriber settings?
I have a GCP subscriber that uses Streaming Pull API to pull messages from a GCP subscription. There is only one GCP subscription and one subscriber attached to this subscription. I am seeing delay of ...
- 13
0
votes
0
answers
49
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,343
0
votes
0
answers
7
views
Want to Know the update Mask for Business notification API
"error": {
"status": "INVALID_ARGUMENT",
"message": "Request contains an invalid argument.",
"code": 400,
"details": [
{
&...
- 19
0
votes
1
answer
52
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
23
views
How to Implement a Form Watcher for External Users in Google Forms?
I need to implement live notifications when respondents fill out a Google Form. While Google Script Triggers would typically work, they are limited to 10 triggers per user, which is not sufficient for ...
- 1
0
votes
0
answers
33
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
49
views
How to allow a client only to subscribe to a specific queue in the Solace broker
I am trying to allow a user to subscribe only to a specific queue without the possibility of publishing to the same queue. When I go to the ACL profile of my user, I can only set up which topics it ...
0
votes
1
answer
41
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
32
views
Intermittent Issue Saving Cumulated Response From SSE Stream
was wondering if someone would be able to give me a hand at trying to figure out an issue I'm having with an SSE stream.
Basically, I'm trying to fully integrate streaming and pubsub into a AI chat ...
- 13
0
votes
0
answers
29
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
2
answers
43
views
NServiceBus Pub/Sub on Azure : Publishing in a message handler requires publisher to have a corresponding message handler
Overview of problem:
I have two services with two different endpoints, I would like to exchange messages between them using pub/sub only. In the future there may be other services that need to process ...
- 136
0
votes
0
answers
37
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
0
votes
1
answer
29
views
MassTransit central configuration of endpoint prefetchcount
We are looking for a way in MassTransit to configure the prefetch count for all endpoints with a few lines of code while still being able to configure a different setting per endpoint using .NET ...
- 193