-
How to get back the message id after publishing a message on solace topic using nodejs
hi Members, i need help to get the message id immediately after publishing a message on topic using nodejs. i can publish a message but not sure how to get the message id back after publishing. i tried to search on the google but no luck. here is the code i am using to publish. code block : const solace =…
-
Distributed Tracing: New features on Solace PubSub+ Cloud!
Hey Community! 👋 As you know, we have been releasing regular updates to our new DT feature. We're excited to announce that Distributed Tracing in PubSub+ Cloud can now export traces to PubSub+ Insights and other observability tools using OTLP/gRPC or OTLP/HTTP. This means customers can now export to solutions like…
-
HA redundancy - Monitoring node issue
I followed the steps documented in the HA redundancy section, both the primary and backup nodes are online and I can see the redundancy working. Monitoring node is offline, the show redundancy group on monitoring node shows all nodes as offline. I tried multiple times the behaviour is consistent, not sure what I am…
-
C# - Solace Queue Message not reading and missing sometime
I have referred sample code provided by the Solace team for implemented Pub/Sub Queue message (https://github.com/SolaceSamples/solace-samples-dotnet) Sample code is implemented part of Microsoft .Net 6 Worker service and scheduled to run every 30 mins. I am facing new issue and i really don't know what went wrong in my…
-
Get clarity on retry count (named delivery count) - several questions
Use Case: ========== As consumer in case of retries you naturally want to differ in your logic depending on which retry you are on. As well likely you want to log somewhere which retry you currently processing. Delivery Count: =============…
-
Spring Cloud Stream Solace - Sticky Load Balancing Implementation
Can any one please help me with a sample implementation of sticky load balancing with spring cloud stream solace. My use case is account transaction information are posted to a solace topic to 6 different partitions. There will be consumer(s) reading from these partitions. Initially there will be 1 consumer which is hosted…
-
Publish unicode string using solclientjs
Hi Experts, I am trying to publish a non-ascii string to a solace topic using the solclientjs library in nodeJs, and consume the same using the golang solace messaging library, and vice-versa (i.e. golang to nodeJs). Example string: abc-nonascii_ãçï_স I understand I have three options to do this in solclientjs: as…
-
How Oauth can be used with Apache Qpid JMS 2.0 AMQP
Hi All, I am using Apache Qpid JMS 2.0 to connect standalone PS+ broker on 5671 port. I am able to achieve using username and password however I am not able to authenticate using Oauth. Our other clients written in nodejs are able to authenticate and connect on 5671 with AMQP protocol and Oauth. As per doc I am providing…
-
Spring Cloud Stream Solace - Manual Acknowledgement
The batch mode is working fine as i am able to receive the msgs as batch and publish as batch. Now, i am trying to manually acknowledge the messages. If no exception, update the database with success and then accept the message. Else, update the DB with error and then requeue the message. Function<Message<List<?>>,…
-
Now available: v1.1 of the PubSub+ Connector for IBM MQ
Hello all connector enthusiasts! Version 1.1 of the Self-contained Connector: PubSub+ Connector for IBM MQ is now available. This release contains a number of new features and enhancements since the 1.0 release in Dec. 2022. These include: Support for durable topic subscriptions in the JMS/MQ input binding/consumer of a…
-
Spring Cloud Stream Data Type in Function
Function<Message<?>, Message<?>> The function takes the input paylaod as bytes even when datatype is mentioned. The auto conversion from json to pojo is not happening. Any suggestion? For example, Message<ClassName> when i directly use it, i am getting Class class exception ClassName a = message.getPayload(). Works as…
-
Garanteed Subscriber problem: "Emitter rejects listener for no-name event: undefined"
Hello everybody, I hope I am posting this on the correct Category, correct me otherwise. I am trying to subscribe a Solace Queue in order to get it's messages and redirect them to a specific endpoint which will later process it's information. For that, i've made a NODE JS service which uses the GaranteedSubscriber example.…
-
How to avoid duplication of Total delivery unacked messages?
Few messages got stuck in the queue for delivered unacked messages, only if the application restarts the messages are removed from the queue. Will the broker tries to send the stuck messages again and cause a duplication of messages and if yes, how to avoid it when the application restarts or any other possible solution…
-
Best Practices for handling message processing failures (Go API)
Hi, just wanted to know what is the best practice for handling failures when processing consumed events from a queue? i.e. Upon consumption of an event from a queue subscribed to multiple topics, I would call an external API to send an email to a person based on the topic. However there is a chance that this API call would…
-
SolaceSystems.Solclient.Messaging is not working in MAC M1
SolaceSystems.Solclient.Messaging dll is unrecognizable in mac M1 , what can be done ? when arm support will be added to DOTNET dlls......... ? All our development activities are paused in all applications due to it , can we make a quick fix ?
-
New blog post for developers | Monthly Solace Developer Community Highlights | April 2023
Below are some of the highlights in the Solace Developer Community in April: Read More › Leave your comments below. Source: https://solace.com/?p=49106
-
NoClassDefFoundError - SolJNDIInditialContextFactory - need assistance
Hi TEam, I am java developers, if I am using the sol-jms-10.3.1.jar or sol-jms-10.3.1.jar I am able to connect to the Solace VPN If I tried to use the sol-jms-10.6.2.jar - I am getting the below error : NoClassDefFoundError - cloud not load class com.solacesystems.jndi.SolJNDIInditialContextFactory Am I missing anything…
-
How to post to Solace VPN - using restAPI
How to post to Solace VPN - using restAPI ? Any documentation or samples on how to send a message to solace vpn using REST API.
-
How to connect to pre-provisioned queue in solace using spring cloud stream ?
I am using @StreamListner, created input binding of type SubscribableChannel & trying to connect to a pre-provisioned queue and used similar configurations as suggested in previous comment but i am not able to bind consumer with queue . Getting error - "EL1008E: Property or field 'isAnonymous' cannot be found on object of…
-
How to use/ enable oAuth2 in spring cloud stream to connect to Solace broker ?
I have implemented spring cloud solace binder to consume messages from Solace Queue. I am using Azure OAuth and registered the app as well as enabled OAuth on the solace broker. I am having hard time finding Oauth properties to connect to solace binder. Referred to various dev tutorials and could only find below properties…
-
Solace Jdk compatible matrix
Hi TEam, I am Java developer, I am looking for Solace Jdk-compatible matrix Which solace client jar is compatible with jdk version Thanks
-
Can't switch back to primary after server reboot.
We got server reboot and after that redundancy can not switch back to primary server. Somehow backup does not see it as ready . on primary No issues on network level.
-
Configure timeout for acknowledging message
Hello folks, Our webhooks take more time to send an acknowledged response back to the broker in qos1. Can we increase the timeout limit?
-
application going on non responsive mode after Consumers window size 0
application going non responsive mode after Consumers window size 0 under the Queue configuration I am not sure why window size is getting 0 . could you please help anyone , when the window size will be 0 and how to resume application after window size 0 ?
-
Exceeded Spool File Limit - Topic 'my/topic'
2023-03-29 02:44:14,962 [WARNING] solace.messaging.core: [_solace_session.py:942] [[SERVICE: 0x7f78a946fbb0] - [APP ID: app_cfdbe3dc-bd2a-4558-bbe2-3ac086e12db5]] {'caller_description': 'From service event callback', 'return_code': 'Unknown (503)', 'sub_code': 'SOLCLIENT_SUBCODE_DATA_OTHER', 'error_info_sub_code': 28,…
-
GoLang API? Let's Go! 🚀
👀 Whats the news? We've been working on a real treat for our developer community here at Solace over the past couple of months and that is --> drum roll please --> The new Solace PubSub+ Messaging API for Go! We will be releasing an early access to members of our community who are interested to use the bling new Go API .…
-
Synchronous publish in python ?
Hi all, what is the easiest, most clean code to publish ONE guaranteed message in python and only proceed after the ACK from the broker has arrived ? (I know, that this usage pattern is not performant, if I have many messages to publish. My use is different). Thank you Uli
-
How to get which broker is in control in HA pair (primary or backup) programmatically
How to get which broker is in control in HA pair (primary or backup) programmatically using SEMP API's or any other means but not using soladmin.
-
[Livestream event] Solace Office Hours: April 25, 2023
Time: 12 PM EDT, April 25, 2023 Where: https://www.youtube.com/watch?v=UcCeazsTn6A Description: This month is all about APIs for PubSub+ Platform! Come hang out with Solace developer advocate Aaron Lee for an interactive session where he will be joined by Julian Setiawan, one of Solace Cloud's high-flying architects.…
-
Consume existing Solace Queue using Python
Hi @marc @Tamimi we have existing solace queue with topic subscription enabled. need to listen and print message flowing to that queue. tried below code & got error, please help. persistent_receiver: PersistentMessageReceiver = messaging_service.create_persistent_message_receiver_builder()\…
