-
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…
-
Solace Topic Destination Header
Hi Team - this is regarding the scenario of publisher using topic string as destination header (using topic hierarchy) and consumer using wild card (> or *) to consume required message. This is in order to facilitate filtering at event broker level. Does the above scenario ensure guarantee message delivery when none of the…
-
Connection reset by peer using python urllib2.urlopen()
Hi Team, We have a "Connection reset by peer" when using python2 urllib2 to send message to solace. This error is resolved if we restart/retry the job. Any ideas what might be causing this? f = urllib2.urlopen(req , timeout = 7200000, context = ctx) File "../urllib2.py", line 154, in urlopen return opener.open(url, data,…
-
Failed to retrieve configuration for syslog forwarding.
Hi Community, I am trying to configure a syslog forwarding on a test broker of developer class and not able to retrieve it's configuration. It's showing contact support. I have tried to configure the syslog forwarding using broker cli but looks like in console it's still showing inactive. Kindly suggest solution for it or…
-
JCSMP Ack mode
Hello. I'm creating a Jcsmp session based on this tutorial: solace-samples-java-jcsmp/QueueConsumer.java at master · SolaceSamples/solace-samples-java-jcsmp · GitHub. even if I'm setting the flow_prop.setAckMode(JCSMPProperties.SUPPORTED_MESSAGE_ACK_CLIENT); and passing the flow_prop to the session as in the tutorial. the…
-
Are you going to AWS: reInvent 2022
Hi folks, we're going to be at AWS re:Invent and would love to have the opportunity to meet you in person. We're going to be hosting a developer evening and would like to invite you to come along. IF you're not attending but your colleagues are please send them the link to register: https://try.solace.com/top-golf-outing/
-
Solace Apache Beam connector with SEMP instead of SEMP-over-message-bus
Hi, The solace-apache-beam connector (https://github.com/SolaceProducts/solace-apache-beam) uses SEMP-over-message-bus to check backlog of queue. Has anyone tried to migrate that to SEMPv1 queries ? Some environments are not happy with SEMP-over-message-bus. Thank you Uli
-
Connectivity Issue from TIBCO BW
Hi All, Getting below error while connecting from TIBCO BW5.x to Solace, we have increased consumer limit also but no use, could you please help. com.solacesystem.jscmp.JSEMPErrorResponseException: 503 Max Router Publishing Flow Exceeded Thanks
-
Expected behaviour if unplug the network cable to a consumer
Hi, there are multiple consumers to a non-exclusive queue, if after a message has been delivered to a consumer and before the consumer ACK the message, the network cable of the consumer is unplugged, what is the expected behaviour? Will the message be delivered to other consumer after a certain period of time? And if yes,…
