-
EDA Myths! What claims have you come across?
Howdy ya'll! EDA is one of the many topics I am passionate about and I am regularly involved with topics and conversations about it in the community. Just like any other domain, there are some claims and myths in EDA that people exchange every now and then. I wanted to start this conversation here to hear from you all:…
-
Solace spring cloud stream support
Couple of questions i have * Does solace has compress support for producer ? producer: compress: true * Does autoBindError Queue is supported only in consumer or producer ? * if i enable error-channel-enabled: true, is there a way to listen to all the error together in one channel, and i would be able to drop them back to…
-
using google.protobuf.Timestamp in c/c++
Hi, I use time_t for google.protobuf.Timestamp in implementation, but doesn't seem to me that it works out well. eg. i put time t t3 = 1621435475, is Wed May 19 10:44:35 2021, but the solace server return time t as, 140723368189072, is Tue Jan 7 03:57:52 4461316, which is garbage. Do you have any idea why? Thanks.
-
Access the Solace Admin from the Virtual Machine Host
Hello dear community, I'm new to solace in general and I would liked to get a support the following case. I have a centos 7 virtual machine running on My Windows Host, Inside the VM, I have Docker installed and a running solace container, The ports are correctly forwarded to the outside of the Docker and to the outside of…
-
Jms, Spring cloud stream
Can I read the message which was published by solace producer using spring cloud stream, i tried but i am receiving a byte message and getBody of Message interface throws exception. Even i tried separately as well but got java.lang.AbstractMethodError: Receiver class com.solacesystems.jms.message.SolBytesMessage does not…
-
Getting Connection object when using JMSListener
Hi, Is there any way to get the handle of Connection object when using @jmslistener? @Bean(name = "FeeBillConnectionFactory") public JmsListenerContainerFactory jmsListenerContainerFactory(ConnectionFactory cachingConnectionFactory){ DefaultJmsListenerContainerFactory jmsListenerContainerFactory = new…
-
Need to connect to two VPNs using Spring boot solace
We have requirement where we have to manually switch between active and DR vpn. so few questions 1. How to connect to multiple vpns? 2. 2. how to identify the vpn is down ? Thanks
-
Subscribing to a subset of the fields on a chatty topic
Hello Solace Community, I'm just starting out with Solace and I'm trying to figure out how topics work. Reading documentation I can see how to subscribe to topics and how to use wildcards but I don't see how to subscribe to a subset of a topic. I have a very chatty topic that sends out SDT maps and I'm only interested in a…
-
When i read message from solace queue using a consumer i get some issues while casting it
java.lang.ClassCastException: class com.solacesystems.jcsmp.impl.BytesMessageImpl cannot be cast to class com.solacesystems.jcsmp.TextMessage (com.solacesystems.jcsmp.impl.BytesMessageImpl and com.solacesystems.jcsmp.TextMessage are in unnamed module of loader 'app') What i get it is SolaceBytesMessage, cant not case to…
-
Solace message compression
How can i check if the message is compressed?? Q1. if i connect solace session with the compressed port , then all messages send out would be compressed ?? Q2. if i connect solace session with normal port (no compression), can i manually set the compression level in solace session property instead ?? So that all messages…
-
Spring Cloud Stream - Solace JMS Client Passwords configuration
Hi All, Let me share steps we use for us, 1. We have autoconfiguration for queues and topics, (using solace binders(Sink, Source, StreamBinders)) 2. We have solace auto configurations 3. Solace clients( random generated clients) connects to queues 4. I have to decrypt the password and inject the same password in runtime by…
-
Use exclusive queue as distributed lock?
I was wondering if I could use an exclusive queue as a rudimentary distributed "headship" mechanism. If there are multiple queue consumers that create a flow to the queue, my thought is that whoever is the active consumer would considered the head node, and if they shut down then headship would automatically be transferred…
-
Spring cloud stream -- jmsTempate
I am trying to read a message using jmsTemplate but not able to cast it, i need to read payload/body and then i have to drop that message using jmsTempate to another queue. class com.solacesystems.jms.message.SolBytesMessage cannot be cast to class javax.jms.Message
-
Spring Cloud Stream + Microservice Pub/Sub
Hello, I am creating a microservice through spring cloud stream. My idea is to have a publisher application send messages through a queue to the microservice, which will then process data, and send out the processed data to a consumer application through a queue. I am having an issue with understanding how to configure the…
-
@JmsListener with concurrency
Hello All, I am trying to use Spring API. I am trying to process multiple messages simultaneously and wanted the JMS listener to be running continuously so that I can process further steps while it is awaiting the message. I am getting below error when I add concurrency with JMSListener. 2021-05-21 16:26:57.922 WARN 164…
-
JMSToolBox: Not able to browse through all queues created on VPN
Hi Team, Need your help here. I'm trying to use JMSToolBox to browse and see the content of the messages on solace queues. have completed the setup and able to connect to solace VPN but the JMSToolBox is displaying only 100 queues. there are around 500+ queues created on Solace VPN and I'm not able to browse through all…
-
Meet error javax.naming.NamingException: Username must be specified when consume solace
Hi gurus, My scenario is capture Solace JMS message then deliver to oracle via OGG Application Adapter (jmsvam). throw below error message when start ogg extract process it's stranger what username should be specified? but i already setup java.naming.security.principal does my reference solace jars are correct? May 21,…
-
Spring cloud stream
In case when we siphon the message from an error queue we dont get from which queue it was thrown like rabbit does it by proving original queue name, also how to get all the headers i am using jmsTemplate or jndiTempated i see property to gather there is not separate method to just get all the headers, also there is method…
-
What are your takeaways from EDA Summit 2021?
Yesterday’s EDA Summit was a great success. I’m sure you enjoyed it as much as I did. My biggest takeaway from it is that EDA is not just a concept anymore. It is a real thing now across almost all the industries. I can see that growing popularity and momentum in Gartner’s Keith Cuttridge’s session about trends in EDA…
-
Queue Subscriber without Latch
Hi, I am trying to have QueueSubscriber without latch but to have QueueSubscriber continously running. Is there any sample code available? I am trying to create a message SubscribeFromQueue. If I have latch inside subscribeFromQueue it works but once control comes back to main method it does not return back. try {…
-
How would you explain EDA to your grandma?
The EDA Summit is on today and I just watched the Welcome Keynote. One of the things that I like about it is the question "How would you explain EDA to your grandma?" It's fun to see the experts and guests make their attempts. What would you say to your grandma? I'd like to hear your versions here. :)@rob @manish @Tamimi
-
Error when setting up Java Code
Hi, When I am setting up the BasicReplier and BasicRequestor code in STS, I am getting below error No "exception of type JCSMPException can be thrown; an exception type must be a subclass of Throwable" in design time. Am I missing anything or any jar file? I just coped the BasicReplier and BAsicRequestor code and I cannot…
-
First-ever EDA Summit on May 19, 2021! Can't wait more !!!!!!!!!!!
HI All, You might have received your registration credential for EDA Summit. I am really excited to attend such event organized by Solace . The EDA Summit virtual event platform is now open. Please sign in with your unique registration credentials below and take a few moments to get prepared for the event: Important: *…
-
Solace Developer Spotlight: Nagaraju Kshathriya (aka NaGG)
Hometown: Chittoor, Awesome place in Andhra Pradesh, India Born and brought up in: Chittoor, India Years of being a developer: 4 Primary programming language(s): Little bit Python but most of the time, I’m into integration platforms and currently exploring MuleSoft as a developer/architect. How did you start as a…
-
How to get queue name with the help of topic subscription
Hi Team, I have a case where i need to get the queue name with the help of topic subscription.I have only topic name which is bind to queue. How can we achieve with the help of SEMP API's Thanks in advance.
-
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!
-
Last chance to register for EDA Summit! Happening Wed, May 19th
EDA Summit is coming up next week and will feature a who's who of the EDA world, including folks from Slack, Google, Boomi, HP, SAP, FAA, IKEA, Accenture, Postman, Wipro, and more! Have you signed up for EDA Summit? If not, what are you waiting for! Even if the timezones don't work for you, register so you can watch the…
-
New Video: Guaranteed Consumer ACKs
After his previous video Solace Guaranteed Publisher: ACKs and NACKs, our Developer Advocate Aaron Lee just posted the 2nd part of the series. https://www.youtube.com/watch?v=K7_E7kzTHhk In this new video, he talks about the things to be expected and some best practices for consumer and processor applications using Solace…
-
Consuming from a topic
There seem to be 2 ways of consuming messages from a topic with the JCSMP client: 1. Add a topic subscription directly to your session, then create a message consumer 2. Create a topic & topic endpoint (non-durable in my case), then create a flow receiver to the topic Can anyone explain the difference between the 2…
-
Spring Cloud Stream- Consumer config, queue name included in topic subscription list
Hi We are using spring cloud stream to consume events from topics defined by publisher application. We have Organization wide agreed topic hierarchy taxonomy for all applications across the board and subscription ACL (default disallowed) is aligned only to that agreed taxonomy. In the binder property…