-
Tuning pre-fetch for load balancing in Python
Hi Team, I have built a system comprised of a number of workers, N, (or application processing engines) fed by a single non exclusive queue. Each job on the queue either takes between 20 second and a minute to complete or under 0.1 seconds (because the job on the queue requires no work). Ideally if there are 3 workers (so…
-
Is it possible to adjust the transport window size using v1.4 solace-pubsubplus Python client?
https://docs.solace.com/Messaging/Guaranteed-Msg/Configuring-Queues.htm says "Modifying max-delivered-unacked-msgs-per-flow may negatively impact performance if it's set lower than the transport window size used by consuming clients." Is possible to set the transport window size for a subscriber using the latest version…
-
JMS Queue Browsing (Received incoming message with no active flow)
I am developing a Spring Boot Application (version 2.7.5). Currently, I'm trying to create a queue broswer using the following code: public int getMessageCount() { return jmsTemplate.browse(fromQueueName, new BrowserCallback<Integer>() { @Override public Integer doInJms(Session s, QueueBrowser qb) throws JMSException {…
-
Play Solly’s Holiday Cheer and win great prizes!!!
Want to have some extra fun this holiday season? Then play our Solly's Holiday Cheer game! You may also win great prizes! When: December 6-9 and December 12-15, 2022 Where: https://sollychallenges.solace.events/ How to play: A new gift “unwraps” to reveal a new question every day at 9 AM EDT during the game period except…
-
With TTL 2 minutes setting exactly how many number of messages got expired for specific VPN
How can we check in solace with TTL 2 minutes setting exactly how many number of messages got expired for specific VPN? please suggest a way to identify? tried checking with command 'show message-spool message-vpn vpn-name stats' when we tried running load with 10k messages observed 'TTL Exceeded' count as zero only.…
-
Not able to delete durable queue on standalone server
Tried disabling the endpoint and I’ve deleted many queues using sol admin, but on refreshing the screen, it reappears, not sure why it is not deleted. Please suggest! xyz1234# show config-sync Admin Status : Enabled Oper Status : Down (redundancy shutdown/replication shutdown) SSL Enabled : No Authentication Client…
-
DMQ Eligible Flag set on Publisher (violates pub sub principles)
The principles for pub sub are to decouple publishers and subscribers from each other. That publisher need to set DMQ Eligible to true (default = false) impacting a correct set-up on subscriber to make use of DMQ (Dead Message Queue) is violating this principle. Even worse as subscriber has done everything correct: *…
-
Distributed Tracing Context Propagation
Hello Solace-Community, I am currently playing around with the distributed tracing and telemetry settings.I tried to create a simple use case with a sender, two static bridged Brokers and a receiver. Both sender and receiver are SDKPerf (sdkperf-jms-8.4.9.27). All of them are connected to the same opentelemetry collector…
-
How to slow down consumption rate in my Solace Consumer Application
I have a Spring Boot based Java application which reads messages from a Solace queue(let's say A) using javax.jms. Then my application applies a 10 seconds delay to each messages individually(using DelayedQueue). Once that 10 seconds have been passed, I push the message to another Solace Queue(let's say B). It all works…
-
Help to get done with online lessons
Took the "Solace Certified Solutions Consultant Path", did everything but for some reasons the system insists that I have not yet completed the "Event Broker Monitoring" (23 our 24 lessons). I had watched the lessons multiple times, on Safari and Chrome. It just does not let me done. I know it is embarrassing (or even…
-
Static linking (on Mac x64)
Hello, normally I use dynamic linking with solclient library and it works as expected. Out of curiosity I tried static linking. I linked following libsolclient.a, libsolclientssl.a, libcrypto.a, libssl.a and Kerberos framework. When I run my app it fails with EXC_BAD_ACCESS when running solClient_cleanup according to LLDB…
-
What's Next with Ed and Ali: Episode 2 - Distributed Tracing, ARM Support, Partitioned Queues
In this episode, PubSub+ product team leaders Ed and Ali take a deep dive into PubSub+ Distributed Tracing, complete with an implementation demo in our cloud service - including the supported OpenTelemetry collector. 0:00 Overview 1:52 Advances in Distributed Tracing 13:34 Distributed Tracing Architecture and Performance…
-
Kind of guaranteed messaging with mqtt QoS 0
Hello solace community, i have a mqtt subscriber client that can only work with QoS 0 and non durable queues. Let's say mqtt Client MQ1 subscribes to a/b/c with queue QU1. On the other hand i want to prevent data loss and have the risk that the mqtt client is not online and the non durable queue QU1 is not there. So if the…
-
Difference between 'Actual Maximum' and 'Configured Maximum' stats in Solace Broker
We have a Solace PubSub+ Event Broker where we would like to configure certain limits, such as max-endpoints in a message VPN, max-egress-flows, etc. However, on changing a value (e.g. changing max-endpoints to 4500) using CLI or SEMP, we see the following output: Queues and Topic-Endpoints Maximum Queues and…
-
SDK Notice while trying to connect to a Solace C API session
Hello everyone, After trying to connect to a session using Solace C API, I get the following output: SDK NOTICE Thu Nov 24 08:16:34.688 2022 solClientSmf.c:7215 (7f0ddd9a2700) Read failed from transport 'TCP' of session '(c4,s1)_od_fo_prod' due to 'Peer closed socket, fd 27, cannot read', client name '(ommited)', VPN name…
-
Distributed Tracing: ACCESS ERROR (amqp:unauthorized-access)
Hi, I'm testing the new dsitributed tracing feature, so I deployed a local stack with Docker: solace/solace-pubsub-standard:10.2.1.32 otel/opentelemetry-collector-contrib:0.67.0 jaegertracing/all-in-one I setup the telemetry over the UI and are using the "Try me" to send message, i find them in my Queue and also in the…
-
PubSub+ Support for MAC M-Series Processors Now Generally Available
Previously we announced the availability of an Early Access release of PubSub+ supporting Apple MACs with M-Series processors. Today we are happy to announce that this is now Generally Available in PubSub+ version 10.2.1. Now that this functionality is GA, you can get it in all of the normal locations where you get PubSub+…
-
Need a Solace example demonstrating how to use OAUTH using C++ Solace API.
I did go through the Solace Doc for C++ API but didn't find any Sample example explaining house to use Solace C++ API to enable OAuth Authentication. Is there any Sample code available? Can anyone please guide.
-
Integrate External Schema Registry With Solace
Hello Members Is there a way to integrate external schema registry with solace ? I am already aware that there is a "Event Portal" that we can use but we have an already available schema registry that we want to use.
-
How to speed up solace standalone docker?
hello, i'm working with solace pubsub image (solace/solace-pubsub-standard:latest), and using it in testing takes a lot of time, as it takes almost 30 seconds to start it up, compared to a few seconds for other images i'm using (e.g. mongodb). is there a way to speed up the image startup time by allocating more resources…
-
Why do flows stop receiving message un-notified?
Hi, we implemented a Solace consumer using the .NET API following the guidelines (https://tutorials.solace.dev/dotnet/persistence-with-queues/). We use one session for several flows on distinct queues, respectively. Sometimes, one of these flows stops receiving messages even though there are still messages in the queue,…
-
solace failed to provision endpoint- While trying to add queue from C# application
hi, I am new to solace, was trying to create the queue with sample C# code given solace site- https://tutorials.solace.dev/dotnet/persistence-with-queues/. however, i am getting error while executing the code- "solace failed to provision endpoint" I am just wondering what kind of error is this
-
How to implement task queue using Solace
Hi, I would like to use Solace for a task queue though Solace is overkill for my needs, but I hope it can meet my use case. I have 2 publishers putting guaranteed messages on a queue, and a single consumer listening to the queue initially, but the numbers of consumers scales up when there are many messages on the queue.…
-
Solace learning reference list for newbies
As part of my own learning when I joined Solace few months back, I collected all references available and utilized them as a ready reckoner - code, lab, tutorial and reading. Sharing it, hoping that new members could benefit. Solace - GitHub Solace Products Solace Samples Solace Labs References Solace Community References…
-
GoLang API Connect stuck
Doing an err = messagingService.Connect() leads me into dead end, client application is stuck forever, blocking any further execution. Is there something I can check on what's wrong? I can actually see my client is connected, telling from the web admin, having a subscription. But client application won't proceed any…
-
Distributed Tracing Demo
Hi, we are currently testing the Distributed Tracing Feature [1]. After some initial difficulties we got it running. We are using the following docker containers: jaegertracing/all-in-one:1.39 otel/opentelemetry-collector-contrib:0.64.1 solace/solace-pubsub-standard:10.2.0.26 We setup the telemetry over the GUI and are…
-
Moving messages from deadletter queue to main queue in Solace
I am new to Solace and using Boomi to push messages to Solace. I tried JMS Toolbox to view the messages. Do we have any tools or any options to move the messages from the Dead Letter queue to Main queue. I am looking for any of the options available. Can you please guide me in right direction please.
-
Distributed Tracing / OpenTelemetry: Testing Solace Implementation and trying our own
Hey there, we are trying to implement Distributed Tracing in our Solace Environment. We are struggling to get your implementation (https://solace.community/discussion/1553/distributed-tracing-is-now-generally-available#latest) to run correctly. We have some questions: In your presentation video…
-
Solace JCSMP Streaming - Code Sample
Hello, From the perspective of using Solace JCSMP with Apache Camel, I m working on a POC to read messages from a Solace Queue in streaming mode, (read 100 messages and Ack). Could you please share with me a sample code, where we use JCSMP API to consume messages in streaming mode? Thank you!
-
API says it can't send while waiting on DNS
I'm trying to do a pub/sub tutorial, both publishing 1 message and subscribing to the queue. The original JS code as Solace created on Github. I'm trying to Typescript-ify the code and now it says OperationError: Cannot perform operation SEND while in state WaitingForDNS PING resolves the host URL to an IP address, so at…
