-
cli to legacy semp for session-idle-timeout
Hello Solace-Community, new Solace user here :smile: We are currently developing our own terraform solace provider and are now at a point where we want to be able to configure some broker settings through terraform. For that we are using the semp v2 api whenever possible but have to fall back to the legacy semp from time…
-
spring cloud stream
compile("com.solace.spring.cloud:spring-cloud-starter-stream-solace:3.1.0") when i add this dependency to my project using spring boot 2.3.12. Its downloading 2.4.3 jar also ( when removed it doesn't ) where as i tried 2 other project its not the case over there they still use 2.3.12 and does not download 2.4.3 and use it…
-
Publish / Subscribe - REST Way
I have been following article https://tutorials.solace.dev/rest-messaging/publish-subscribe/ for long time but not really able to get it 100% working. Below are some of the issue I am confused with 1. Operational state of my RDP, Rest Consumer and Q is down but they are enabled. 2. Node Server is up and running and below…
-
Spring Cloud Stream publishing messages
I have heard that SCS should no longer be used together with flux (flux destroys that: retry handling, error handling, transmission confirmation). With StreamBridge messages can be published. But in my opinion the StreamBridge is not quite consistent with the other declarative and functional handling of SCS. Are there…
-
Pull message from a queue on an adhoc basis
Hi, I have a requirement to use spring cloud stream binder for solace to connect and pull messages from a queue. The application should not listen to that queue continuously instead it should try to pull the message based on a scheduled time interval. Could you pls help me how to achieve this with minimal java code? Thanks
-
Use LVQ to run in Master/Slave mode
Hi, I wanted to run my service in 2 regions in master/slave mode. Is it possible to use an LVQ to achieve this? What I am thinking is that whenever the service starts it will try to connect to an LVQ and as per my understanding only one can have access to it. (Is it correct assumption?) If so, that process will act as a…
-
Quick-and-dirty REST server for RDP testing
Hi there! I thought I'd share a (possibly!) useful snippet of code that you can use to receive REST requests, and respond with a canned body. It's in Node. I don't know Node, so apologies if it's not glamourous code. I was inspired by the "Simple REST Consumer" on this tutorial:…
-
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…
-
Boomi V2 Connector released 🎉
We have released our version 2 of the Boomi connector! Check out a tutorial on our codelab site here https://codelabs.solace.dev/codelabs/boomi-v2-getting-started. You can also check out other codelabs that uses our Boomi Solace connector by filtering on the 'Boomi' category. What's new? Some of the new features with this…
-
Solace PubSub+ Event Broker (Software & Appliance) new versions are released
The following Solace PubSub+ Platform products have been released and are available for download: * Solace PubSub+ Event Broker: Software version 9.6.0.27 * Solace PubSub+ Event Broker: Appliance version 9.6.0.27 Please refer to the product release notes for information on new features, changed functionality, resolved…
-
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…
-
Trying to connect consumer to the pre-defined queue, getting error as Permission mismatch.
Hi, I am trying to connect pre-defined queue named GMMO.UCTRADE.DSLT01 it has ALL OTHER POERMISSIONS: No Access(0000) . When i try to consume frm the queue , application throws below error : org.springframework.cloud.stream.provisioning.ProvisioningException: Failed to provision durable queue GMMO.UCTRADE.DSLT01; nested…
-
[Weekly Quizzicle] Which subscriber provides no delivery guarantee?
-
Max transacted sessions exceeded (503) error - PubSub+ Event Broker and Camel Solace component issue
Our team is currently working on a proof of concept with Apache Camel to split a file and publish the events to a Solace queue (PubSub+ Event Broker). Unfortunately, we are experiencing a persistent issue from the consuming route where, after a few minutes of consuming messages using the Solace Camel component, we start to…
-
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…
-
In Spring cloud , i would like to print logs which will tell to which queue application is connected
Hi, I am working on spring-cloud-solace. In application i need logger to track which queue application is connected to. Could you pls help
-
Disaster recovery setup
I am trying to enable Disaster recovery between 2 HA pairs. Is there a consolidated documentation of the steps to follow? I followed the default solace documentation, and there are lot of moving parts/configurations, and now my replication bridge is not coming up. I don't see anything in the logs to debug the problem.…
-
How to solve :com.solacesystems.jcsmp.JCSMPTransportException: Unexpected error:Fatal reactor error
2019-12-24 07:20:46.556000+0000 [86052:Context_3_ReactorThread] INFO com.solacesystems.jcsmp.protocol.impl.TcpClientChannel: (Client name: gtosp-tibco/86052/#0bb60005/5jqZ4iMrCl Local addr: 10.0.0.8:57346 Remote addr: ...:55555) - handleException(): Channel Closed Event (smfclient 12) 2019-12-24 07:20:46.563000+0000…
-
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
-
spring cloud stream multi api version
The problem: A single spring cloud stream application, have to send out the same data via 2 major versions of the same api. spring: stream: bindings: myApiV1-out-0: destination: api/v1/the/topic myApiV2-out-0: destination: api/v2/the/topic Question: What is the most elegant solution for this problem? Idea / what i want to:…
-
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…
