-
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…
-
Backpressure / message delivery and the Python API
Hi, We have a non exclusive durable queue with several consumers (compute worker) who connect using the Python API. Each consumer runs the MessageHandler in a separate thread, essentially just filling up a buffer with messages, the messages are then consumed by the main thread in the compute worker and results sent out.…
-
Is there a way to get the List of Topics, applications are using to pub and sub from a broker?
For governance purposes, there is a need to know the topics which are being created by various applications on the broker. As I know (and I might be wrong), there is no intuitive way to get a list of topics under usage on a broker. As of now, we are not using Event Portal and hence do not have an Event Catalogue.
-
Spring cloud stream solace binder connection
Hi Team, I am trying to connect to solace using spring cloud stream solace binder with all the properties in application.yaml . It keeps giving error for connecting to localhost. Error creating bean with name 'com.solace.spring.cloud.stream.binder.config.SolaceMessageChannelBinderConfiguration': Invocation of init method…
-
Reason for Solace CLIENT_CLIENT_DISCONNECT
Recently some of the microservice AMQP applications are disconnected based on the solace event logs. However, the microservice AMQP applications did not detect any "CONNECTION_CLOSE" event. And, the applications did not trigger DISCONNECT action. Is there any documentation of the reasons and the explanation for the causes…
-
SSL connection problem
Hello again, I used the scuresession.js file of nodejs toturious. And I created a Private Certificate Authority using this command: openssl req -newkey rsa:2048 -nodes -keyout MyRootCaKey.pem -x509 -days 365 -out MyRootCaCert.pem Then I created a certificate using blew command: openssl genrsa -out client1.pem 2048 openssl…
-
ITransactedSession in .Net
Is there any sample on how ITransactedSession work in .Net with Confirm Delivery (Acknowledged) ? Is CreateFlow require when work on Producer and how its Acknowledgement work within a commit?
-
How to connect the event broker using ssl connection?
Hello, solace team I am a beginner and I want to ask some simple questions. I have created a PubSub+ Software Event Broker on my local docker following blew tutorial：https://docs.solace.com/Software-Broker/SW-Broker-Set-Up/Containers/Set-Up-Docker-Container-Windows.htm And I also connected to the broker using the node js…
-
What's the best Java based API (JCMSP, JMS or new Java) to achieve blocking publish behaviour?
Hi All, What's the best Java based API (JCMSP, JMS or new Java) to achieve blocking publish behaviour? The application team is using JCSMP currently and having a hard time achieving the behaviour they are looking for, which is: Publish a message Wait for Ack or Nack (and do error handling) Repeat They have strict ordering…
-
Certification exception- No subject alternative DNS name matching solace found
i have A service running on AWS ECS cluster that connects to Solace broker instance, it’s been working for last few years but suddenly from past few days it’s giving error like “ Client-1: Connection attempt to host ‘solace’ ConnectException com.solace systems.jcsmp.JCSMPTransportException: CertificateException - No…
-
C# .net integration getting error Failed to create session
I follow the instruction in this tutorial: https://solace.com/samples/solace-samples-dotnet/publish-subscribe/ Getting error (SOLCLIENT_FAIL - Failed to create session) when create session and connect how to reproduce: * Create Solace Cloud free plan * Pub/Sub using Secured SMF URI with (host, vpn, username, password)…
-
OAuth + Microsoft Azure AD
Hello guys, does anyone have experience with how to set up the Solace connection using Microsoft Azure AD? I am aware of OAuth profiles in Solace admin, but not really sure what to input there. Thank you very much, Regards, Stan.
-
New blog post for developers | Monthly Feature Highlight Training | May 2022
The end of April brought with it Solace PubSub+ Event Broker version 10, the latest major release of our event broker. Whether you’re using appliances or software brokers, version 10 has some fantastic new features, so the next few monthly feature highlights will be focusing on all the great stuff version 10 is giving us.…
