-
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…
-
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,…
-
JMS Transaction COMMIT error
Hi Team, I have seen this error in logs. Can someone explains me when this error occurs and what happens to messages? javax.jms.JMSException: Error committing - internal error (Operation COMMIT disallowed in state COMMITTING.) Caused by: com.solacesystems.jcsmp.InvalidOperationException: Operation COMMIT disallowed in…
-
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…
-
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.
-
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…
-
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…
-
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…
-
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…
-
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…
-
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…
-
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
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…
-
MQTT 5.0 Support 🎉
PubSub+ Early Access Broker now supports MQTT v5.0! With this new support, the broker will automatically determine whether the client is speaking MQTT v3.1 or MQTT v5.0. Some of the new features you will be able to have access to with this support is: * Assigned Client ID * Determine content type so that message consumers…
-
@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…
-
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 {…
-
get only first message
Hi, I want to receive only the first message with property in a Queue. How to get this? Will this utility will help ? ./sdkperf_jms.sh Or any other choice ? Saw this article..Any hint - on how to re-write to receive only first message? https://tutorials.solace.dev/jcsmp/topic-to-queue-mapping/ These messages are now on…
-
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
-
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: *…
-
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.
-
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…
-
403: Subscription ACL Denied - Queue 'scst/wk/txGroup/plain/txError' - Topic 'txError'
Config - application.yml spring: cloud: stream: default: group: txGroup contentType: application/json consumer: concurrency: 2 maxAttempts: 1 bindings: output: consumer: group: txGroup provisionDurableQueue: true autoBindErrorQueue: true errorQueueNameOverride: txError durableSubscription: true republishToDlq: true…
-
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…
-
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…
-
Updating solace Queue Object (username ) when Azure Key vault credentials are updated
The use case is to update the Solace Queue Object when the credentials in Azure key vault is updated/deleted/created.
-
Solace spring cloud stream support
Currently the project is making use of rabbit mq and message channels not functions i want to replace the rabbit mq with solace so what are the changes specific to solace. Information carrying in message header Re-processing from DLQ in SOLACE feasibility and approach for duplicate handling parallelism limits on Kafka vs…
-
Setting multiple factories to connect to solace in JMS
I want to establish multiple factory connections in the program at the same time, but I find that after establishing the connection, JMS will not receive the information sent by solace. Here is the code for establishing the connection. Please forgive me for the help of the solution @Value("${solace.ssl.host}") private…
