-
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…
-
Monthly Feature Highlight Training | August 2022
The August Monthly Feature Highlight focuses on two new features in PubSub+ 10.1 that both improve upon features we've highlighted in previous Monthly Feature Highlights. Sign up to Solace Academy to get access to our August 2022 Monthly Feature Highlight Training and read on to learn about the features you’ll be learning…
-
New blog post for developers | Batch Processing with Spring Cloud Stream Binder for Solace PubSub+
Batch processing in messaging usually means that the code is designed or optimized to process messages in batches instead of one at a time. Usually, the underlying messaging system and the interfaces need to support producing and consuming batches of messages. This makes the system less chatty because data is coming in…
-
New blog post for developers | The Importance of Message Settlement for EDA
There is no doubt that event-driven architecture (EDA) is going mainstream. Every industry – whether it be consumer goods, retailers, banking, aviation, or capital markets – has come to a realization that EDA is no longer a niche architecture but an absolute requirement in order to remain competitive and relevant in the…
-
Sending Ack with multiple flows
@Ragnar as per the conversion here is fresh discussion. Hello, I am new to solace and I have a question about having multiple flows. Consider the following situation: A consumer is consuming messages from 2 queues. Then the consumer will create 2 flows. Here the consumer is not just consuming the messages, it also…
-
My Question is regarding Replay in Solace
Hi , I have following questions on Replay Want to know more about the replay Queues that gets created once we enable the replay on our VPN. One of the queues has name like Replay Log which stores all the persistant messages getting send to the VPN , what about the other queue having name like REPLAY_TOPICS what exactly is…
-
[Demo & Live Coding] Outputting syslogs in JSON format
Tamimi and Rey show you how to use this feature.
-
[Demo & Live Coding] Replay to temporary queue
Tamimi and Rey show you how to use this feature.
-
Spring cloud data flow slow consuption
Hi There I need help to understand why spring cloud data flow is very slow in reading message from solace. I run four consumers in non-exclusive mode but message reading is like 5 message in 30mins. One catch here is message size is more than 10mb but will that be problematic. Is there any network parameters to be…
-
C# consumer flow dispose
Hi I'm new to Solace + this is my first post, so be gentle :D I'm building a worker (C#) that consumes messages off a Solace Queue using the SolClient messaging API. On application shutdown, I attempt to stop & dispose the flow. See code below: _flow = session.CreateFlow(flowProperties, queue, null, HandleMessageEvent,…
-
[Demo & Live Coding] Topic filtering with message replay
Tamimi and Rey show you how to use this feature.
-
[Demo & Live Coding] Delete all messages in a queue
Tamimi and Rey show you how to use the new feature.
-
Does Solace have an inbuilt schema registry ?
Does Solace have an inbuilt schema registry ? Is that an open source registry? What problem is the registry solving in Solace?
-
[Demo & Live Coding] Copy One Message to an Endpoint
@Tamimi and @rey show you how to use this feature
-
Rootless Containers with Podman Now Supported in PubSub+ 10.1
Podman is a relatively new container runtime but, as the default in Red Hat Enterprise Linux 8 it is quickly gaining in popularity. PubSub+ 10.1 adds full support for Podman including running PubSub+ as a rootless container. For years Docker has been synonymous with containers; some security teams took issue with the fact…
-
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…
-
[Video] Introducing Integrated Kafka Client Bridge
Kafka and Solace brokers work together to deliver capabilities that Kafka wasn't designed for such as enabling multiple connectors, filtering and sequence preservation, and hybrid-mesh scenarios. Watch the short video clip
