-
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…
-
whether the queue messages objects returned in the SEMP response list follow a specific order
When we call the SEMP API to fetch message information from a queue using the Get API /msageVpns/{msgVpnName}/queues/{queueName}/msgs, it returns a list of Queue Message objects. Is there a certain order that these message objects follow in the response list? Also, is it safe to assume that the first message object in the…
-
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…
-
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…
-
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…
-
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?
-
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,…
-
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.
-
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()\…
-
New blog post for developers | How Does PubSub+ Cloud Help you Secure Your Data in the Cloud?
Preena Patel is a technical writer at Maropost. Read More › Leave your comments below. Source: https://solace.com/?p=49002
-
any restriction on the number of subscriptions topics per Non-durable Queue level for solace 3530
Hi All, Please confirm if there is any restriction on the number of subscriptions topics per Non-durable Queue level for solace appliance 3530?Â
-
In Spring cloud , i would like to read data from pre-define queue.
Currently spring cloud app will create the queue "scst/an/some randome-id/plain/myConsumer-in-0" at server startup (some thing similar), Since i already have a queue and queue has some persistence message so how to command spring cloud to use existing queue for subscriptions.
-
Failed to consume a message from destination Queue
I am using Spring cloud stream 2021.0.2 to consume messages from queue, when some messages are sent , I can see the message get spooled continously in the queue but It is not coming inside application and processed because of below exception. Please help org.springframework.messaging.MessagingException: Incorrect type…
-
Blocking send operation
Is there a way to invoke the send method in a blocking way? I would like to wait for the ack/nack/timeout, and continue only after I have the result. My current solution is a wrapper of the original send method, that keeps track of the sent messages and waits for the event from the event broker.
-
PubSub+ Messaging API for C & Go - Support for Apple's M-series Macs - Now Available
Hello everyone, We are excited to announce that the PubSub+ Messaging API for C (also known as CCSMP) and Go now officially support Mac M-series processors! This means that developers can now build applications that take full advantage of the power and efficiency of Apple's latest generation of processors using Solace's…
-
Read Consumer response object from broker in function app
Hi, We have an Event driven app which publish a payload to a topic in solace broker from Azure function app. There is a consumer which is of REST endpoint. Once the message is delivered and processed by consumer, they send a 200 OK with an object `{"message": "SUCCESS"}` . We want to read this response object from the…
