-
How to set Message TTL when using Spring Cloud Stream Binder Solace
Hi there, I am wondering whether it is possible to set a Message's TTL if you are on the Spring Cloud Stream layer. I wrote a message listener using Spring Cloud Stream, and at most I get access to a GenericMessage from the Spring Cloud Stream framework - but that class does not offer any methods to set a TTL. Is there any…
-
How to implement async request/response with Boomi?
I'm interested in how to implement async request/response using correlation ID's and using the Boomi connector? See https://solace.com/samples/solace-samples-c/request-reply/
-
Dynamically chaging the concurrency value for spring cloud stream
Hi , Is there a way to dynamically changing this "concurrency" value without application down? I am using solace and spring cloud stream for listining message . There is a need to reduce/increase number of consumer on demand to manage application throughput.
-
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
-
Graylog Content Pack
To ease of support, I am wondering any Graylog content pack is available for Solace
-
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…
-
Boomi Solace listener: com.solacesystems.jcsmp.PropertyMismatchException: Access Type mismatch
Hi, We have successfully tested Boomi and Solace Cloud. We're now testing Boomi with a Solace broker running on an EC2 AWS instance. We basically changed the connection settings on the Boomi side. * The Boomi connection connectivity test is successful * We're able to send messages from Boomi to Solace * The Boomi listener…
-
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…
-
Quarkus native and solace client issue
Hello, I'm developing an application with Quarkus and Solace. Quarkus allows you to compile java to a native application. Compilation is fine, but at runtime I have this issue: 2020-11-13 12:49:18,462 ERROR [io.qua.run.Application] (main) Failed to start application (with profile dev): java.io.FileNotFoundException:…
-
Approaches to consume the data from solace queues on need basis.
Hi Team, Could anyone share the solution approach for consuming the data from solace queues whenever it is needed. Lets says every 12 hrs or 24 hrs, the time frame might change as per the need. I am more looking in to pull mechanism, unlike RDP( Push). We have also MuleSoft in the approach, any feasible solutions is much…
-
Simple pub/sub inside the connector (MedTech Dev Kit) Python
I wonder how I can replace the echo device with my python code inside MedTech Dev Kit: how I can replace my code with an echo device without a BLE device
-
solace JNDI Connection error
Hi, Im trying to fetch a feed of data via a VPN connection. The VPN connection is successful , however the jumpstart kit based on solace when runs throws an error ( screenshot attached). Hence we are not able to receive the data feed.
-
Pubsub+ with serverless cloud components (esp azure) in the data flow: which tech? How?
We are using pubsub+ in an event-carried-state-transfer pattern to integrate data between a number of enterprise applications. As of right now, the publishers can make use of a nuget package authored by me to simplify connectivity, which they can incorporate into their application if it can raise events natively. For…
-
Unable to reuse sessions in Springboot while producing persistent messages to SOLACE SMF
We have been trying to create a Bean that creates the JCSMPSession. In the class we are using the session object do session.connect(). We are using asynchronous mode to publish the data. It seems the code is not thread safe in this case and we are not able to receive the acknowledgement. Can some one share a sample…
-
REST Messaging
Hi Folks, Can we push messages from queue/topic to REST Endpoint? I'm pushing my application logs to Topic and now want to publish those logs to another log management system over REST endpoint.
-
Solace broker and ELK integration
I am not able to apply solace gork pattern(Solace event log) on logstash config file if [type] == "syslog" { grok { match => { "message" => "%{SOLACE_EVENT_LOG}" } } syslog_pri {} }
-
MuleSoft & Solace Integration
Hello, Royal Cyber has experience in integrating the solace with MuleSoft. You can find more information from our Blog. https://rb.gy/9o2pvs. We have an upcoming free webinar. Join us using this link: https://rb.gy/peutle
-
Solace PubSub+ and PHP
Friends, If you are looking to emit/consume Solace PubSub+ events from PHP, please checkout the following links. You will find wrapper/connector ideas, reference implementation and sample Publisher/Subscribe PHP code. * Solace PHP MQTT Samples: This github repo has PHP samples to access Solace with Mosquitto MQTT API using…
-
Connector Hub is Live!
Just a heads up that the PubSub+ Connector Hub is live! The Connector Hub is a great resource to figure out how to integrate Solace with other technologies. You can search for the technology you want to integrate with, choose the integration option you're interested in, and see more information about that option such as…
-
How to use pre-defined queue name in Solace spring cloud stream
When I add consumer group in configuration, the queue name is always generated with destination name and group name. But our queue name is predefined. We do not need to append the group name. Please provide a way to use specific queue name without any group name. The code for generation of queue name is found below:…
-
Solace with mulesoft integration
Hi All, Does anyone have experience in integrating the solace with mulesoft and sending the messages to solace message brokers can you help me with answering the below queries? What are connection details requires to connect to solace from mulesoft. How can you manage the message queues and topic configuration via mulesoft…
-
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…
-
Solace + protobuf in Android application
Hi everyone! I'm absolutely new in Solace, so I would you to help me: my app has to communicate with Solace using protobuf models. Can you help, what to start with?
-
Attach protobuf message to solClient_msg_createBinaryAttachmentStream
Hi everyone! Would you be so kind to tell me, how to attach GPBMessage to Solace message? I'm using solClient_msg_createBinaryAttachmentStream (C/iOS API) function to send a message, so my question is how to serialize it to needed type?
-
@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…
-
How to connect to Solace broker using truststore credentials using Python
No formatter is installed for the format not-found
-
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…
-
Solace + protobuf in iOS application
Hi everyone! I'm absolutely new in Solace, so I would you to help me: my app has to communicate with Solace using protobuf models. Can you help, what to start with?
-
Writing to Solace with Spark
i have a spark dataframe and i want to write it to solace i.e. i want to send the rows of dataframe as events to solace(publishing basically) in a distributed way . like spark to kafka.
