-
Delete All the Messages on a Queue Using Legacy SEMP
For deleting all the messages on a queue you can use the following legacy SEMP command: admin message-spool message-vpn <vpn-name> delete-messages queue <queue-name>SEMP Request:<rpc semp-version="soltr/9_6VMR"> <admin> <message-spool> <vpn-name>vpn-name</vpn-name> <delete-messages> <queue-name>queue-name</queue-name>…
-
Why is the flow in the HandleMessageEvent sometimes null?
Hi, we implemented a Solace consumer using the .NET API following the guidelines (https://tutorials.solace.dev/dotnet/persistence-with-queues/). When runnung some tests we figured that sometimes messages were not properly acknowledged and removed from the queue. When debugging the HandleMessageEvent we found that…
-
Pubsub+ Now Offers Configurable Replay Topics!
Hey Solace operations and developers! PubSub+ is taking the replay log to the next level of flexibility by allowing you to configure exactly which topic is mapped to your replay log. PubSub+ Event Broker 10.0.0 allows you to customize exactly which topics are sent to your replay log. Your broker administrator to configure…
-
Sending json message using Python to queue using Kerberos authentication.
Does python api supports solace Kerberos authentication?. If so can any one share sample code? If not what are other ways to use Kerberos authentication for sending json message.
-
New blog post for developers | What We Announced in our June ‘22 PubSub+ Product Update
Yesterday I was joined by a few of the leaders of our product team to debut and demonstrate some of the really cool capabilities we’re adding to PubSub+ Platform. Our main goals these days are to make it easier for enterprises like yours to integrate applications in an event-driven manner, and to manage the resulting event…
-
[That Tech Show Podcast] The Magic behind Event-Driven Architecture with Jamil Ahmed
Listen to the podcast where Jamil Ahmed, Distinguished Engineer from Solace, shared with That Tech Show hosts Samuel Gregory and Chris Addams the "magic" behind Event-Driven Architecture (EDA). Podcast link: https://www.linkedin.com/posts/jamilahmed_tech-podcast-eventdrivenarchitecture-activity-6943149842852397056-TiLP
-
Python API limits message size to 0.176MB while Solace configuration has 10MB limit
Hello all, I am trying to use the Python API from the official repo (https://github.com/SolaceSamples/solace-samples-python/blob/master/patterns/guaranteed_publisher.py) to publish some messages of size 3-5 MB to a Solace queue, but all the messages under 0.176 MB work and the ones above do not work. I am trying strings…
-
How does the sslvch option of SDKPerf work
In the newer version of SDKPerf, such as sdkperf-jcsmp-8.4.5.19, sdkperf-jms-8.4.6.5. There is an option "sslvch", the description is "Enable validation of certificate hostname". How does the validation work? and what is the expected out put when this option is applied? I tried different combinations, but didn't see any…
-
.Net integration using .pem certificate
Hello, I'm looking for some help on how to import .pem certificate and use it .Net code. Any help or sample implementation for reference will be appreciated.
-
When import the certificate getting error access denied
When i used the sanbox account certificate not got any error when we try to import the UAT certificate in our application getting access denied error when both certificate have same detail we used .pfx that extract from .cer file.
-
Reply Topic name in InboundMessage - GOLANG API
HI, I need to get reply to topic in message received in gateway mode.. It's possible? Exist some a property? I tried thus... reply_to, _ := message.GetProperty("reply_to") but not working... returned nill... How to do for get reply topic name in the message???? I am using GOLANG API 1.0.1... Thanks for help..
-
How to set up consumer in Azure Container Instances using python qpid proton
Hi all, I have been trying to deploy a consumer as an Azure Container Instance implemented in python, which uses qpid proton. When running the Docker image locally it works without any issue, however when deploying the image as an ACI, I obtain the following error: ```2022-06-03T16:05:19UTC ERROR: proton - Couldn't…
-
I want to add delay on consumption of messages. Delay will be dynamic in my application.
I want to add delay on consumption of messages. Delay will be dynamic in my application. Example: For Message A delay will be of 1 min and for Message B delay will be 2 min. I tried with below code of snippet but it's not working. TextMessage msg = JCSMPFactory.onlyInstance().createMessage(TextMessage.class);…
-
Solace throughput scaling
What is the rate of consuming message/sec for a consumer with 1 concurrency in spring cloud stream app with solace. Just wondering what would be throughput / hour if there is just one consumer with 1 concurrency smoothly. Using Physical Solace Appliances.
-
Found issue, Where messages were stuck in the queue, it wont accept and let consume from queue
The messages were stuck in the queue, we cant publish anything to it but the problem is the listener is not even consuming them to create space for new messages. Caused by: com.solacesystems.jcsmp.InvalidOperationException: Tried to perform operation on a closed XML message producer 2022-06-02T15:38:25.309-05:00…
-
ELK / Logstash performance testing
Hi all, Not really (specifically) a Solace thing, but wondering if anyone out there has done any performance testing with Logstash, using either the JMS plugins or other (MQTT Beats?). I'm looking for any ballpark ideas on throughput, performance of the Logstash VM, etc. And if you've done any load testing, how did you…
-
CLIENT EGRESS MESSAGE DISCARD | Transmit Congestion
We use guaranteed messaging. How to interpret Client Egress Message discard due to Transmit Congestion ? Does these mean 3014 message got discarded ? If yes, Why the message should get discard in guaranteed messaging case ! Ideally it should spooled in Durable Queue. ****************************** Egress Discards…
-
Can we have application connect to multiple Data Centers to achieve active/active capability
We have a use case where we have 2 data centers with guaranteed messaging , currently we want HA hence both data centers are active all the time, so we have DC1.VPN1 with Q1 that is consumed by Client 1 DC2.VPN2 with Q2 that is consumed by Client 2 The publishing of events happen either in DC1.VPN1 or DC2.VPN2 based on…
-
Error running API-GOLANG app in windows 10
Hi, I am trying to execute app API-GOLANG in Windows 10, but the following error is present: # solace.dev/go/messaging/internal/ccsmp ..\..\pkg\mod\solace.dev\go\messaging@v1.0.1\internal\ccsmp\ccsmp_container.go:29:10: fatal error: solclient/solClient.h: No such file or directory 29 | #include "solclient/solClient.h" |…
-
Spring Cloud Stream solace error handling
In the codelabs example it suggests we shouldn't use global error handler as suggested by spring because binder will already be handling it. Is there a recommendation how you'd configure error handler channel for an application which uses a system property to determine the destination queue in order for the application to…
-
Queue and consumer number limit with solace docker image
Hello, We are using solace image tagged (public.int.repositories.cloud.sap/solace/solace-pubsub-standard:9.13.1.38) in our CI. As it uses more memory ,this instance is shared across all the PRs in CI. We are using the default VPN for connection settings. is there a limit of 1000 queues and 1000 consumers on the open-source…
-
how to stop message from being sent to next solace topic while going through chain of function?
how to stop message from being sent to next solace topic while going through chain of function? e.g. inTechVal|inFuncVal|map|persist|report-in-0: input inTechVal|inFuncVal|map|persist|report-out-0: output here message goes through inTechVal|inFuncVal|map|persist|report all of these functions but if i want to terminate and…
-
Is there a way to get a Queue Created Date in Solace?
Hello All, I would like to know if there is a way to get the queue created date via SEMP API's or any other means in Solace? Have tried with SEMP Over Message Bus & Monitoring SEMP API but it does not speak about when the queue was created. Thanks Tejas Chowsalkar
-
How To Create Docker Image For Go Client ?
Hi Team, Tried Creating the Docker image for Go client, but Facing the Below Error seems the Go package has issues, can someone help on this? # solace.dev/go/messaging/internal/impl/constants 53 /go/pkg/mod/solace.dev/go/messaging@v1.0.1/internal/impl/constants/default_properties.go:35:2: undefined:…
-
JCSMP Blocking Publisher Example: Timeout configurable
Hi Community, I have a question on the JCSMP BlockingSynchronousSendGuaranteed.java sample: What happens, if the broker doesn't respond with either an ACK or a NACK? Is this even possible or under which conditions could that occur? (I read something about disk full could be one potential situation.) Is there a timeout for…
-
New blog post for developers | Event-Driven Machine Learning: A Stock Trading Session Demo
Machine learning is an element of artificial intelligence, namely use of computer algorithms (machines) that can automatically adapt and theoretically improve their operation (learn) by building a model based on sample data, making predictions about the outcome of particular action it decides to take, and factoring the…
-
Cache instance status NotAvail in Docker demo instance
Hi guys, noob question. I am trying to setup most basic cache configuration. I am running this in linux container on Windwos 10 in WSL2. Commands: _docker run -d -p 8080:8080 -p 55555:55555 --shm-size=1g --env username_admin_globalaccesslevel=admin --env username_admin_password=admin --name=solace…
-
How can i gurantee sequence of events to be consistent.
Lets assume i have 4 events Event A producing message to Queue AQ Event B producing message to Queue BQ Event C producing message to Queue CQ Event D producing message to Queue DQ Lets assume consumer named TestConsumer consumer consumes messages from all 4 queues. I want to make sure when solace emit these events it will…
-
Can we discard or reject message in solace streaming?
this is our declaration spring: cloud: function: definition: inTechVal|inFuncVal|map|persist|report stream: function: bindings: inTechVal|inFuncVal|map|persist|report-in-0: input inTechVal|inFuncVal|map|persist|report-out-0: output here solace streaming is sending message out to solace as per out mapping e.g. after…
-
Is it possible to have DMQ configured with a remote Queue using VPN Bridge/DMR
Hi, Is it possible to have a DMQ configured with a Queue that is not in the current VPN but in another remote VPN/Data Center ? This will help in handling cases when a Queue events/messages are not being processed due to inactive client in one VPN/Data center , so it can be sent to a DMQ in a different active VPN/data…
