-
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…
-
How to ensure that the replier is always online throughout the whole time request messages are being
Hi Team, Good Afternoon!! Functionality: Publishers ---> q/prd:durable queue--->XYZ consumers (replier) and reply to publisher by using non-durable queue. Please help with me with end to end steps for below ask. How to ensure that the replier is always online throughout the whole time request messages are being published?…
-
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…
-
Connection State Problem
Hello Community, While we are trying to move our setup from centos to ubuntu as host vm, together with docker setup, we are trying to solve the folloing error: Connection State: Down (Local SSL handshake failed: Server certificate verification failed: path length constraint exceeded solace That message is shown on an edge…
-
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…
-
SEMP java client INVALID PARAMETER
Hi, The Semp v2 java client built via swagger code gen doesn't appear to be able to handle a comma separated list of selects and where clauses. Using selects - queueName,msgs.count: ApiClient.buildUrl calls escapeString(value) which causes 'queueName,msgs' not a valid attribute. If i change the change to remove the…
-
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…
-
How to use Kerberos with Java RTO API?
With Java RTO API, I can set AUTHENTICATION_SCHEME to GSS_KRB. But other than that, there is no document on how I can specify other Kerberos options and keytab file. How should I do it? I really don't want to use RTO but it is the only Java API supporting both PubSub+ Cache and topic dispatching. Thank you very much.
-
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
-
New blog post for developers | Monthly Solace Developer Community Highlights | August 2022
Thanks to its increasing popularity among developers, more and more things are happening in the Solace Developer Community every day and on a regular basis: new discussions, questions, comments, events, blog posts and tutorials, etc. As such, you may find it difficult to stay on top of what is happening. That is why I am…
-
Show max num subscriptions exceeded error when running direct receiver script - Python
Hi all, Currently I am working on the direct message PubSub. In the beginning, the script works very well without any error. However, after executing the script several times without making any changes, errors pop out and say the maximum numbers of subscriptions exceeded and unable to unsubscribe the topic. May I ask is…
-
New blog post for developers | How to Integrate Solace PubSub+ with Snowflake
Snowflake is a data warehouse built for the cloud. It provides enterprises with a cost-effective combination of the power of data warehousing, the flexibility of big data platforms, and the elasticity of the cloud. Snowflake can help you bring together diverse data into one system for data warehousing, query processing,…
-
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,…
-
solClient_session_connect failed subCode: SOLCLIENT_SUBCODE_LOGIN_FAILURE, responseCode: 401, reason
I started a Solace broker docker instance, created message-vpn and username: esptest. When my solace pubsub client tries to connect to the broker using username/password, it gets "Unauthorized error". I have set up the auth-type to internal and followed the doc:…
-
How to turn on keepalive for kafka connector
HI all, we are using both pubsubplus source and sink kafka connectors: https://github.com/SolaceProducts/pubsubplus-connector-kafka-source However, we hit the issue that connection drop from time to time and our VPN admin suggest that our connection don't have keepalive enabled, he send me this page for the keep alive…
-
PubSub+ Event Portal 2.0 Now Available in Beta
Solace is making available the beta version of our second generation PubSub+ Event Portal. This second generation makes it much easier for companies to adopt and optimize their EDA. Here are the new key capabilities available: More granular role-based access control (RBAC) Version control and lifecycle status for each…
-
New blog post for developers | Monthly Feature Highlight Training | August 2022
This month’s training focuses on two new features in PubSub+ 10.1 that both improve upon features we’ve highlighted in previous Monthly Feature Highlights. Read More › Leave your comments below. Source: https://solace.com/?p=46796
-
Query regarding Topic Based Filtering of Payload
I have a Solace Topic Based Filtering related requirement in which we have a topic already established with the topic name: Dia/Tech/Mulesoft/Interlayer/PRC/PIOS/RSVD/RSVD/FromMSBQueue/Published/1/PRC/PIOS which is attached as a subscription to Queue in On-Premises : Dia.Azure.POC & Queue in Cloud Broker :…
-
Client/Manual acknowledgement
Hi @marc I am tring to do Client/Manual acknowledgement using spring cloud. First I want to know what configuration I have to do for producer end bcz I did the configuration on consumer side and its getting failed as shown below logs. I have attached java code and yaml file as well please suggest. cid------>: null…
-
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…
