-
what changes are required on Solace VPN to connect to Kafka Connector.
From a solace admins end what are changes i need to make to my VPN, so the Kafka connectors can connect easily.
-
How to keep the queue consumer flow open?
Hi everyone, I have actually a bunch of questions, hopefully it's okay to ask here :) How to keep the queue consumer flow open? Example Consumer provided here (https://tutorials.solace.dev/dotnet/persistence-with-queues/) gets messages only currently on the queue and closes immediately after that. How to keep the flow open…
-
PDB for libsolclient.dll version 7.19.0.30 for x64 windows
Hi All Is there a download link for the libsolclient.pdb for version 7.19.0.30 for x64 windows. I am building against version 7.14.0.8. However during runtime the program is picking up 7.19.0.30. Is that a problem ? I see some unexpected behaviour. and the pdb will give a slightly better idea. the program actually starts…
-
.NET - Enforcing Queue to Respect Message Priority
Hello everyone, I am trying to implement a simple PoC solution to check whether Solace PubSub+ will be appropriate for my company. All went fine to the moment I wanted to use priority messaging. I would like to 1. create a queue from .NET 2. assign Priority to messages 3. enforce the queue to respect message priority…
-
Google Storage Connector Speed Issue
Hello, There seems to be a problem with delivering message to a google cloud storage bucket. Solace can't deliver the messages in the same speed as they come in. It falls back to 1 per 1-3 seconds. Why would this happen and why would it need to redeliver? I've checked it with another storage account and there it has no…
-
Solace JMS Channel closing on it's own when running on a Kubernetes cluster (Spring Boot Autoconfig)
Log snippet: {"com.solacesystems.jcsmp.protocol.impl.TcpClientChannel","label": "Client-109: Connected to host 'orig=host:55555, scheme=tcp://, host=host, port=55555' (smfclient 109)"} {"com.solacesystems.jcsmp.protocol.impl.TcpClientChannel","label":"Client-109: Channel Closed (smfclient 109)"} It basically loops like…
-
How to export queue configuration with SEMP API
I'm building a process to integrate Solace with CI/CD, where we need to export the queues from Dev to UAT as part of the deployment process. Basically developer create the queues in DEV using UI and then its moved to upper envs with automation. I could not find a way to export specific queues configurations using SEMP,…
-
Consume from multiple queues in Spring Cloud Stream
Yesterday I got asked by a developer how she could have multiple functions in her Spring Cloud Stream microservice each consume from its' own queue. Luckily the framework makes this relatively simple to accomplish, but the devil is in the details as your configuration must match your code so I figured I'd share the steps…
-
Is it possible to have a workflow in Solace-IBM MQ connector between a Solace Queue and IBM MQ Queue
Is it possible to have a workflow in Solace-IBM MQ connector between a Solace Queue and IBM MQ Queue. In the user guide for the latest available version, there are two workflows defined 1. Solace Queue to IBM MQ Topic and 2. IBM MQ to Solace Topic. There is nothing given for Solace Queue to IBM MQ Queue. Any pointers,…
-
Selector on Browser, how to do?
Hi all, I try to filter a specific message of a queue I want to delete (I have the message ID from a call before). How to set the selector? this is my code and I tried a lot of variations on the selector for example mi = '485' mi = 485 JMSMessageID = 485 JMSMessageID = '485' etc. when I browse via the console and select a…
-
OAuth 2.0 authentication for solace.cloud REST endpoints?
Hi, Is it possible to use OAuth 2.0 authentication for solace.cloud REST endpoints (instead of the default basic auth)?
-
If you are familiar with the PubSub+ Event Broker Operator, I have some questions!
Is it possible you use the PubSub+ Event Broker Operator like the PubSub+ platform. As in, can I use the operator to create a cluster/service that I can use to send and receive events? Can I implement something like this article with the operator…
-
Python TLS Connection Reset By Peer
I'm a bit at loss here, Solace shows everything is ready to accept TLS connections but it refuses with the following error on the client side: solace.messaging.errors.pubsubplus_client_error.PubSubPlusCoreClientError: {'caller_description': 'do_connect', 'return_code': 'Not ready', 'sub_code':…
-
Pull messages from Azure service bus using Solace PubSub+ Cloud
Hi, Is it possible to connect Solace Pubsub+ Cloud to an Azure service Bus by pulling messages from a topic or queue ? So something like a Azure-Solace mesh? I know you can push messages to AWS ansd Azure components using RDP. But does Solace support pull? Background: We have a use case where we must transport messages…
-
Error sending message - Direct buffer memory
Hello We are using ( Solace + Spring JMS + Spring Boot + Pivotal Cloud Foundry ) to read a message from a queue and post to Topic. We are facing issue when reading 1 message of size - 7MB and posting to a topic. Smaller message size are working fine. Below error when sending to topic Error Message : javax.jms.JMSException:…
-
Let Solace act like it is Kafka to Kafka Consumers
I would like to connect apache Druid to Solace. However, it seems Druid doesn't support any of the connection types that Solace offers: One of the solutions would be if Solace offered Kafka consumers the possibility to directly connect to Solace, where Solace acts like it is kafka to them. Is this something that's a)…
-
JMeter Config to publish or subscribe via JMS Producer or Receiver
We currently would like to use JMeter which comes along with JMS Producer and Receiver but i can't get it working. Can anyone in Solace instruct where to place the VPN ? In code samples: #85972: JAVA API (solace.messaging) Library does not support SenderTimestamp i see that one way is to use the VPN behind user: user@vpn…
-
Solace PubSub+ broker / Informatica Cloud Integration over AMQP
Hi community members I created this integration to assist one of our customers with their use case to integrate to Informatica cloud to a Solace PubSub+ broker over the protocol AMQP. Overview: The steps are briefly as follows: Setup SDKPerf-jmsamq on your local computer. Setup a cloud Solace PubSub+ broker with a…
-
Azure datalake connector gen2
Hi, I created a Azure datalake gen2 connecter in solace using oauth 2 credentials but it is not wokring. I see that configuration completed successfully and all the assets (connector/RDP , Rest consumer, Queue and queue bindings) were created successfully. When I tried to test it, I did not see any transaction. Can you…
-
How to use Oauth Using Solace PubSub+ Connector in Mulesoft
We have a requirement where we want to use OAuth using Solace PubSub+ connector but I don't see any option to use the same in the connector configuration. Any leads would be appreciated.
-
Spring cloud stream Solace binder prevents application from running when Solace is down
Hello everyone, I am currently working on an application that consumes messages from Solace and serves users with HTTP endpoints. However, when Solace is down, the Solace binder prevents the application from running until Solace is reachable again. This behavior is problematic for our business as we want to continue…
-
Spring Cloud Stream Solace - Manual Acknowledgement
The batch mode is working fine as i am able to receive the msgs as batch and publish as batch. Now, i am trying to manually acknowledge the messages. If no exception, update the database with success and then accept the message. Else, update the DB with error and then requeue the message. Function<Message<List<?>>,…
-
Garanteed Subscriber problem: "Emitter rejects listener for no-name event: undefined"
Hello everybody, I hope I am posting this on the correct Category, correct me otherwise. I am trying to subscribe a Solace Queue in order to get it's messages and redirect them to a specific endpoint which will later process it's information. For that, i've made a NODE JS service which uses the GaranteedSubscriber example.…
-
How to connect to pre-provisioned queue in solace using spring cloud stream ?
I am using @StreamListner, created input binding of type SubscribableChannel & trying to connect to a pre-provisioned queue and used similar configurations as suggested in previous comment but i am not able to bind consumer with queue . Getting error - "EL1008E: Property or field 'isAnonymous' cannot be found on object of…
-
How to use/ enable oAuth2 in spring cloud stream to connect to Solace broker ?
I have implemented spring cloud solace binder to consume messages from Solace Queue. I am using Azure OAuth and registered the app as well as enabled OAuth on the solace broker. I am having hard time finding Oauth properties to connect to solace binder. Referred to various dev tutorials and could only find below properties…
-
In Spring cloud , i would like to read data from pre-define queue.
Currently spring cloud app will create the queue "scst/an/some randome-id/plain/myConsumer-in-0" at server startup (some thing similar), Since i already have a queue and queue has some persistence message so how to command spring cloud to use existing queue for subscriptions.
-
Spring cloud Stream Solace Unit Test
Solace Spring Cloud BOM 2.4.0 Solace Spring Cloud Stream Starter 3.4.0 <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-stream</artifactId> <type>test-jar</type> <scope>test</scope> <classifier>test-binder</classifier> </dependency> <!--…
-
Not able to connect the solace container with testcontainers module in java
I am trying to connect the solace container with java testcontainer 1.17.6 module but not able to connect everytime. I am getting the below error: Caused by: org.testcontainers.containers.ContainerLaunchException: Container startup failed at org.testcontainers.containers.GenericContainer.doStart(GenericContainer.java:349)…
-
Configuring Solace w/ testcontainers
Hi I'm trying to configure my Solace that runs on testcontainers and Springboot JMS. The container starts up just fine, but the container is not setup the way I need it. I need it to have some queues and I'm having a hard time finding a way to get it running. I tried to create one with testcontainers equivalent to docker…
-
Debezium Connector
Hi, we are currently consumer of Solace pubsub + in our organisation. I wanted to check if a version of https://solace.com/connectors/debezium-cdc-connector/ is available for us to use ?