-
Trying to understand Consumer Ack Window
I think that I have totally misunderstood the consumer flow ack window, and am trying to figure this out. Does the consumer ack window dictate the max number of messages unacked by the JCSMP API, or by the application? I have client acknowledgement enabled, and want to throttle the application so that the broker does not…
-
upgrade procedure of monitoring node
Hi experts, I have a redundancy env including two msg-routing nodes and one monitoring node as Active/Standby, and want to confirm upgrade procedure(s) of the monitoring node, which is not mentioned in the doc below. https://docs.solace.com/Solace-Appliance-Upgrade/Upgrade-Redundant-Appliances.htm#With Could anyone help me…
-
Do I need to close my JCSMP consumer/session on application shutdown?
I generally like to close resources gracefully when shutting down an application, and ran into a scenario where my queue consumer still had an outstanding message that it tried to ack() after the consumer had been closed, so I got the message "Attempted an operation on a closed message consumer." If upon shutdown I instead…
-
Unable to create a Polling Consumer
I want to create a polling consumer which is written in myFunction the queue is : Test and topic is abc/test **I have also autowired PollableMessageSource source and used this polling source in my function however, it is not fetching values from topic, is my configuration incorrect? *** spring: cloud: function: definition:…
-
Spring cloud stream with solace
Couple of question i have for solace binder, 1. I tried an example for DLQ functionality where i could throw exception from the listener and it was published to error queue, does solace has any mechanism to reprocess them, except that we add a listener and reprocess manually/code. Even same for DMQ.
-
@StreamListener(target = Sink.INPUT, condition = "headers['eventType']=='EmployeeTransferredEvent'"
I am using latest version of solace streaming and want to filter messages based on header but I see @StreamListener is deprecated and how to achieve this with properties file i have seen queueAdditionalSubscriptions but its filtering based on topic and not on header properties. solace: #The solace bindings section allows…
-
Open APIs - streaming : which to use??
Hi all, Looking for some opinions here!! When exposing a request/reply style interface, REST-over-HTTP is the defacto standard for applications, especially web and cloud apps. GraphQL and gRPC are gaining ground. But if you wanted to expose an asynchronous / streaming service (e.g. to publish temperature updates, bus…
-
SEMPv2 - Your Solace Broker comes with the OpenAPI docs!
Beyond getting the SEMPv2 OpenAPI specs from our downloads page, did you know the Solace PubSub+ Event Broker allows you to access the openapi spec for the SEMPv2 API directly from it? You can access human readable docs at: * Config API - http://<HOST:PORT>/SEMP/v2/config/help * Action API -…
-
When we create new consumer then it is creating queue in fomart scst/wk/exclusive/plain/*
How to avoid creating this queue because it creates extra queue. I want to listen on queue which is already created and just map to it
-
[New Podcast for Developers] Microservices For Everyone w/Tom Fanara: Ep 03: Real World Tech
In this episode Tom interviews Jesse Menning, CTO Software Architect at Solace. Jesse discusses Event Driven Architecture (EDA) for microservices. EDA is a best practices way of separating the communication between microservices with an event broker! Thus creating layers of knowledge on really what's happening in your…
-
[Weekly Quizzicle] Which subscriber provides no delivery guarantee?
-
springcloudstream processor app listening wrong queue with appended scst/wk/
i have created springcloudstream processor appliation which need to listen to queue "TEMPS.Q" and publish to topic "sensor/temperature/celsius/topic" But when i start running the application instead of listening to queue "TEMPS.Q" its creating new queue "scst/wk/PROCESSOR/plain/TEMPS.Q", so its not able to pull messages as…
-
Discard indications and topic dispatch
Hi, how does discard indication (in .NET) work together with topic dispatch? According to the documentation if my egress queue contains * message A to topic T (top of the queue) * message B to topic T2 * message C to topic T and gets full then message A will be discarded and discard indication will be set on message B? But…
-
[Weekly Quizzicles] message.acknowledge() only acknowledges message has been received and consumed
-
Solace Developer Spotlight: Shradha Bhatia
Hometown: Kanpur, Uttar Pradesh, India Years of being a developer: 3.2 years as a professional developer Technical competencies: MuleSoft, Solace PubSub+, TIBCO, Azure How did you start as a developer? I started as an IT professional and it was a roller coaster ride for me. I was completing my graduation specialization in…
-
SPRING CLOUD STREAM
SolaceExtendedBindingProperties does not provide the implementation of getBindings() , I would request you to please provide some method to get bindings details at run time.
-
Spring cloud stream Message Type Conversion Issue
Hi Team, We get the type casting issue when spring cloud stream reply the message to non spring cloud stream service. com.solacesystems.jcsmp.impl.BytesMessageImpl cannot be cast to com.solacesystems.jcsmp.TextMessage" Code: Below is the code used in the non spring cloud stream service which is type casting to text message…
-
Solace .net libraries possibly using no-longer-supported binaryformatter (also, .net5)
In a question thread created late last year, forum user @Anton was asking about a binary formatter exception in relation to his attempt to use .net5. I have just run into a similar issue. But interestingly, at around the same time that previous thread was resolved, microsoft issued a notice: BinaryFormatter serialization…
-
When i read message from solace queue using a consumer i get some issues while casting it
java.lang.ClassCastException: class com.solacesystems.jcsmp.impl.BytesMessageImpl cannot be cast to class com.solacesystems.jcsmp.TextMessage (com.solacesystems.jcsmp.impl.BytesMessageImpl and com.solacesystems.jcsmp.TextMessage are in unnamed module of loader 'app') What i get it is SolaceBytesMessage, cant not case to…
-
Limitation on UserPropertyMap of Solace Message Format
Is there any limitation for UserPropertyMap of a solace message (SMF) ?? ==> Size ?? number of bytes ?? Or as long as the whole message <64Mb (Direct) / <32Mb (Gurantee), it is still okay ??
-
Python TLS/ClientCertificateAuthentication error
Hi All, I am trying to use Python to connect to solace and failing to connect with “unable to get local issuer certificate” error. I have setup TLS with_certificate_validation and authentication strategy with ClientCertificateAuthentication.of. I have tried various combinations to use with or without TLS, while creating…
-
"Guaranteed Message Publish Window Size" with (Solace) JMS
Hi there In one of our applications we use the com.solacesystems.sol-jms (version 10.6.4). I want to configure publishing as described in https://solace.com/blog/understanding-guaranteed-message-publish-window-sizes-and-acknowledgement/ I found this:…
-
[Weekly Quizzicles] When Message Replay is enabled, what can you request?
-
Client username (sender id?)
Is there a way to get username of a sender of a message? As a consumer I want to know the name used to authenticate (basic or gss auth scheme) sender session. Obviously I dont want sender application to attach this as client can't be trusted so maybe VPN can attach this? I need this ID for further-more granular application…
-
Using Selectors in Solace PHP SMF
Hello all, is there a way to use Message selectors in the PHP SMF library similar to the other Solace interfaces ( https://tutorials.solace.dev/jcsmp/message-selectors/ ) ? If not, do you have any other idea how we can easily receive messages via PHP using message selectors? Thanks a lot and best regards from Mannheim,…
-
Working Principle For Solace Loopback Bridge
Hi, I have question around Solace loopback Message VPN Bridge which is used for link two Message VPNs on same event broker. Let's say we have Appliance Name “Router_DC_1” and there are 2 VPN i.e. VPN_A & VPN_C, Now both VPN is linked together via bridge (VPN_A_to_VPN_C) on same appliance. There is DR for this setup on…
-
Gaps and direct vs guaranteed messaging
Assume I disabled reconnect on Solace session - so once the session is down it will stay down. Now I have a publisher which is publishing messages A, B, C (in order and all messages have the same priority). (1) Suppose the publisher is publishing to topic T and uses direct messaging. Can it happen that only messages A and…
-
Need help on SOLCLIENT_SUBCODE_COMMUNICATION_ERROR
Hi, I am encountering an error when trying to establish a connection to the broker. I'm using TLS with certificate in the transport security strategy. Here is my code: transport_security = TLS.create() \ .with_certificate_validation(True, validate_server_name=True, trust_store_file_path=trust_store_path)messaging_service =…
-
XMLMessageProducer - java.io.NotSerializableException
Hi I am new to Solace. I have been trying to use Solace with Spark cluster with DStream. My sample code for producer looks like this private XMLMessageProducer managerProducer; // In my init method, I am creating the instance of managerProducer like shown below managerProducer = session.getMessageProducer(new…
-
Basic Configuration Defaults
Hey, What are basic Configuration Defaults required for software event broker?? Read good stuff here, https://docs.solace.com/Solace-SW-Broker-Set-Up/Starting-SW-Brokers-for-the-First-Time/Set-Up-KVM.htm#VMR. Can you brief more on it??
