-
View topic subsciptions in Solace Admin UI
Hello We are using Spring Cloud Stream to consume and publish messages using solace binder. From the logs we can see the message - "Subscribing Queue xxxx to topic yyy" at application startup. However in Solace admin UI, we can't see any subscriptions under the topic. Could you please help where we can view the topic…
-
Gettting JCSMPTransportException in AWS Solace HA environments
I'm getting this error below when HA configured Solace instances on AWS javax.jms.JMSException: Error sending message - transport error ((JCSMPTransportException) Error receiving data from underlying connection.) at java.base/jdk.internal.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method) at…
-
Beta version of PubSub+ Connector for IBM MQ is now available!
Solace has just released a beta version of the new PubSub+ Connector for IBM MQ. This connector enables bridging of PubSub+ events with MQ Queue Managers. It supports a 2-way flow of data with PubSub+ -> MQ or MQ -> PubSub+ and you can have up to 10 of these "workflows" in each connector instance. If you need more than 10,…
-
Having issues accessing SWIFT subscription using Solace/Kafka
Hey team, I'm trying to ingest data from swim.ffa.gov using Solace/Kafka and I'm having issues authenticating: "com.solacesystems.jcsmp.JCSMPErrorResponseException: 403: Subscription ACL Denied - Topic 'solacetest' [Subcode:27]" I'm using the following version: solace_version: 2.3.0 kafka_version: 2.3.0 SWIFT Subscription…
-
Mulesoft Connector Session Recovery issue in Auto Ack mode
Hi all, A strange behavior was observed while using the Solace mulesoft connector. Guaranteed listener connector throws 'session recovery ack timeout' error when the ack mode is selected as "AUTOMATIC_ON_FLOW_COMPLETTION" and the flow executes successfully. The message is also successfully removed from the broker…
-
Infinite Loop Message Consumer
While using solace jcsmp the message consumer reiceving infinity times. Can I stop consumer and listen again for the next message Thank you
-
Solace DMQ (Dead message queue) best practices
Hi All, I am new to solace and recently we implemented an Azure connector to receive message from a solace queue to azure function. I wondering if there are any docos around handling dead letter messages in instance where azure function is down or there is a fault in processing etc. We have a DMQ ready that receives any…
-
How to turn on keepalive for kafka connector
HI all, we are using both pubsubplus source and sink kafka connectors: https://github.com/SolaceProducts/pubsubplus-connector-kafka-source However, we hit the issue that connection drop from time to time and our VPN admin suggest that our connection don't have keepalive enabled, he send me this page for the keep alive…
-
Client/Manual acknowledgement
Hi @marc I am tring to do Client/Manual acknowledgement using spring cloud. First I want to know what configuration I have to do for producer end bcz I did the configuration on consumer side and its getting failed as shown below logs. I have attached java code and yaml file as well please suggest. cid------>: null…
-
[Video] Introducing Solace PubSub+ Connectors
Introducing new connectors built using the Spring Cloud Stream Applications Framework. Faster and more on-ramps and off-ramps to the Solace Event Mesh. Watch the short video clip
-
Logstash using spring cloud
Hi Team, I have pub/sub model with dynamic routing, I have to integrate a different tool to grap the logs for event specific. How I can implement it using spring cloud like ELK or something like.. Please suggest.
-
download JMS API on ec2 instance
Hi Team, How to download JMS API on ec2 instance. I have follow https://solace.com/blog/integrating-solace-with-logstash/ example for the same way I tried to download the JMS API. But when I am trying to unzip it getting below message. please suggest. unzip soljsm.zip Archive: soljsm.zip End-of-central-directory signature…
-
Is there any connector available for Google PubSub ?
I want to consume messages from Google Pubsub topics. I have signed up for the 60-day trial version on cloud. But it shows the connector only for Google Cloud Functions. Is it because of the trial version or there is no connector available for Google PubSub ?
-
Solace’s PubSub+ Click-to-Connect Wizard for Google Cloud Run
In case you missed it. In release 10.0.0 we made available a Google Cloud Run Connector Wizard providing an easy way to take advantage of Google serverless computing in your EDA. This is great for those deploying GCP containerized apps for their Solace Event Mesh. Check out the details. -…
-
Python API limits message size to 0.176MB while Solace configuration has 10MB limit
Hello all, I am trying to use the Python API from the official repo (https://github.com/SolaceSamples/solace-samples-python/blob/master/patterns/guaranteed_publisher.py) to publish some messages of size 3-5 MB to a Solace queue, but all the messages under 0.176 MB work and the ones above do not work. I am trying strings…
-
ELK / Logstash performance testing
Hi all, Not really (specifically) a Solace thing, but wondering if anyone out there has done any performance testing with Logstash, using either the JMS plugins or other (MQTT Beats?). I'm looking for any ballpark ideas on throughput, performance of the Logstash VM, etc. And if you've done any load testing, how did you…
-
Certification exception- No subject alternative DNS name matching solace found
i have A service running on AWS ECS cluster that connects to Solace broker instance, it’s been working for last few years but suddenly from past few days it’s giving error like “ Client-1: Connection attempt to host ‘solace’ ConnectException com.solace systems.jcsmp.JCSMPTransportException: CertificateException - No…
-
RDP consumer failed with Local SSL handshake failed: certificate chain too long
Hi , We were trying to configure an RDP but encountered this error "Local SSL handshake failed: Server certificate verification failed: certificate chain too long" The backend cert chain length is 5. Is it supported 9.12 version on cloud and if so are we missing some configuration. Regards, Rajesh
-
How to integration test Solace with Spring Boot AutoConfig / JmsListener
Hello the project I'm working on needs me to integrate a receiver for Solace PubSub+ Messages with Spring Boot. The following snippet resembles my current implementation. The controller receives a message, forwards it to my usecase which extracts some headers and the payload and creates a MyMessage POJO which in turn is…
-
jmsListener selector mechanism for new solace bee's :)
while consuming solace messages with selector functionality from message header property, do not include any special characters in header key.. if in case if you are adding key with special character you may able to successfully send messages but while retrieving from queue/topic using jmsListener you may end-up with…
-
Client Ack using Apache Beam
Hi - I am using Apache Beam (2.30) with Solace connector. I receive messages from Solace, process it, save it and then wish to ack to Solace once I am done with processing. I explicitly sets the status of my POJO to true once saved. So for such successfully processed messages, I wish to ack. However, I am facing issues as…
-
Getting ClassCastException when consumer consumes userdefined object from solace.
I have published message to the queue as "MessageContent". When i trying to pull messages from queue getting Caused by: java.lang.ClassCastException: [B cannot be cast to solace.test.consumer.entity.MessageContent] @Bean public Function<Message, Message> functionUsingTargetDestHeader() { return input -> { String…
-
How to gracefully stop a consumer ?
looking for way to stop and resume a consumer with out losing the messages in the queue.
-
Library to Unsubscribe Topic from Queue
Hi Community, I am exploring Solace and its Use Cases. Using Solace Java API Library we can create a Queue and subscribe a Topic to the Queue. Using SEMP Java Client Library we can Create and Delete a Queue. Using SEMP REST API we can create and delete Queue , subscribe a Topic to Queue and can also unsubscribe a Topic…
-
Sample on Solace with Spring Cloud Bus
Hi everyone, I recently created a simple sample that shows the use of Spring Cloud Bus (a lightweight enterprise message bus) with Solace PubSub+. I was asked to share it here, in case some of you might find it helpful. You can find the sample here. Let me know what you think - unless you hate it... ;) Cheers!
-
Prometheus vs Grafana Agent for Grafana dashboard
Hi Team, Grafana is getting popular and many users prefer this for new monitoring solution. I am planning to create a Grafana dashboard for Solace monitoring but confused hot to feed the metrics from solace. Based on my initial review Option 1: Use Prometheus exporter tool to feed metrics into Prometheus data source and…
-
Integrating the Solace Kafka Sink Connector with Confluent Schema Registry
Avro is a common message format used for Kafka records. Large Kafka implementations leveraging Avro often use the Confluent Schema Registry to ensure uniform record schemas across publishers and subscribers. When using the Solace PubSub+ Kafka Connectors to publish Kafka records as Solace PubSub+ events, it may be…
-
Dynamically setting selectors in the Boomi Solace Connector
There are alot of use-cases that require setting the selector dynamically. Say for example you have your Solace shape bound to a Solace queue using Solace GET and interested in a subset of messages that you can only have access to via matching selectors. You can use selectors and set them dynamically in other shapes. To do…
-
Good reference on Solace PubSub+ Connector - Mule 4 demonstrating Mulesoft-Solace integration
Came across this on YouTube, a good reference. Check it out...
-
AMQP client from AWS lambda that works with Solace
Hi, we would like to publish to Solace topic from AWS lambda ( written in java). Is there any java AMQP client library that we can use to do that ?
