-
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:…
-
Can we use Solace connection pool for node.js application using solaceclient library
Hi Team, we are building an Azure Function using node.js. This azure function is connecting to Solace using SolaceClient library and publishing a message into Solace topic. Currently, we are open and close the connection for a request. We want use the Connection Pooling concept in Solace Connectivity. so that, same…
-
cluster external links
Greetings i have 2 deployments in azure configured, clustered together where the external links were working fine but recently show up as "internal link missing between solace1 and solace2". The external links show as "Down" in Operational State but the channels show as "Up" in Operational State Suggestions please ?
-
Spring Cloud Stream - Open telemetry Manual Instrumentation
I am trying to see any possibility to do manual instrumentation on scs consumer and publisher application. If there a possibility to achieve this with jcsmp opentelemetry dependency?
-
python qpid-proton cannot access solace broker after rename Message VPN
Hi everyone, I have some problems with connecting to solace with qpid-proton python. I connected to Solace that isn’t running on my local machine but other server, and I could send the message into the queue with the subscription topic and also receive the message from the queue successfully for a while. All I specified…
-
Regarding issue with the dll
Hi Team, I am trying to publish a message using a C# code. It is compiling correctly, but when I run it. It gives me error. By the looks libsolclient.dll is missing. Can you please help me?> Error Message System.Reflection.TargetInvocationException: Exception has been thrown by the target of an invocation. --->…
-
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:…
-
handle Throw error in Pub/Sub Pattern in Javascript
Hello, I am trying to get my head around how error with a publisher in javascript. When I invoke a failed connection via false credentials the following code snippet is executed in the Publisher code: publisher.session.on(solace.SessionEventCode.CONNECT_FAILED_ERROR, function (sessionEvent) { publisher.log('Connection…
-
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…
-
Content resolution example with Spring Cloud Stream
The Spring documentation mentions one of the core features of the framework: It tries to automatically convert incoming message payloads to type Person with the following code: @Bean public Consumer<Person> log() { return person -> { System.out.println("Received: " + person); }; } My attempts to have the incoming message…
-
PubSub+ Messaging API for Python with Mac M-series Support - Now Available
I am pleased to announce that as of the latest release of our Python API (v. 1.7.0) it now has support for Mac M-series processors so developers can use the API when developing applications on the latest Mac hardware. It can be downloaded through all the regular channels such as: Solace Downloads Page: Solace Products…
-
OpenTelemetry Agent for Spring cloud binder
I would like to autoinstrument my scs based application. For trial I have added opentelemetry agent latest version and started my application- But traces are not generating. Is there any separate agent available for SCS to to auto-instrument ?
-
Solace Python API on Mac M1 ?
Hi, I tried to install Solace Python API on Mac M1 and run some scripts with it. pip install solace-pubsubplus ⇒ Successful Running some script: Unable to load core library from [/Users/uherbst/Library/Python/3.11/lib/python/site-packages/solace/messaging/lib/macosx-x86_64/libsolclient.dylib]. Exception:…
-
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.
-
How to get a Map (java.util) of internal properties of a JCSMP message (in java)
When calling the `dump()` method on a message (BytesXMLMessage, with JCSMP API), there are two kind of information: 1. metadata, which are internal headers (replicationGroupMessageId, traceId, messageId, etc…) 2. message body in binary format I would like to know if it's possible to get the internal properties in a Map…
-
How to see information on each message in a queue
Problem You want to check the messages you are sending for error checking or validation but don’t know how to do that. Prerequisite Download Solace Java or .NET APIs Download SDKPerf Solution You can do that in two ways: * Option 1: Use a queue browser with either the Solace Java or .NET API or SDKPerf * Option 2: Use…
-
Pods are not running and failing very often
Hello Team, I have deployed the pubsub+ HA using helm chart in the GDCE environment (Google Distributed Cloud Edge) which is GKE cluster. There are 3 nodes, hence 3 pods are suppose to run. but 2 pods are failing very often. and one pod is about to start, but not starting. One of the Pod log says: "ERROR:…
-
How to send JSON in Javascript
Hello, in the example files for Javscript, perticular the TopicPublisher, there is a line of code that defines a message text. var messageText = 'Sample Message' var message = solace.SolclientFactory.createMessage() message.setDestination(solace.SolclientFactory.createTopicDestination(publisher.topicName))…
-
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.…
-
solace websocket connection interrupted - Messages sometimes doesn´t reach the end client
solace websocket connection interrupted - Messages sometimes doesn´t reach the end client We seeing some issues, that the websocket was not disconnected and died, but that it was the same, with the same solclient id before and after, when it happened. Like there was a hitch just in communication. " with the websocket…
-
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?
-
Is that possible to get Broker information into json format with SEMPv1/curl?
Hi all, good morning I'm trying to query such information using the commands below, and I would like to know if I can get the output into json format? curl -u "user:pwd" "https://solace-broker-IP:443/SEMP" -d '<rpc><show><hardware><details></details></hardware></show></rpc>' curl -u "user:pwd"…
-
Error parsing request header. Our best guess of the apiKey is: -1
I am following the tutorial at www.youtube.com/watch?v=AkQT_B1S1fQ When I fire up the kafka console producer proxy to publish messages, I get the following error on the Kafka Producer Proxy Server: [oracle@oracleeast19cOnOracleLinux7 tmp]$ /usr/lib/jvm/jdk-11.0.21/bin/java -jar…
-
DeliveryMode setting with Pure Java API
I am creating a rewrite of previously JMS specific spring implementation of an eventing library to pure java. But I could not find where to set DeliveryMode in the message properties, and then found that there pretty much is no place to set that per-message like I used to with JCSMP / JMS. I have to decide when I create…
-
Unsupported message amqp-value type: map
Does solace message broker support amqp-value type - map ? I using Apache Camel to send message to the broker. However, i faced an exception when sending the following message to Solace message broker. {message=up, uptime=1000.200} Log Message : ```` Caused by: org.apache.qpid.jms.provider.ProviderException: unsupported…
