-
Subscribing to a subset of the fields on a chatty topic
Hello Solace Community, I'm just starting out with Solace and I'm trying to figure out how topics work. Reading documentation I can see how to subscribe to topics and how to use wildcards but I don't see how to subscribe to a subset of a topic. I have a very chatty topic that sends out SDT maps and I'm only interested in a…
-
Use exclusive queue as distributed lock?
I was wondering if I could use an exclusive queue as a rudimentary distributed "headship" mechanism. If there are multiple queue consumers that create a flow to the queue, my thought is that whoever is the active consumer would considered the head node, and if they shut down then headship would automatically be transferred…
-
JMSToolBox: Not able to browse through all queues created on VPN
Hi Team, Need your help here. I'm trying to use JMSToolBox to browse and see the content of the messages on solace queues. have completed the setup and able to connect to solace VPN but the JMSToolBox is displaying only 100 queues. there are around 500+ queues created on Solace VPN and I'm not able to browse through all…
-
Error when setting up Java Code
Hi, When I am setting up the BasicReplier and BasicRequestor code in STS, I am getting below error No "exception of type JCSMPException can be thrown; an exception type must be a subclass of Throwable" in design time. Am I missing anything or any jar file? I just coped the BasicReplier and BAsicRequestor code and I cannot…
-
Spring cloud stream -- jmsTempate
I am trying to read a message using jmsTemplate but not able to cast it, i need to read payload/body and then i have to drop that message using jmsTempate to another queue. class com.solacesystems.jms.message.SolBytesMessage cannot be cast to class javax.jms.Message
-
Spring cloud stream
In case when we siphon the message from an error queue we dont get from which queue it was thrown like rabbit does it by proving original queue name, also how to get all the headers i am using jmsTemplate or jndiTempated i see property to gather there is not separate method to just get all the headers, also there is method…
-
MQTT 5.0 Support 🎉
PubSub+ Early Access Broker now supports MQTT v5.0! With this new support, the broker will automatically determine whether the client is speaking MQTT v3.1 or MQTT v5.0. Some of the new features you will be able to have access to with this support is: * Assigned Client ID * Determine content type so that message consumers…
-
@JmsListener with concurrency
Hello All, I am trying to use Spring API. I am trying to process multiple messages simultaneously and wanted the JMS listener to be running continuously so that I can process further steps while it is awaiting the message. I am getting below error when I add concurrency with JMSListener. 2021-05-21 16:26:57.922 WARN 164…
-
Queue Subscriber without Latch
Hi, I am trying to have QueueSubscriber without latch but to have QueueSubscriber continously running. Is there any sample code available? I am trying to create a message SubscribeFromQueue. If I have latch inside subscribeFromQueue it works but once control comes back to main method it does not return back. try {…
-
get only first message
Hi, I want to receive only the first message with property in a Queue. How to get this? Will this utility will help ? ./sdkperf_jms.sh Or any other choice ? Saw this article..Any hint - on how to re-write to receive only first message? https://tutorials.solace.dev/jcsmp/topic-to-queue-mapping/ These messages are now on…
-
How would you explain EDA to your grandma?
The EDA Summit is on today and I just watched the Welcome Keynote. One of the things that I like about it is the question "How would you explain EDA to your grandma?" It's fun to see the experts and guests make their attempts. What would you say to your grandma? I'd like to hear your versions here. :)@rob @manish @Tamimi
-
First-ever EDA Summit on May 19, 2021! Can't wait more !!!!!!!!!!!
HI All, You might have received your registration credential for EDA Summit. I am really excited to attend such event organized by Solace . The EDA Summit virtual event platform is now open. Please sign in with your unique registration credentials below and take a few moments to get prepared for the event: Important: *…
-
How to get queue name with the help of topic subscription
Hi Team, I have a case where i need to get the queue name with the help of topic subscription.I have only topic name which is bind to queue. How can we achieve with the help of SEMP API's Thanks in advance.
-
New Video: Guaranteed Consumer ACKs
After his previous video Solace Guaranteed Publisher: ACKs and NACKs, our Developer Advocate Aaron Lee just posted the 2nd part of the series. https://www.youtube.com/watch?v=K7_E7kzTHhk In this new video, he talks about the things to be expected and some best practices for consumer and processor applications using Solace…
-
403: Subscription ACL Denied - Queue 'scst/wk/txGroup/plain/txError' - Topic 'txError'
Config - application.yml spring: cloud: stream: default: group: txGroup contentType: application/json consumer: concurrency: 2 maxAttempts: 1 bindings: output: consumer: group: txGroup provisionDurableQueue: true autoBindErrorQueue: true errorQueueNameOverride: txError durableSubscription: true republishToDlq: true…
-
Setting up AWS Cognito OAuth for PubSub+
Hello! Has anyone had success setting up AWS Cognito OAuth for PubSub+? I went through How to set up Solace PubSub+ Event Broker with OAuth for MQTT against Keycloak but was unable to translate the instructions to Cognito. Has anyone integrate the two successfully? If so, any pointers or advice on doing so? Thank you!
-
Last chance to register for EDA Summit! Happening Wed, May 19th
EDA Summit is coming up next week and will feature a who's who of the EDA world, including folks from Slack, Google, Boomi, HP, SAP, FAA, IKEA, Accenture, Postman, Wipro, and more! Have you signed up for EDA Summit? If not, what are you waiting for! Even if the timezones don't work for you, register so you can watch the…
-
Spring Cloud Stream- Consumer config, queue name included in topic subscription list
Hi We are using spring cloud stream to consume events from topics defined by publisher application. We have Organization wide agreed topic hierarchy taxonomy for all applications across the board and subscription ACL (default disallowed) is aligned only to that agreed taxonomy. In the binder property…
-
Updating solace Queue Object (username ) when Azure Key vault credentials are updated
The use case is to update the Solace Queue Object when the credentials in Azure key vault is updated/deleted/created.
-
Solace spring cloud stream support
Currently the project is making use of rabbit mq and message channels not functions i want to replace the rabbit mq with solace so what are the changes specific to solace. Information carrying in message header Re-processing from DLQ in SOLACE feasibility and approach for duplicate handling parallelism limits on Kafka vs…
-
Setting multiple factories to connect to solace in JMS
I want to establish multiple factory connections in the program at the same time, but I find that after establishing the connection, JMS will not receive the information sent by solace. Here is the code for establishing the connection. Please forgive me for the help of the solution @Value("${solace.ssl.host}") private…
-
Happy Mother's Day!!
Happy Mother's Day to all the hard-working mothers out there, and all of our mothers as well for bringing us into the world and raising us... for encouraging our curiosity and creativity. Which (in some small way) eventually led each of us to be curious about Solace. haha Big shout out to one of our tireless…
-
Solace Message VPN
I want to send the message from VPN A to VPN B by trageting the queue on bridge VPN. how can I achieve that? can you share the steps?
-
Exchange Type , Routing key support
In our existing project Exchange type and bindingRoutingKey used which is rabbit only feature what could be the work around for this feature in solace ?
-
Solace Message VPN bridge limitation
Are there any limitation for sending / receiving message for solace message vpn bridging (bi-directional)?? e.g. Is it possible to send message targeting to a queue on the bridged vpn ?? Or it is only possible to send message targeting to a topic ??
-
Solace spring cloud stream support
Hi I am a software Engineer and my name is Atul. Currently our project is making use of rabbit mq and there are two option kafka and solace by which we will replace the solace and i am here to know more about solace i have visited the docs and vedios but they are majorly using functions but as you know i have existing code…
-
Extract Topic Name from Java Beam pipeline
I am using java beam pipeline and want to extract topic name from solace. But I am not getting any such function or anything to do the same.
-
Getting getSplitBacklogBytes() unable to read bytes error after draining Streaming Dataflow job
I am trying to read messages from solace queues through solace io connector and then writing them to GCS bucket , i was able to read and write messages to GCS as it was streaming job i need to drain it so when i drain the Streaming dataflow job getting below error error: getSplitBacklogBytes() unable to read bytes from:…
-
Sending json message using Python to queue using certificate authentication
Is there any way we can send json message to queue using certificate authentication in Python. If possible please share code snippets showing this.
-
Messages getting discarded from broker
Hi , We have a jscmp producer publishing messages to a broker. the publisher pushes around few 100 messages and we see messages gets discarded every now and then. we did some debugging and found that "Message Spool Ingress Discards" is getting increased. Further in show message-spool stats details Publisher Not Found .…