-
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…
-
Introductions Thread - New to the community? Start here!
Intro Hi all, if you've joined recently you may have seen a welcome message from me in your inbox but I figured a great way to get to know folks here would be an intro thread. As we share Solace related knowledge and learn from each other, let's get to know each other! Name or handle (only share what you're comfortable…
-
Solace Beta Opportunity: Solace Terraform Appliance Provider (Declarative SEMP)
Now Available! Solace's Hashicorp Terraform Appliance Provider Public Beta Release 0.9.0 is available from the Terraform Registry! Now is your opportunity to try out the Beta release of the PubSub+ Appliance Provider alone or in combination with the PubSub+ Software Broker Provider for Service Automation! The appliance…
-
New Graphical Designer in Event Portal
Hi all, 📣 We are pleased to announce the availability of the new graphical designer in Event Portal. This feature is being delivered in phases, with this first phase providing a graphical view of the event driven architecture for each of your application domains. ⭐️ The graph displays the latest, non-retired version of…
-
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…
-
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…
-
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:…
-
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…
-
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 ?
-
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…
-
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:…
-
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 ?
-
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?
-
Debizium Connector
Hi, I posted to check on this a few months back, but haven't heard any update. Opening this up again to see if there is any news
-
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…
-
Using Proxy setting to connect to Event Broker
I am using Java Client code to connect to event broker and need to know how to do Proxy setting in the code. Tried below code for HOST but its not recognizing the below fromat and throwing "Too many colons in host" exception tcps:solace.company.com%socks5://User:PassWord@proxy.company.com:13128
-
Opentelemetry support New Java API
Hi Team, I am building an application with new Java API. And I have a use case to integrate with open telemetry for distributed tracing. I guess 1.4.0 version is not supporting open telemetry. When can we expect the support? or is there any way that we can achieve this ?
-
CONNECT_FAILED_ERROR : All hosts failed DNS resolution
I am trying to establish connection from my nodejs app(angular) to solace and I am getting CONNECT_FAILED_ERROR : All hosts failed DNS resolution (error subcode 145). I am not sure what I am missing. I am able to connect to solace from my backend service using the same host and port details. From UI its giving me error
-
Any tricks to speed up Commit() using an ITransactedSession in C#?
This question follows on from this discussion : The objective here is to… publish guaranteed messages, and be certain that the broker receives them in the order in which they were generated so that re-ordering does not have to be done on the subscriber side (for reasons summarised in the linked thread), and Avoid…