-
Does Solace support any kind of Connector from/to MSMQ ?
We currently want to integrate a .net based solution and i wanted to know if any connectors exists from/to Solace from/to MSMQ ? Or is only option to use the .net API and receive messages to forward into MSMQ ? (message bridge)
-
How to set max-delivered-unacked-msgs-per-flow via JCSMP API
I see that .Net API has methods to set WindowSize and MaxUnackedMessages () But I do not see any such documentation for JCSMP API, can you please let me know how to set those? Regards, Karthik
-
TTLs & Message Processing
Dear Experts, I am trying to use JCSMP client and I have three questions w.r.t message processing at client side and TTL : I have realised that if a message expires just at the moment it is being listened to at the client side, the message would be processed by client and also re-delivered via DMQ (as I am listening to DMQ…
-
Support for Priority ?
We are currently looking into a multi tenant integration (up to 800 tenants). If we would create 1 queue per event type we would get 20+ Event Types * 800 Unit = 16000 Queues!!!! So alternative would be to have 1 queue per Unit but in this queue different message events will arrive and some are more important and some…
-
cache request on python
I use CachedMessageSubscriptionRequest.cached_first to call cache data but I got Fail on_completion CacheRequestOutcomeListenerHandler:CacheRequestOutcome.FAILED, cache_request_id:3 exception:Unable to send cache request. Caller Description: On cache request send. Error Info Sub code: [1]. Error: [Only…
-
Cache request on python
I found that solace PubSub+ 1.6.0 support cache But I follow this step to do cache request I can not receive the cache message from direct_receiver.receive_async(MessageHandlerExample()) but I can use DirectMessageReceiver.add_subscription to get message(CacheStatus.LIVE). and I also develope C# code it allowed call…
-
what changes are required on Solace VPN to connect to Kafka Connector.
From a solace admins end what are changes i need to make to my VPN, so the Kafka connectors can connect easily.
-
New blog post for developers | Introducing Architecture Diagram Icons
A big part of our developer relations team's mission in life is making life easier for developers of event-driven systems, so I'm pleased to introduce a new set of icons that I hope will make it easier for architects, developers and dreamers looking to communicate and collaborate on their ideas for building event-driven…
-
Introducing Solace & EDA Icons for Architecture Diagrams
Hi Folks! 📣 I'm excited to share that we now have Solace & EDA Icons available for everyone in the Solace Community to use when creating architecture diagrams, specifically those built with the products of Solace PubSub+ Platform, including our event broker, event platform and wide range of APIs and connectors. ⭐️ Here are…
-
Which Java client API to use ?
So I am a bit confused on which Java client API to use for connecting to a solace appliance from an application. My understanding is that we have the option of using JCSMP , RTO , JMS , Spring JMS vs Spring JCSMP ? Could some one please summarize at a high level what are the pros and cons of each approach in terms of…
-
Defragmentation Failing: Unmovable Local Transaction
I'm having trouble running defragmentation of a broker's message spool - which is currently at 90% and using up all the disk space. Each time I run defragmentation it completes about 5% until it exits with the same Exit Condition: ``` Last Result: Completed On: Oct 30 2023 07:29:21 UTC Completion %: 5% Exit Condition:…
-
Should the FlowReceiver be closed before recreating a new FlowReceiver?
I am following along with this solace tutorial. I am now testing and handling this portion of the tutorial where I handle REPLAY_START_TIME_NOT_AVAILABLE: . I have added a System.out.println(consumer.isClosed()); before I recreate a new FlowReceiver to replay from the beginning. This is printing out false.…
-
Can Solace event listening by a client with multiple user accounts?
I am face a problem, as some of the clients in solace is not maintaining by me, I would like to define multiple user account for the same client to prevent if any account expired on their side, is it possible?
-
Is there a difference for Solace CLI Commands in PubSub+ Cloud / Software Event Broker / Appliance
Is there a differences in terms of Solace CLI commands among PubSub+ Cloud / Software Event Broker / Appliance? I cannot find some commands mentioned in the help pages when I connect to CLI in PubSub+ Cloud? Thank you
-
How to keep the queue consumer flow open?
Hi everyone, I have actually a bunch of questions, hopefully it's okay to ask here :) How to keep the queue consumer flow open? Example Consumer provided here (https://tutorials.solace.dev/dotnet/persistence-with-queues/) gets messages only currently on the queue and closes immediately after that. How to keep the flow open…
-
Sending large amount of guaranteed messages with nodejs
Hi, we want to send a large amount of guaranteed messages with nodejs. Our code is similar to https://github.com/SolaceSamples/solace-samples-nodejs/blob/master/src/basic-samples/ConfirmedPublish.js but without limited number of messages (we do not want to send 10 messages, but much more). After sending a few messages, we…
-
PERFORMANCE! Why you should use Message.reset() in Solace APIs..!
Hi Developers! Want to go fast? Faster, anyway? Read on... I'm just putting the finishing touches on a new bunch of Solace Java (JCSMP) samples, and have been doing a bit of performance testing with them. They are still meant to be fairly simple and straightforward, and don't try to maximize absolute throughput…
-
PDB for libsolclient.dll version 7.19.0.30 for x64 windows
Hi All Is there a download link for the libsolclient.pdb for version 7.19.0.30 for x64 windows. I am building against version 7.14.0.8. However during runtime the program is picking up 7.19.0.30. Is that a problem ? I see some unexpected behaviour. and the pdb will give a slightly better idea. the program actually starts…
-
.NET - Enforcing Queue to Respect Message Priority
Hello everyone, I am trying to implement a simple PoC solution to check whether Solace PubSub+ will be appropriate for my company. All went fine to the moment I wanted to use priority messaging. I would like to 1. create a queue from .NET 2. assign Priority to messages 3. enforce the queue to respect message priority…
-
Want to make two pods communicate through Solace pubSub.
I have two pods in different namespace in Kubernetes and want each pod talk to other pods through solace, could you please tell me how I implement the same?
-
Solace Beta Opportunity: Solace Terraform Software Provider (Declarative SEMP)
I declare Solace's Hashicorp Terraform Software Broker Provider Public Beta Release 0.9.0 available! See the link to Solace's Hashicorp Registry, customer documentation, and release notes below! Now is your opportunity to try out the Beta release of the PubSub+ Software Broker Provider for Service Automation! This…
-
python using tls : error connecting to a Solace pubsub broker
# Broker Config broker_props = { # "solace.messaging.application_id" : "default", "solace.messaging.transport.host": os.environ.get('SOLACE_HOST') or "tcps://pubsub.preops.nm.eurocontrol.int:5671", "solace.messaging.service.vpn-name": os.environ.get('SOLACE_VPN') or "",…
-
BytesXMLMessage data safety
I saw in the documentation the recommendation not to cache BytesXMLMessage objects, because they may be reused. I am usually extracting the data from it using getBytes() method, and pass it down to the next layer of my processing. Question: is it safe to pass that data array as is? Do I need to make a copy of it?
-
Python Proton AMQPS Transport Error
Good afternoon all, Am having some odd behavior using a varient of Solace demo code for Python/Proton AMQPS connection: https://github.com/SolaceSamples/solace-samples-amqp-qpid-proton-python/blob/master/src/simple_recv.py Using the methodology shown in this case, but with a pem key/password i can successfully connect to a…
-
New blog post for developers | The Importance of Event Governance in EDA
Check out this new blog post by @StephenTsoi re: The Importance of Event Governance in EDA. In this blog he covers why you need event governance, and then talks about Event Governance in terms of identification, flow control, security control, audit, reusability and testing.
-
URGENT-Iterate through Solace Message Queue
Hi All, We have read data from SOLACE queue in .Net using C# . However we are unable to iterate through SOLACE queue messages as we are not receiving Message ID or datetime. Hence if any one could able to loop through the QUEUE message then please share the code snippet. Thanks in advance Sumeet
-
Message redelivery for New Java API - if an exception or un-acknowledgement happened
I am exploring new Java API for solace integration. I have noticed that message redelivery is not happening if an exception happened in consumer thread. In JCMP api we were able close/ unbind and bind consumer. Spring cloud stream binder also doing same way. But new Java API I those apis's were not exposed. Please let me…
-
Match (regex) incoming message topic to a list of topics (Python)
Hi, I have a queue which is internally subscribed to various topics. When I read from this queue I can retrieve the original topic. I have a list of actions in my application that run based on whether or not this topic matches that entry: message topic: cars/toyota List of topic actions: cars/bmw > cars/> cars/*/> I think…
-
Google Storage Connector Speed Issue
Hello, There seems to be a problem with delivering message to a google cloud storage bucket. Solace can't deliver the messages in the same speed as they come in. It falls back to 1 per 1-3 seconds. Why would this happen and why would it need to redeliver? I've checked it with another storage account and there it has no…
-
Solace JMS Channel closing on it's own when running on a Kubernetes cluster (Spring Boot Autoconfig)
Log snippet: {"com.solacesystems.jcsmp.protocol.impl.TcpClientChannel","label": "Client-109: Connected to host 'orig=host:55555, scheme=tcp://, host=host, port=55555' (smfclient 109)"} {"com.solacesystems.jcsmp.protocol.impl.TcpClientChannel","label":"Client-109: Channel Closed (smfclient 109)"} It basically loops like…
