-
[Demo] PubSub+ Distributed Tracing
The new distributed tracing functionality will let you observe events on a step-by-step basis so you can easily troubleshoot delivery and performance problems. If you are interested in participating in the early access, let @rtomkins know. Watch the demo
-
Message type for Object type (JAVA)
Hello, First things first, I'm a complete newb regarding Solace PubSub+. I'm trying to build a library to be used as a dependency that will deal with all the solace communication. In my case, I want the library to be abstract in a way where it does not care about what kind of information it is dealing with. My problem is…
-
Monthly Feature Highlight Training | June 2022
Continuing from our previous monthly feature highlight, Solace PubSub+ Broker version 10.0.0 brought us many different new and useful features when it comes to message replay. In this training we’ll be learning about the new configurable topic filtering feature as well as the ability to replay messages to a temporary…
-
Pause & Resume Solace Message consumption from a queue
Hi, we have requirement, when a particular job is running we need to stop listening to a queue to consume new messages after that job is completed we want to start consuming the messages from Queue. Using Solace Spring Cloud Stream how we can pause and resume consuming of messages from a queue. if we have some code snippet…
-
Solace’s PubSub+ Click-to-Connect Wizard for Google Cloud Run
In case you missed it. In release 10.0.0 we made available a Google Cloud Run Connector Wizard providing an easy way to take advantage of Google serverless computing in your EDA. This is great for those deploying GCP containerized apps for their Solace Event Mesh. Check out the details. -…
-
[Demo] PubSub+ Event Portal Lifecycle Management
Learn about the lifecycle management features in PubSub+ Event Portal, like finer-grained role-based access controls, object versions, lifecycle stats, and environments. Watch the demo
-
Subscribe to direct messages with RequestConfirm and correlationKey (.NET)
Hi, I'm using .NET. I would like to subscribe to direct messages. I have set session property SubscribeBlocking to false. I plan to use TaskCompletionSource as correlationKey and complete it when handling SubscriptionOk or SubscriptionError. Unfortunately I can't find suitable overload of ISession.Subscribe. There are 3…
-
New blog post for developers | Why Pyth Needs an Event Mesh to Enable Market Data for All
Pyth is an innovative market data distribution protocol that aims to decentralize market data distribution and thereby make it accessible to the masses. Read More › Leave your comments below. Source: https://solace.com/?p=46460
-
JCSMP get numbers of messages in QUEUE
Hi, is it possible to get actual number of messages in a queue with JCSMP API ? I want to monitor that number each 5 sec.
-
PubSub+ Messaging API for Java releases
The following API has been released and available for download: * PubSub+ Messaging API for Java 1.0.0 Release Summary This is the initial release of the PubSub+ Messaging API for Java. Solace created this API to modernize our JCSMP API. This is a separate standalone API which provides modern interfaces, patterns and…
-
Respool to queue
I was reading the behavior for Solace redelivery to consumer while assuming I have an exclusive queue with one consumer. First : Can you please let me know if the behavior is correctly understood ? Solace redelivers messages on the transport level. Meaning the messages are redelivered only when a flow or connection is…
-
How long does temporary queue last after client disconnects?
Hi. I would like to use temporary queues to make a client more robust so even if the client disconnects for a short period of time it won't lose any messages thanks to the queue. It's also desirable that temporary queues are destroyed if the client doesn't reconnect so too old messages don't waste space of the broker.…
-
How to Purge Queue?
Hi team, I have around 2k messages in queue. is there any way to purge the queue? I do see only delete messages not purge in actions tab. Best, Nagaraju Kshathriya
-
SEMP API to delete the messages from the queue?
Hi Team, Is there any way or SEMP API available to delete the messages from a queue? Thanks Tejas
-
Delete All the Messages on a Queue Using Legacy SEMP
For deleting all the messages on a queue you can use the following legacy SEMP command: admin message-spool message-vpn <vpn-name> delete-messages queue <queue-name>SEMP Request:<rpc semp-version="soltr/9_6VMR"> <admin> <message-spool> <vpn-name>vpn-name</vpn-name> <delete-messages> <queue-name>queue-name</queue-name>…
-
Why is the flow in the HandleMessageEvent sometimes null?
Hi, we implemented a Solace consumer using the .NET API following the guidelines (https://tutorials.solace.dev/dotnet/persistence-with-queues/). When runnung some tests we figured that sometimes messages were not properly acknowledged and removed from the queue. When debugging the HandleMessageEvent we found that…
-
Pubsub+ Now Offers Configurable Replay Topics!
Hey Solace operations and developers! PubSub+ is taking the replay log to the next level of flexibility by allowing you to configure exactly which topic is mapped to your replay log. PubSub+ Event Broker 10.0.0 allows you to customize exactly which topics are sent to your replay log. Your broker administrator to configure…
-
Sending json message using Python to queue using Kerberos authentication.
Does python api supports solace Kerberos authentication?. If so can any one share sample code? If not what are other ways to use Kerberos authentication for sending json message.
-
New blog post for developers | What We Announced in our June ‘22 PubSub+ Product Update
Yesterday I was joined by a few of the leaders of our product team to debut and demonstrate some of the really cool capabilities we’re adding to PubSub+ Platform. Our main goals these days are to make it easier for enterprises like yours to integrate applications in an event-driven manner, and to manage the resulting event…
-
[That Tech Show Podcast] The Magic behind Event-Driven Architecture with Jamil Ahmed
Listen to the podcast where Jamil Ahmed, Distinguished Engineer from Solace, shared with That Tech Show hosts Samuel Gregory and Chris Addams the "magic" behind Event-Driven Architecture (EDA). Podcast link: https://www.linkedin.com/posts/jamilahmed_tech-podcast-eventdrivenarchitecture-activity-6943149842852397056-TiLP
-
Python API limits message size to 0.176MB while Solace configuration has 10MB limit
Hello all, I am trying to use the Python API from the official repo (https://github.com/SolaceSamples/solace-samples-python/blob/master/patterns/guaranteed_publisher.py) to publish some messages of size 3-5 MB to a Solace queue, but all the messages under 0.176 MB work and the ones above do not work. I am trying strings…
-
How does the sslvch option of SDKPerf work
In the newer version of SDKPerf, such as sdkperf-jcsmp-8.4.5.19, sdkperf-jms-8.4.6.5. There is an option "sslvch", the description is "Enable validation of certificate hostname". How does the validation work? and what is the expected out put when this option is applied? I tried different combinations, but didn't see any…
-
.Net integration using .pem certificate
Hello, I'm looking for some help on how to import .pem certificate and use it .Net code. Any help or sample implementation for reference will be appreciated.
-
When import the certificate getting error access denied
When i used the sanbox account certificate not got any error when we try to import the UAT certificate in our application getting access denied error when both certificate have same detail we used .pfx that extract from .cer file.
-
Reply Topic name in InboundMessage - GOLANG API
HI, I need to get reply to topic in message received in gateway mode.. It's possible? Exist some a property? I tried thus... reply_to, _ := message.GetProperty("reply_to") but not working... returned nill... How to do for get reply topic name in the message???? I am using GOLANG API 1.0.1... Thanks for help..
-
How to set up consumer in Azure Container Instances using python qpid proton
Hi all, I have been trying to deploy a consumer as an Azure Container Instance implemented in python, which uses qpid proton. When running the Docker image locally it works without any issue, however when deploying the image as an ACI, I obtain the following error: ```2022-06-03T16:05:19UTC ERROR: proton - Couldn't…
-
I want to add delay on consumption of messages. Delay will be dynamic in my application.
I want to add delay on consumption of messages. Delay will be dynamic in my application. Example: For Message A delay will be of 1 min and for Message B delay will be 2 min. I tried with below code of snippet but it's not working. TextMessage msg = JCSMPFactory.onlyInstance().createMessage(TextMessage.class);…
-
Solace throughput scaling
What is the rate of consuming message/sec for a consumer with 1 concurrency in spring cloud stream app with solace. Just wondering what would be throughput / hour if there is just one consumer with 1 concurrency smoothly. Using Physical Solace Appliances.
-
Found issue, Where messages were stuck in the queue, it wont accept and let consume from queue
The messages were stuck in the queue, we cant publish anything to it but the problem is the listener is not even consuming them to create space for new messages. Caused by: com.solacesystems.jcsmp.InvalidOperationException: Tried to perform operation on a closed XML message producer 2022-06-02T15:38:25.309-05:00…
-
ELK / Logstash performance testing
Hi all, Not really (specifically) a Solace thing, but wondering if anyone out there has done any performance testing with Logstash, using either the JMS plugins or other (MQTT Beats?). I'm looking for any ballpark ideas on throughput, performance of the Logstash VM, etc. And if you've done any load testing, how did you…
