-
MessagePublishReceiptListener is not getting the acknowledgement python API
class SolaceMessagePublishReceiptListener(MessagePublishReceiptListener): def __init__(self): self._publish_count = 0 @property def get_publish_count(self): return self._publish_count def on_publish_receipt(self, publish_receipt: 'PublishReceipt'): with lock: self._publish_count += 1 print(f"\tSOLACE -- \n", f"\tMessage:…
-
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…
-
How does Queue or Topic Proxy differ from DestinationImpl?
In my previous post I am facing a class cast exception while writing the consumer code. java.lang.ClassCastException: com.solacesystems.jms.ra.outbound.QueueProxy cannot be cast to weblogic.jms.common.DestinationImplStack Trace for RuntimeException was:java.lang.ClassCastException:…
-
How to solve this error: Received disposition with role=receiver
I using AMQP Camel to read message from Queue A, add header to the message and send to topic B. There will be 200 message every 300 millisecond. Based on the log file, the JMS MessageConsumer closed every 1 seconds. I don't know why. Can someone give me hint how to prevent the MessageConsumer to close ? Camel Route…
-
java.lang.ClassCastException: Solace QueueProxy cannot be cast to Weblogic DestinationImpl
Hey Guys, I was recently introduced to Solace and am trying to deploy a sample Pub/Sub application using JMS API on a local Weblogic server but ran into this class cast error which I cant seem to find a solution for. I have created a topic "MyTopic" which is subscribed by a queue, "MyQueue" and also configured the JNDI…
-
Unable to start the Solace pubsub in podman
I am trying to start the pusub in podman, but when I run the below command the container is in running state and I am unable to access the console in browser. Command: podman run -u 1000:1000 --ulimit nofile=524288:524288 -p 1943:1943 -p 55555:55555 --shm-size=1g --env username_admin_globalaccesslevel=admin --env…
-
Golang Parallel For One Consumer?
How can I increase the number of connections for a consumer using pubsubplus-go-client? We pass a callback to ReceiveAsync for a consumer via PersistentMessageReceiver, but only one message is processed at a time.
-
Cleanup of Unused Queues
In an use-case like an mqtt client connects with CleanStart: No and Durable: Yes, the queue will be created and msgs are consumed as per the subscriptions. But when we restart the client, with a different session name will lead to creation of new queue. Now, both the old and new queues will have the same subscriptions.…
-
Message Spool Ingress Discard
May i know what is the cause for message spool ingress discards? How to prevent it? How to troubleshoot the issue?
-
SMF AD ack response error [condition = amqp:resource-limit-exceeded]
I have seen this error in logs. Can someone explains me when this error occurs and how to prevent it in future? I checked the event log of the solace software broker and found out there are warning messages — VPN_AD_MSG_SPOOL_QUOTA_EXCEED: test - Message VPN(1) test message spool quota (102400 KB) exceeded, messages…
-
Parsing characters from Binary data
Hi @marc @Aaron @all I am deserialising some stream of binary data using the payload format as — typedef struct { char messageType; // 'N' or 'G' ('N' – New Normal Order, 'G' – New Spread Order) long timestamp; // Numeric Time in nanoseconds from 01-Jan-1980 00:00:00 double orderID; // Numeric Day Unique Order Reference…
-
Binary to ASCII
Hi @marc @Aaron How do I convert the data received from queue(lvq) to ASCII or human readable format?
-
Sequence Convoy Pattern with Solace
Hi Team, In my landscape, 20+ applications are generating events that are consumed by about 50 applications. Each consumer needs to receive all the messages from the 20+ in the same order they are generated per customerID. Meaning, for customer/123 all events from 20+ should be convoyed in sequence for all consumers. Each…
-
JMSToolBox not showing messages greater than 4MB
We use JMSToolBox to browse the messages in Solace Queue since there is no built-in tool. We now faced strange behaviour likely caused by large message sizes. What happened: * We published messages >5 MB to Solace * We could see the messages in Solace Portal(message count increased) * When using JMSToolbox and looking into…
-
Release note / Change Logs for version 10.0.1.XX
May i know where to find changes log for version 10.0.1.XX ? I want to know whether there is any vulnerability patch happen in 10.0.1.XX
-
Will JCSMPInboundChannelAdapter have configurable shutdownInterruptThresholdInMillis?
Hello, we are experiencing an issue with graceful shutdown of an application. We are using spring cloud "com.solace.spring.cloud:spring-cloud-starter-stream-solace:4.1.0" There is no awaiting for the termination and messages finish in the error queue. Is there a better way to gracefully stop and resume? Will configuring…
-
Intermittent "Assured message delivery is not enabled on this channel" errors
Hi there, We've had this publisher app that sends events to topics other client apps in the firm are subscribed to using queues of their own, for years. Lately, though, we've started to notice these exceptions intermittently that we've encountered previously. The client profile has "Allow Guaranteed message send" enabled…
-
Can someone please help me to know How to generate the details mentioned below.
IP Address of the Solace messaging appliance in the form: [Protocol:]Host[:Port] (e.g. tcp:192.168.160.101:55555 ). * Client username and Message-vpn used by the sample application (e.g. browser_nse_dev) * Password for the Client username used by sample application (e.g. browser)
-
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…
-
Solace Spring Cloud Stream Function (Processor pattern) with StreamBridge
Hi, I currently have a usecase wherein I have implemented a Processor pattern using the typical Bean Function<?,?> for my SCS application. I understand that a Processor pattern is a straightforward Input-Output Solace stream. But now I have an additional requirement that, within the processor, an arbitrary event message…
-
C API error as --'solclient/solClient.h' file not found #include "solclient/solClient.h"
When I am trying to run a file in C, I am getting this error. Can someone please help me with this. I am new to PubSub+. Trying to learn as much as I can.
-
solace-pubsubplus is not getting installed in python:3.8.0-alpine3.10
Trying to install the solace-pubsubplus==1.6.0 into the python3.8.0-alphine3.10 inside the docker ERROR: Could not find a version that satisfies the requirement solace-pubsubplus==1.6.0 (from versions: 0.2.0, 0.2.1) ERROR: No matching distribution found for solace-pubsubplus==1.6.0 error building image: error building…
-
Publish block when over the memory / disk threshold
Hi, we are migrating from rabbit to solace now. There is a feature (https://www.rabbitmq.com/alarms.html) RabbitMQ will block connections that publish messages when over the memory/disk threshold. I see there is a way to set the threshold in solace: https://docs.solace.com/Monitoring/Configuring-System-Event-Thresholds.htm…
-
com.solacesystems.jcsmp.JCSMPErrorResponseException: 401: Certificate Error [Subcode:1]
Hi Team, I'm trying to publish on Solace queue with Client Certificate Authentication using self signed certificate. But getting below error: Remote addr: mr-connection-dcnuo3u5bkz.messaging.solace.cloud Remote port: 55443) - ) com.solacesystems.jcsmp.JCSMPErrorResponseException: 401: Certificate Error [Subcode:1] at…
-
SSL 'SSL-client' cannot read, sslErr = 5 in python client
Not able to connect to the solace broker using the python client library. Below mentioned how i connected: SOLACE_BROKER_PROPERTIES = { "solace.messaging.client.name": "test-client", "solace.messaging.transport.host": "tcps://mr-test.messaging.solace.cloud:55443", "solace.messaging.service.vpn-name": "com-test"),…
-
Receiving Error Response (503) Max clients exceeded for queue
Definition of exclusive queues: exclusive specifies that only one consumer can receive a message at any one time, while additional consumers may be connected as standby. That is, only one Flow can be active. Only the first consumer to bind can receive messages. If the first consumer disconnects, the second consumer…
-
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 ?
-
Queue Authorizations
Dear All, When I check the queue authorizations(permissions), it looks like it's based on either you're being an owner or not and there is only one owner if I am mistaken. Is there a way to assign this ownership to multiple users-consumers so that only "these" can do the same activities, instead of only one user.
-
How to check if field exists or is null in a solace map?
I am using Solace c client api (CCSMP), to subscribe to a Solace topic where messages contain a map. A value for the same key in a map can be a string or null. Is there a way to check if a value for a key is null? If I try to retrieve a value for a key and it's null, Solace API logs "Field Type Null could not be converted…
-
Broker v10.5 - SparkplugB 3.0 Compliant
I ran the Sparkplug Compliant test against our 10.5 broker and the result is, it is complaint. The 10.5 broker was running as a hyper-v image. I had to make the changes as detailed at in order for the retain test to pass. I had to increase the VM's memory to 8192 MB in order to make the aforementioned MQTT retain changes.…
