-
Solace supporting FHIR
Does Solace supports HL7 FHIR ?
-
arm64 on Linux
Hi, I'm exploring migration to arm64 architecture atm, but as soon as I publish my app for linux-musl-arm64 architecture and try to run it in Docker container based on Alpine 3.1 memory usage goes to 100% and container being killed by runtime. When switched back to x64 same code runs fine. Is Alpine supported at all for…
-
Encountered Error - Timed out waiting for credit to send Message
I using Camel AMQP client to receive messages from other EMS and publish to Solace EMS. However i encountered this error - "Timed out waiting for credit to send Message" if i set jms.sendTimeout=2000. 1) May i know how does broker issue credit to publisher? 2) Can I increase the credit at the EMS broker? at…
-
In the .NET API, why isn't the `CorrelationKey` set on the `RejectedMessageError`?
I have an application with messages sent to Persistent and a session event handler checking for SessionEvent.RejectedMessageErrorstatuses. I wan to add some special handling logic for the scenario where a persistent message is too large (>30MB), but for some reason the SessionEventArgs.CorrelationKey is always null,…
-
Selectors in node js
I see that selectors are not available in javascript API Will this feature ever come to javascript ? What are some alternatives options for consuming messages based on specific message headers in javascript ?
-
Need Help in orderbook-distribution-ext-users using Solace C API
SnapShot_Recovery(int Queue) { int argc=9; char *argv[9]; argv[0]="./SnapShot_Rec"; argv[1]="-c"; argv[2]="tcp:172.28.124.40:10986"; argv[3]="-u"; argv[4]="member_fo_prod@od_fo_prod"; argv[5]="-q"; if(Queue == 10){ argv[6]="lvq.nse.fo.od.10.orderbook"; } if(Queue == 11){ argv[6]="lvq.nse.fo.od.11.orderbook"; } if(Queue ==…
-
Shared Subscription Syntax for MQTT
Hello Solace Community, I have a question regarding the usage of shared subscriptions with an MQTT client. I found two different prefixes in the documentation and am curious to learn which is used in which case. I found in the documentation the following hint (see:) : Syntax of Shared Subscriptions A shared subscription…
-
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…
-
How to fetch the Non durable queue details via SEMP API
when i use SEMP API to fetch all the queues details from my vpn, found that Non durable queues is not included. is it as designed that non durable has been filter out from the SEMP API get queues return result? or is there a SEMP API can be use to get the non durable queue details?
-
How to send NACK(Negative Acknowledgement) using java API
Hi Team, Need your help to find the solution. Current Implementation details, SolConnectionFactory connectionFactory = SolJmsUtility.createConnectionFactory(); --> for create connection factory using host , vpn,trust store,keystore with auth scheme AUTHENTICATION_SCHEME_CLIENT_CERTIFICATE this.connection =…
-
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:…
-
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.…
-
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
-
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
-
Using an ITransactedSession and handling errors with the .net API
Suppose I am publishing guaranteed messages to a topic. I want to avoid sending duplicate messages. I am also going to send messages in transactional batches to make it easier to guarantee the broker receives the messages in the same order that the publisher creates them, without having to fall back to completely…
-
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…
-
Filtering messages on a topic by the consumer
I have a topic to which my backend service publishes the messages. I connect to that topic from my UI ( angular application) to consume the messages. I can have multiple browser sessions subscribing to the topic. I want to consume messages from the topic which are relevant to a browser session only
-
Certificate of Training - how to change the name?
Certificate of Training - how to change the name? I noticed that the value in field This is to certify that contains a spelling mistake. Am I able to correct that as self-service? In field My Profile I fixed the issue. When hitting the Download your Certificate button it is working with the previous spelling.
-
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…
-
Serialize Solace JCSMP BytesXMLMessage
I am working on Apache Flink based Realtime/Streaming data processing pipeline. Here my upstream system is Solace Q's. After receiving message from Solace, I have a requirement to store the message(BytesXMLMessage) in cache until all the functions(filter/map/translator/enricher) in the Flink pipeline are executed. Since…
-
Write for the community and get paid with the Solace Scholars Program!
Good news! We just launched the Solace Scholars Program to encourage original technical content about Solace by the community and for the community. What can you write about? You can write about your project, a use case, or something you are working on or have built using Solace technology and third-party integrations. You…
-
Timestamp when queue received message
Hi, does Solace durable queue store a timestamp when it received a message or can we configure it to do so? I tried InboundMessage.getTimeStamp and it always returns 0. I also tried InboundMessage.getSenderTimestamp and it's always null because I'm not filling it in the sender. According to an older question…
-
How to enable queue to accept incoming messages from CLI
Hello, I m using solace cli to provision a queue in the router, but I m not able to find the command that enable the incoming / outgoing functionality that I can see in the solace console UI. This is a snippet of the script : configure message-spool message-vpn default create queue dev/st1/q1/p1 access-type non-exclusive…
-
Could not load file or assembly 'SolaceSystems.Solclient.Messaging, Version=10.23.0.0 in container.
Hi Thank you Solace team - I was very excited with the release of version 10.23, as this now supports the Mac series M processors. I am now able to build event driven dotnet applications on my Mac M2, using rider, without issues. However, when dockerizing these applications & running the container locally on my M2, I still…
-
After Active-Passive solace brokers has switched there role. what is the best way to do switchback
Lets say After solace Active-Passive brokers has switched there role due to primary. what is the best way to handle switchback once previous primary node becomes healthy. should there be any change in configuration? pls let me know
-
Which SolOs support 2 NTP Server (Active/Backup) configuration for Appliance !
Which SolOs support 2 NTP Server (Active/Backup) configuration for Appliance ? This is required for redundancy purpose, I know workaround but more interested to know if in recent SolOs we have such feature!
-
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 .…
-
Make original client-ip visible inside Solace when running in Kubernetes
Hello everyone, we are running Solace in a Kubernetes Cluster. We have the issue that all connected clients are only shown with a IP address from the internal K8S Cluster subnet (e.g. 10.240.0.0/24). Our setup is as follows: We are using Traefik as IngressController Traefiks service is set to be of type LoadBalancer…
-
Is it possible to track messages in each topic and queue level
Hi Team, Can you please help us, is it possible to track messages in each topic and queue level (how many messages consume topic/queue level per day).
-
Python users! What are you using the Python API for?
Hey folks! As most of you know by now, we have a Solace PubSub+ Messaging API for Python and I am curious to know what use-cases you are using it for? How are you using the Python API? Where are you using it at? Happy to start the discussion and community sharing here! 🎉
