-
Does any of the other Delivery modes other than DIRECT has any impact or use on Topic subscription?
Does any of the other Delivery modes (PERSISTENT or NON-PERSISTENT) other than DIRECT has any impact or use on Topic subscription? Also in the Solace UI, when publishing a Topic there is an option to switch the Delivery mode, but didn't see this has any impact on consumer/Subscriber side. I have seen this has an impact on…
-
Go let's Go! Solace PubSub+ Messaging API for Go v1.0.0 🚀
What's the news?? 👀 Yep you read this correct, the Solace PubSub+ Messaging API for Go is officially generally available for download! In November 2021, we released the early access version of the API on the community and had a successful wave of developers and users give us initial feedback on the API. We appreciate all…
-
Does Solace Pub Sub + Event Broker-Software (On Premise) have the Event portal ??
I was trying to evaluate the solace and wanted to understand if the Solace On-Prem version have the Event Portal .
-
Unable to reuse sessions in Springboot while producing persistent messages to SOLACE SMF
We have been trying to create a Bean that creates the JCSMPSession. In the class we are using the session object do session.connect(). We are using asynchronous mode to publish the data. It seems the code is not thread safe in this case and we are not able to receive the acknowledgement. Can some one share a sample…
-
How to connect XASession of Solace JCSMP API with Weblogic Database XAConnection?
Hi team, I am looking for a way to connect solace XASession with database XA connection (my datasource is on weblogic server) so that if the query execution fails, solace transaction should rollback when db transaction.rollback is called; and same with commit statement. Or vice-versa - if solace transaction is rolled back,…
-
Retry mechanism with delay
We are adapting our services to use Solace, and one of our applications uses a retry mechanism with delay from RabbitMQ in which an error message would be sent to a DLQ, which had a TTL configuration and, after the TTL expiration, it would be sent back to the initial queue. Beyond that, the message had a specific header…
-
Does Solace inspect the schema of message with AsyncAPI contract?
Hi, We use AsyncAPI to define our event contract and I'd like to know whether Solace will inspect the schema of message sent by publisher before the consumption? Thanks
-
DMQ Eligible flag in Java different libraries
After some tests using JCSMP API, I assumed it is necessary to set this flag on the producer side to make the Dead Message Queue features working. Now, I am testing my new applications that use the Spring Cloud Stream with the Solace PubSub+ Binder and just see this parameter on the consumer side (Is that right?), which…
-
Sequential consumers call for single request pushed in topic- Solace Rest API (RDP- Consumer)
Use Case: Sequential consumers call for single request pushed in topic Insurance Quote creation -> Activity Creation -> ActivityCreated->SMS/Email For above use case you are basically looking if Solace can act as an microservice and decide to move to next step if the previous step is successful. Meaning, if Insurance Quote…
-
Wanted to know how spring solace streaming is working with sleuth
Hello All, I have seen solace messages are visible on zipkin and broker is also seen on zipkin but for some of services its not working when message passing between some rest endpoints. Can you please lets us know if solace streaming API's are adding any message headers to solace message to keep track of trace id and span…
-
Node JS typescript compiler not liking Solace API reference to 'long'
I'm running into this error when I try to run my TS compiler: node_modules/solclientjs/index.d.ts:2:10 - error TS2616: 'Long' can only be imported by using 'import Long = require("long")' or a default import. 2 import { Long } from "long"; ~~~~ node_modules/solclientjs/index.d.ts:2:22 - error TS2497: This module can only…
-
Reprocess of messages
We have similar scenario like below discussion our scenario is 1) Consumer consuming message A 2) we have disable auto ack 3) Consumer failed while processing messages A and catched exception 4) Message is not acknowledge 5) We want to retry same message again In current scenario we can see message on solace queue after…
-
Error occurred for Solace queue depth request message: 0 while reading from Solace using dataflow
Hi, I am trying to stream messages from Solace to BigQuery using DataFlow where I am using the pubsub+ IO connector for Apache Beam provided in the below github repo. https://github.com/SolaceProducts/solace-apache-beam I am able to read the messages but also getting below errors which is due to failures in reading the…
-
Take the Solace Developer Community Challenge
As we see in our first virtual Easter Egg hunt in April, developers like challenges! So, we decide to do a Solace Developer Community Challenge. The challenge contains 3 questions. If you follow our community closely, you can find answers to the questions in the community. A winner will be selected based on the number of…
-
Announcing the winner of the Solace Developer Community Challenge
Our first Community Challenge has received a warm response from the community. Since it was launched on August 25, 77 people submitted their answers before the September 2 deadline. Based on the number of correct answers and time of submission, the participant with “jaorjixiaocong” in the email address won the backpack!…
-
How properly close JCSMPSession
Hello i need advice, we use sol-jcsmp version 10.15.0 Session is create with XmlMessageLIstener, XmlMessageConsumer and XMl MessageProducer. gproducer is create by JCSMPStreamingPublishCorrelatingEventHandler. wwhen i want to close session i call session.clouseSession() Problem is that after close i still can see running…
-
can commands be issued into Solace PubSub+?
I'm new to Solace PubSub. I'm wondering if it's possible to issue commands into PubSub broker so it can get picked up somewhere else? Or, are only events issued through PubSub broker? Thank you for your time.
-
Solace - Spring cloud stream binder.
I found strange issue with my app. Application should have the bind count to 20 (4 Instance, Each with default 5 concurrency) but it went down to 2, the consumers for that queue stopped consuming and message started to spool. When i added another instance of the service the bind count went upto 7 and messages were consumed…
-
Send a message to the Queue instead the Topic
After hours of studying in Solace Documentation, Youtube Channel and etc, I believe I've ended up with some points to check with you: Although we have some samples of sending a message to a queue, the best practice is to send a message to a topic. As I could see in the Spring Cloud Streams samples, this is the only way to…
-
Issue in posting xml message to queue via REST messaging
Hi i am trying to post an xml message via postman to queue and I use content type as application/ xml . The data is not coming as an xml . Should I add any other header
-
Client latency/response time
Hi We are using Solace to push market data to client applications via direct messaging. I have noticed that some clients struggle to consume data at the same rate due to connectivity issues. When network dips occur or when you reach a wifi 'dead zone' some client fall behind on market data. In order to alleviate the load,…
-
Spring cloud stream concurrency
Hi there I'm trying to configure more than one Consumer Thread for my functional consumer, the yaml file looks like this: cloud: stream: function: definition: bookIn bindings: bookIn-in-0: destination: BOOK group: BOOK_CONSUMER consumer: concurrency: 13 # has no effect_ The value is actually taken over into the…
-
Spring Boot XA Transaction Autoconfiguration?
Hello, I am working on a Spring Boot Java project where we are trying to incorporate XA transactions using the Atomikos implementation of JTA. However, we are struggling to see how to easily create the XAConnectionFactory. There does not seem to be any way to autoconfigure the creation of this bean and we are having to…
-
How to set DMQ Eligible flag in Spring Boot
Hi there, i am using solace-jms-spring-boot-starter and jmstemplate in spring boot to send messages to queue. How can i set the DMQ Eligible flag over jmstemplate? Currently all my messages have the status DMQ Eligible NO. public void sendEvent() throws Exception { String msg = "Hello World " + System.currentTimeMillis();…
-
Springboot Solace JMS Autoconfig with Client Authentication
I am using SpringBoot Solace JMS AutoConfig to listen and produce message for solace queue. I am currently using Basic authentication. Now, I am trying to use Client Authentication using truststore and key store. How do I connect to Solace using JMS AutoConfig?
-
Solace and Boomi - Acknowledgement process
Hi, I need some guidance and help regarding acknowledgement process of Solace. 1.I have Boomi process which gets input (payload) from external system and sending xml to Solace topic.Here how to acknowledge the source system the message is received in Solace in success. What settings are to be done in Solace Pubsub +…
-
Unable to connect to existing solace queue instead trying to creating a new durable queue and fails
Asking help from this community after coming through several articles and sites. Didn't find solution I want to connect and use manually created queue, but it is not working. refer the below properties and error i am getting. Any recommendations? Details Spring Boot Applicaiton created using start.spring.ip with the…
-
StreamBridge creating consumer and it's subscription
I have created a Spring cloud stream application that publishes messages to Solace. The publish message is triggered by an external event. I am using StreamBridge to achieve this functionality of publishing messages. My application.properties look like this Problem: when the application starts it creates a consumer queue…
-
What is the difference between all the different Queues?
As I was trying out Solace PubSub+ with java implementation I tried to use Persistent messages as our previous eventing system used a similar concept. As I was exploring the concept of Queues showed up and I noticed there were many different kinds. The first part of this question is what is the difference between…
-
[Explainer Video] How PubSub+ Enables an Event Mesh
Watch this short explainer video to understand how PubSub+ Platform enables an event mesh where brokers can be deployed on-prem, public clouds, and remote locations. https://solace.com/resources/videos/how-pubsub-enables-an-event-mesh
