-
Develop spring cloud stream code to manually send acknowledgement post message consumption
Develop spring cloud stream code to manually send acknowledgement post message consumption "pick up message from Solace broker --> do some business logic --> if business logic successful --> ack the message so that it gets deleted from queue (if not, don't ack)"
-
Spring Cloud Stream Binder - Sending Persistent Messages with StreamBridge
Good morning everyone, using the spring-cloud-stream-binder-solace sending Messages via the StreamBridge, is there a possibility to send persistent Messages? "show client ... stats" only reports non-persistent messages beeing sent by the application. Thank you guys for your support and have a great day! Timo
-
Solace Channel Interceptors
I am trying to implement common functionality in my methods marked with @StreamListener. I tried registering a GlobalChannelInterceptor but found that the postReceive/afterReceive methods are not triggered when a message is received. Only the preSend/postSend/afterSendCompletion callbacks are executed when sending a…
-
A Bootiful Podcast - Spring Cloud Stream Lead Oleg Zhurakousky
If you're interested in hearing about the latest with Spring Cloud Stream & Spring Cloud Function be sure to checkout the latest podcast from Josh Long. In this episode he talks to Oleg Zhurakousky, the lead of the Spring Cloud Stream and Spring Cloud Function project. While you give it a listen keep in mind that the…
-
Spring Cloud Stream msgTtl on producer/supplier binding
Hi there I tried this: spring.cloud.stream.bindings.bookSupplierV1-out-0.destination=v1/bookJsonspring.cloud.stream.bindings.bookSupplierV1-out-0.binder=solace1 This works. But when I do this in addition: spring.cloud.stream.solace.bindings.bookSupplierV1-out-0.producer.msgTtl=23000 no message is sent to the destination.…
-
Spring Cloud Stream Consumer Binding to a DMQ
Hi there Is there a way to bind a Spring Cloud Stream consumer to a DMQ? I tried things like that: failedMessage-in-0: destination: DEAD_MSG_QUEUE contentType: "application/text" But a consumer always binds to a queue which has a subsciption to the topic (in destination), right? So this doesn't work. Is there a solution…
-
Solace Spring Cloud Stream and DMQ Binding
Hi there We configured an application like this: spring: cloud: stream: solace: default: prefix: myapp/${application.stage}/ consumer: prefix: ${spring.cloud.stream.solace.default.prefix} autoBindDmq: true A DMQ is created for each of our queues, and in case of application errors, the DMQ is written to. So far so good. But…
-
Solace Spring cloud stream and opentracing
Hi there I am trying to introduce tracing in my project, for that I defined the following dependency: io.opentracing.contrib opentracing-spring-jaeger-cloud-starter 3.1.2 There are starters for kafka, rabbitmq... But unfortunately none for Solace. Now I want to implement it on my own. What would be the best hook for a…
-
Reactive approach micro-services for API integration (direct using WebClient), without MessageBroker
I am implementing microservices however not planning to have any message broker. services will talk to each other with WebClient/web flux. Is there any risk of going production like this? what are the drawbacks like failover/replay?
-
[Recording Available] Event-Driven Made Simple w/ Spring Cloud Stream, AsyncAPI, and Event Portal
Are you passionate about building modern, real-time applications? Is your organization adopting an event-driven architecture (EDA) to compete in our event-driven world? Build and expand your developer toolbox by learning how to create event-driven microservices using Spring Cloud Stream, AsyncAPI, and PubSub+ Event Portal.…
-
Java Client: How to use lookup data
Hi together, what is the best way in Solace to use non static structured lookup data in a Java Client, without the use of an external system ? For example, I am getting an Id from a source system and now I want to enrich my data based on the lookup and send it back to Solace.
-
Java API: Working with the Topic String
Hello together, we are currently starting with Solace development and want to build different use cases. First we created a topic hierarchy, where for example a source systems stores different data parts in the topic string like: ${sourceSystem}/${stage}/${businessObject}/${objectId} Now we want to extract different parts…
-
@PollableBean for Reactive Suppliers in Spring Cloud Stream
Supplier beans, or functions that only publish messages in Spring Cloud Stream, are a bit special in that they aren't triggered by the receiving of events like Function or Consumer beans. This means that you often need a way to trigger them to be executed periodically. For imperative functions the framework by default…
-
New Spring Cloud Stream Dynamic Topic Publish Sample!
Heads up for everyone using Spring Cloud Stream I created a new sample that shows how to publish to dynamic topics! I'll be creating a tutorial or blog at some point to add more explanation, but for now you can check out the code on github: * DynamicDestinationProcessor.java * application.yml Note that this is already…
-
Livestream Recording Available: Developing Event-Driven Microservices using Spring Cloud Stream
👉Recording Now Available on YouTube What Join us for this Live Coding session on Spring Cloud Stream! Solace Developer Advocate @marc will be joined by Oleg Zhurakousky from the Spring Engineering Team where he leads the Spring Cloud Stream and Spring Cloud Function projects at VMware. Spring Cloud Stream is a framework…
-
Checking payload with Json schema
Hi ! In the Event Portal I can associate a Json schema for checking the payload of an incoming event. I'm wondering how to do this when using Spring cloud streams messaging with the Solace binder in a Docker environment. Is there an example available ? BR Gerhard
-
Solace SCSt Binder now added by start.spring.io!
Hey Solace developers, I know a bunch of you are using Spring Boot to develop Microservices. I wanted to give you all a heads up that start.spring.io now automatically adds the Solace Spring Cloud Stream Starter for you when you choose Solace PubSub+ and Cloud Stream dependencies. Go check it out! Learn more about How…
-
Spring Cloud Stream and Solace Bindings
I am trying to use Spring Cloud Stream bindings with spring-cloud-starter-stream-solace but encountering issues with the set up / configuration. I have created a durable queue Q.MYQUEUE which is mapped to a Topic /mytopic/topic1. It seems that the SolaceQueueProvisioner tries to create a new queue and gets a "Router does…
