-
Relation between Window size and unack messages in message consumer service
Hi, The page nicely summarises from publisher acknowledgment point of view Is there something similar for consumer acknowledgment? We see window size often dropping to 0 when unack messages are around 255. The listener/consumer service is built using Spring Cloud Stream. Thanks Tilak
-
Is there any way to copy queues from one event broker to other
I am planning to create event broker service for PRODUCTION environment. Existing event broker instance I used for DEV and QA purpose. I know cloning whole event broker service but not sure about if we do have any way to copy the queue from one event broker to another.
-
SDKPerf | JMS | Client cert based authentication
Hi Team ,Can anyone please guide me on how to do cert based authentication from sdkperf jms with cert and privake key or p12 file.
-
health-check for solace
Hi Team, I want to create a health-check for solace which will check it can make connection to topic or not. This check will be called from a MuleSoft API. Only connection check is required. Publish/Consume is not needed. Please let me know how I can implement this use-case.
-
pubsubplus-connector-aws-kinesis
Hi Trying to setup connectors pubsubplus-connector-aws-kinesis , but struggle to understand the documentation. 1. Were must this be running? Connecting to Services on the Host If services (e.g. PubSub+ event broker) are exposed on the localhost, they can be referred to using the container platform’s special DNS name which…
-
Solace connectivity for Azure ADF
Hi Team, We have our data present in AWS Yugabyte. We are planning to use Solace for pub Sub. How we can move data to Azure Data Factory using Solace for pub Sub. Any expert please advice.
-
PubSub+ Maximum Message VPNs
Hello. My team and I require a Message VPN for each and every one of us, all of which should be on a single Solace instance (so there's no resource wasting). I tried reducing all the settings (of the VPNs) I could get my hands on to the minimum possible, but i cant seem to create more than 3 VPNs (including the default…
-
Solace supporting FHIR
Does Solace supports HL7 FHIR ?
-
arm64 on Linux
Hi, I'm exploring migration to arm64 architecture atm, but as soon as I publish my app for linux-musl-arm64 architecture and try to run it in Docker container based on Alpine 3.1 memory usage goes to 100% and container being killed by runtime. When switched back to x64 same code runs fine. Is Alpine supported at all for…
-
Round Robin configuration
Hi! I have a question abount using Solace Python SDK to connect to a non-exclusive queue. The Solace PubSub+ is self hosted and there are two consumers connected to a non exclusive type queue. The consumer takes about 5 seconds to send an ack signal to the broker, during that time consumers displays different Delivery…
-
consumer setting to connect solace system
What are the installation to be done at consumer system( windows) to connect solace system
-
Visualizing of data inside Solace topic/Queue
Hi, We have a requirement to see what field values are specified in the given record sent to Solace. Is anyone aware of any tool/utility that provides data visualization? Thanks. Regards Sameer
-
Which correct protocol should I choose?
Hi! I'm new working on Solace PubSub and despite the fact I've been reading a lot, I didn't understand which is the correct protocol I should use. For example, I have an application publishing more than 1k events per hour on dynamic topics. It can be company/salesorder/usa/123/234, company/salesorder/usa/453/1/45,…
-
spool, spool-cache, and spool-cache-backup
I have reviewed the documentation on spool, spool-cache, and spool-cache-backup but need a more detailed explanation of their respective roles.
-
About spool size
I want to set the spool size. If the OS has a separate disk capacity of 1TB and the spool area is mounted separately, could you provide the optimal ratio for spool, spool-cache, and spool-cache-backup?
-
Number of Unacknowledged Messages
Hello All, I am trying to clean up the shutdown of my service, and delay it until all messages have been processed. I call the Stop() method on all of my IFlows, but I then want it to wait until the number of Unacknowledged messages drops to 0. I can see in the console the number of unacknowledged messages on the consumer,…
-
Debizium Connector
Hi, I posted to check on this a few months back, but haven't heard any update. Opening this up again to see if there is any news
-
Each Message is not removing from Queue after acknowlegement Flow.Ack(message.ADMessageId)
Hi, I am consuming messages from queue using .net c# . I am using MessageAckMode.ClientAck. It's acknowledging with Flow.Ack(message.ADMessageId) immediately message recieving. But it is not removing each message after acknowledgement from queue. All messages are removing at once after the flow end.
-
Drain Queue via MQTT
Hi everybody, I'm trying to drain a queue via MQTT. My queue is confingured like this: Following https://docs.solace.com/Messaging/Reserved-Topics.htm and https://docs.solace.com/API/MQTT/MQTT-Topics.htm#Special I created a client that subscribes to the Topics (_P2P/QUE/test-queue, _P2P/QTMP/v:default/test-queue ) that…
-
Is there a way to enable Audit logs in pub sub+ event broker and fetch those logs?
I want to enable audit logging in pubsub event broker which I am running it as docker container. Is there a way to do that? I see Audit logs are there in pubsub cloud but is it available in pub sub event broker? #audit
-
Is there a way to enable Audit logs in pub sub+ event broker and fetch those logs?
I want to enable audit logging in pubsub event broker which I am running it as docker container. Is there a way to do that? I see Audit logs are there in pubsub cloud but is it available in pub sub event broker?
-
Does Solace tibco EMS supports JavaRTO as consumer?
Hi Team, We are planning to migrate from TIBCO EMS to Solace. We have done some PoC and planning to Java RTO Messaging API. We have a use case where we need to sync data between Solace consumers and TIBCO Producers. We heard that Solace provides the connector for this but we are not sure if we can use it where the producer…
-
New Access Levels for Event Portal Users to Use Runtime Event Manager
Hi all, 📣 We are pleased to introduce new access levels for Event Portal Users to use Runtime Event Manager. Previously, only Administrators and Event Portal Managers could access the Runtime Event Manager and its environment-focused features. Now, users with the Event Portal User role can be assigned the new EP Runtime…
-
Encountered Error - Timed out waiting for credit to send Message
I using Camel AMQP client to receive messages from other EMS and publish to Solace EMS. However i encountered this error - "Timed out waiting for credit to send Message" if i set jms.sendTimeout=2000. 1) May i know how does broker issue credit to publisher? 2) Can I increase the credit at the EMS broker? at…
-
SEMPv2 API : parameter in __private_monitor__ not in the public monitor
By checking the Solace console I found that the private_monitor__ contains a (query) parameter which is not present (or documented) in the url. Exemple for queue listing filtered by owner:…
-
In the .NET API, why isn't the `CorrelationKey` set on the `RejectedMessageError`?
I have an application with messages sent to Persistent and a session event handler checking for SessionEvent.RejectedMessageErrorstatuses. I wan to add some special handling logic for the scenario where a persistent message is too large (>30MB), but for some reason the SessionEventArgs.CorrelationKey is always null,…
-
Troubleshooting frequent / high amounts of fragmentation on an event broker
Hi all, Trying to get a better understanding of fragmentation and potential culprits of high amounts of fragmentation occurring in a particular event broker. Defragmentation is running daily on a schedule, not threshold. But we are seeing within an hour after defrag runs successfully the estimated fragmentation reaches 99%…
-
How to achieve Topic + Queue mechanism using NodeJS & AMQP
Hello, I'm using NodeJS as my tech stack and created a Queue and that queue is subscribed to the topic. Mechanism: Publish a message to the topic and subscribe to the msg from the queue, basically Topic to Queue Mapping. Query: I want to build the above mechanism using the AMQP protocol with NodeJS. Tried Approach: I've…
-
Selectors in node js
I see that selectors are not available in javascript API Will this feature ever come to javascript ? What are some alternatives options for consuming messages based on specific message headers in javascript ?
-
Showing exemplars on Prometheus
Hi All, I am trying to use prometheus to display data with exemplars to show traceID but I cannot seem to get it to display the exemplars I used this repo as a base and placed in prometheus and grafana tempo. #Docker Compose version: '3.5' networks: solace_msg_net: name: solace_msg_net external: false driver: bridge…
