-
@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.
-
Solace PubSub+ Connector for Mulesoft(Integration)
Hi Everyone, A month back, I have received this link from @Tamimi about Integrating PubSub + with MuleSoft Solace Connector. The Solace connector for MuleSoft is still not publicly available in MuleSoft Anypoint Exchange. It is available as an open source project in Solace Github repository. Once the Solace connector will…
-
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…
-
How to Configure-JMS-access-to Solace in SnapLogic
Dear Solace users, How to Integrate Solace PubSub with SnapLogic? Let me jot down modus operandi to integrate Solace with SnapLogic (iPAAS ) . 1- Login to SnapLogic Designer (https://elastic.snaplogic.com) . 2- Move to Manager tab and Navigate to project where accounts needs to be created . 3- Under Create account option ,…
-
Solace Dynamic routing
Is dynamic routing is same as dynamic destination binding Dynamic routing as per rabbit all producer published to same queue, configured on routingKeyExpression for producer and consumer listener receives it based on bindingRoutingKey. does this can be accomplished using stream bridge or BinderAwareChannelResolver??
-
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…
-
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…
-
OpenShift TCPS routes
I am able to connect to the ws endpoints in solace (running on openshift) with the nodejs samples. I am unable to connect to the tcp/tcps endpoints (55555 and 55443) with nodejs and Java samples. Can someone tell me what I need to do to get the Java or nodejs samples to connect to the tcp and tcps endpoints?
-
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…
-
Router does not support guaranteed subscriber flows
Hi SolaceDevs, We are facing below error while consuming the messages from the queue. Seems we will need to enable the Guaranteed message on message vpn and client-profile level but how can we enable on PubSub+ Cloud. Thanks, NaGG
-
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…
-
NodeJS troubleshooting help
Hi all, I'm not very good at JavaScript coding. I spent some time on the weekend coding up a simple app that does REST polling every minute (gathering arrival times from a bus stop, via an open API), and publishing the values via MQTT onto Solace broker using MQTT.js. Now... I've been running the program using nohup node…
-
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 ?
-
Api to unsubscribe to a topic and delete the queue
I have a queue and topic created like this. Now I want to unsubscribe to the topic and delete the created queue. Is there any api to do this? curl http://localhost:8080/SEMP/v2/config/msgVpns/aaron/queues-X POST \- u admin:admin \- H “Content-type-type:application/json” \- d ‘{…
-
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 ??
-
Deploying own TLS certs on a broker that is deployed on AKS (K8S in azure)
Hi all together, I tried to achieve following: Having custom TLS certificates on our Solace broker that is deployed on an azure Kubernetes services (AKS) cluster. This is due to the requirement that only internal traffic is allowed for internal customers of our solace broker. We have a k8s Loadbalancer that routes all the…
-
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…
-
Publishing the event in existing microservice
How can we publish event in running existing microservice using solace and spring cloud stream.
-
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:…
-
what is the benefit of using JNDI for the JMS connection setup
solace doc suggestion to destination object is configured on the JNDI store on the event broker, and JMS application can perform a destination lookup for obtaining an InitialContext, what is the benefit to do this than setup the JMS connection to solace server directly from solace client.
