-
Beta Opportunity: Solace Schema Registry - Beta Now Available!
In recent years, the use of Schema Registries has been growing in order to improve data quality and governance and standardize on topics & schemas. In short, Schema Registries allow you to ensure payload compatibility between producers and consumers and upgrade schemas on different applications independently while ensuring…
-
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 Terraform Software & Cloud Provider & Modules (Declarative SEMP) now generally available!
Our first Declarative SEMP for Terraform Release General Availability release! This, like our Beta, was designed to manage broker services (the message VPN and the configuration contained within it)! More than just a provider, this release also includes modules! Terraform modules encapsulate the configuration of a set of…
-
New Distributed Tracing Video Series
Howdy y'all! We have a new video series explaining what distributed tracing is and how it fits within event-driven architecture. You can watch it here! This playlist includes Episodes 1 through 5 and cover: 1: What is Open Telemetry? 2: How does Open Telemetry work? 3: The Basics of Distributed Tracing 4: Introduction to…
-
SolaceCommunity Github Contribution Guide 🎉
📣 We are launching the SolaceCommunity Github organization! This organization offers community supported, authored and maintained open source projects. As our community grows, these projects offer integration with, and ways to use, Solace technologies. What to contribute Contributions to the SolaceCommunity Github…
-
Implementing Exactly Once in Order (or FIFO) in Solace
Hi there, We have recently introduced SAP Advanced Event Mesh (AEM), which under the hood is 'Solace PubSub+ Cloud' in our Integration Landscape, and now I am seeking for the best way to implement 'Exactly Once In Order' Sequencing in our Integration. We are on Version 10.9.1.114-0. The Integration is going to do the…
-
iOS Simulator-Compatible Libraries or Universal Versions for Solace SDK
I have downloaded the iOS support libraries from the Solace website (). However, when I try to run my app on the iOS simulator, I encounter the following error: "Building for 'iOS-simulator', but linking in object file(s) built for 'iOS'" This error is occurring for the following libraries: libsolclient.a…
-
solace rust library
any plan for rust official rust library?
-
Solace bridge no starting.
I have created a unidirectional guaranteed message bridge between my solace vpns which are on same broker but the bridge status still seems to be down, can someone help me what i missed. a576a7d2708c(configure/message-vpn)# show bridge guaranteed_bridge Total # Bridges : 1 of 50 Local Bridges : 1 of 25Remote Bridges : 0 of…
-
How to monitor Solace as an external consumer
Hi, I have inherited an application that consumes messages from an external Solace pub+sub system and fairly new to it. What would be the best way to monitor from a consumer perspective? Having been thinking of the following check the auth check the connection to queue check the queue (is it possible to measure things like…
-
Python client reconnection failure
Hi, I use Python package solace-pubsubplus v 1.2.0 to connect to Solace. My client has the following reconnection settings: reconnect retries = 20 and reconnect retry wait = 3000 ms. Here is my code for that: messaging_service = MessagingService.builder().from_properties(broker_props) \…
-
How to prevent endless loop of timeouts when the Solace queue is not available
Our microservices were not able to connect to clients respective Solace queues. Although it seems microservices were able to connect to Solace, the queues themselves were not available, causing a huge volume of time outs. At the moment the configuration has a set number of retries for the connection to Solace, but no…
-
Are key words "TOPIC" and "QUEUE" case-sensitive in CURL?
Hello Exports, Greetings. Are key words "TOPIC" and "QUEUE" case-sensitive in CURL? Thank you. https://docs.solace.com/API/RESTMessagingPrtl/Solace-REST-Example.htm Felix, BR
-
Allowing a publisher to see the last message published while preventing subscription
I'm a bit stuck trying to figure out the best way to combine some features I'd like to provide in our in-house broker abstraction library. I have an IPublication<T> interface, which exposes a "simple" API to consumers, Task PublishAsync(T message, CancellationToken ct)and event Action<T>? MessagePublished. So far so good.…
-
Solace Spring Cloud processor app issues when upgrading to version 4.2.0 from 3.4.0
Our client is using Solace PubSub+ broker version 9.25 and are not going to move to the version >10.2, therefore we have to get our application working with the version 9.25 of broker. Previously we used Java 8 and Spring Boot 2 and "com.solace.spring.cloud:spring-cloud-starter-stream-solace:3.4.0". The config for…
-
Setting up AWS Cognito OAuth for PubSub+
Hello! Has anyone had success setting up AWS Cognito OAuth for PubSub+? I went through How to set up Solace PubSub+ Event Broker with OAuth for MQTT against Keycloak but was unable to translate the instructions to Cognito. Has anyone integrate the two successfully? If so, any pointers or advice on doing so? Thank you!
-
How do I non-destructively view a message payload of the most recent message in a queue?
I've come across this issue a few times recently. The two tools I've tried using are JMSToolbox and SDKPerf. I've found neither really have the documentation or resources to help with this. The problem I'm having is I have large queues and DMQs (some with 2M+ messages) and we are trying to determine the payloads of these…
-
Random "failed to retrieve" error in streaming scenario
Hello together, I currently working on a lokal setup where solace software acts as the message broker in docker setup. I try to receive events from a existing queue, which is not a problem in general, but in my case I emit them in a flink job (wirtten with pyflink). I receive around 1000-3000 events/sec from this queue. I…
-
Exploring Event-Driven Architecture in Everyday Applications
Hey everyone! I have been exploring event-driven architecture (EDA) & its practical applications outside of traditional enterprise use cases. For instance; how might EDA enhance everyday consumer technologies, like smart home devices / personal productivity apps?🤔 I am curious to explore how EDA can make these systems more…
-
Possible to have partitioned queue without rebalancing or handoff?
Partitioned queues are a nice feature. With the hash function, a given consumer always gets the same subset of incoming messages. In my use-case, I never want a consumer to process messages from a different partition. I would prefer for the msgs to fill up their assigned partition and eventually to lose msgs rather than…
-
Partitioned Queue and Topic Subscription
We have a setup with the following A producer posting events to topic "T/o-all/event-type/{eventType}" where {eventType} is dynamic value. When posting the event to the topic we also set jmsTemplate.convertAndSend(topic, event, message -> { message.setStringProperty(SupportedProperty.JMSX_GROUP_ID,partitionKey); return…
-
How can I resolve the error BinaryFormatter serialization and deserialization are disabled within th
I'm using Solace version 10.5 and we are migrating to dotnet core 8 In the following line : ContextFactory.Instance.CreateContext(new ContextProperties(), null); I get the exception : Exception thrown: 'System.NotSupportedException' in System.Runtime.Serialization.Formatters.dll An exception of type…
-
Topic to Queue Mapping and Queue Full
In a setup where we are using Topic to Queue Mapping, lets say the queue is full and can not receive any new messages, what happens to the messages that are being posted to the Topic and are subscribed by the Queue (that is full and unable to receive any new message) . Are these messages lost ?
-
[Solace: solace.dev/go/messaging] Unable to run debug session when solace dependency is included
Hi All, We are unable to run go debugger when we include the `solace.dev/go/messaging` dependency in Mac with intel processor. The same works fine on Mac with the M1 chipset. The issue can be reproduced with the following code snippet: package main import ( "solace.dev/go/messaging" ) func main() { println("Hello, World!")…
-
Connecting ServiceNow as subscriber
I'm looking for guidance on connecting ServiceNow as a subscriber to event topics on a Solace PubSub+ event broker. The business domain for this is enterprise asset lifecycle management across multiple asset classes with their own asset registers/systems-of-record and field service management performed in ServiceNow FSM.…
-
Do Event Portal’s Graphical Designer creates objects in event broker?
I am aware about Event Portal’s Graphical Designer and information mentioned here. It helps Architects to design EDA and developers to understand the same for implementation. But Do these graphical design able to create the objects like queues, topics etc. in event broker service. Any thoughts with this. BR, Swap
-
Solace jms spring boot starter has started failing eureka health check after april 2024.
Hi All, We are using dependency of solace-jms-spring-boot-starter (1.0.0) version and spring boot version is 2.7.13. Till April 2024 we didnt face any issue. But yesterday when we deployed our application in production we got an unexpected exception of Connection refused and application was up and running but was…
-
cli-to-semp is not working for adding access-level-exception.
I'm trying to use a SEMP v1 command to change the access level exception for a user in a specific message VPN, but I'm encountering a schema validation error. Here is the command I used: I tried cli-to-semp command but it's giving me the following error : Unexpected parameter(s): access-level-exception at…
-
how to get the number of connections per client username in a vpn
i have a vpn which has a lot connections, i want to see which usernames are creating the most number of connections. how can i do that
-
Moved: Introducing Micro-Integrations
This discussion has been moved.
-
Exploring Event-Driven Architectures and Solace
Hi Solace community! I am a Developer Advocate at RisingWave Labs. RisingWave is a Postgres-compatible data platform designed for event-driven applications, while Solace serves as an event broker for event-driven architectures. I've been following Giri Venkatesan's insightful content about EDA, and when I explored Solace…
-
Java Client: How to set ttl (seconds) when creating a queue
Hey, I am trying to find a way of how to set a ttl property in seconds when creating a new queue via jms. Currently I'm using the EndpointProperties which provides only the option to respect the ttl (I guess that can come as a value in headers from the messages). By default when a queue is created and the respect ttl…
-
Solace Queue Browser Using Python
Was wondering if anyone has had any luck with building a queue browser using Python & the Solace Python API? I have seen some queue browsing options using SDKPerf & Java (including the Chrome Browser) but I was hoping to do something similar but with Python. It's also worth noting while the Chrome Browser tool is great,…
-
Deduplication of events (business events vs granular events)
Hi all, I'm interested in your thoughts on this matter. Our current workaround does not ensure guaranteed delivery, so we risk losing messages. Use Case How can we eliminate duplicate events with Solace from applications that generate lots of granular events? What it solves 1. Reduce unnecessary process executions…
-
Solace fail-over test - affected consuming of event
Hi, While doing Solace fail-over test, once the test was initiated, the SolaceHealthIndicator Status change in following chronological order : DOWN -> RECONNECTING -> UP We didn't observed and pod restart. However, the consumer was in stale state, where no events were being consumed. Note that the event consumer health was…
