-
Solace PubSub+ Connector Consume "Selector" Feature
Hi I'm trying to use the solace "consume" operation and attempting to use the "selector" to only consume a subset of messages. When publishing a message I have passed in a userProperties: (refer to attachment publish.png) counter: 1 As per this link -…
-
Consuming messages a predefined solace queue using Spring Cloud Stream
Hello Solace Community, I'm brand new to solace product, but I set up a solace Kubernetes instance with a VPN relatively easy with the community documentation and publish to topics and subscribe from queues fairly quickly with the Python provided examples. (see guaranteed_publisher.py, guaranteed_subscriber.py) Now I'm…
-
Testing guaranteed queue based message delivery over flow in C
I have a C++ application using solace C API to read guaranteed message over a flow, with queue based message delivery. Currently I connect to broker to test my application, but I would like to add some local tests, that I can run on my machine to test the complete flow at my end. I need to have a message publisher, which…
-
solace_replyto header is failed to retrieve in spring cloud stream
Hi Team, We are getting the below error when get the solace_replyto header. Please help to check. Caused by: java.lang.IllegalArgumentException: Incorrect type specified for header 'scst_targetDestination'. Expected [class java.lang.String] but actual type is [class com.solacesystems.jcsmp.impl.TopicImpl]
-
Boomi Solace Connector: Send operation failed due to maximum size limit
Hi, I am using Boomi and Solace Connector. I am gtting information from Database and mapping to XML profile and trying to push xml to Solace queue (Send) operation. Just 2000 db records it was erroring as Error : [400] SEND's operation combined incoming documents exceed allowed size of [ 1048576 bytes ]. . Did we have any…
-
Boomi V2 Connector released 🎉
We have released our version 2 of the Boomi connector! Check out a tutorial on our codelab site here https://codelabs.solace.dev/codelabs/boomi-v2-getting-started. You can also check out other codelabs that uses our Boomi Solace connector by filtering on the 'Boomi' category. What's new? Some of the new features with this…
-
Trying to connect consumer to the pre-defined queue, getting error as Permission mismatch.
Hi, I am trying to connect pre-defined queue named GMMO.UCTRADE.DSLT01 it has ALL OTHER POERMISSIONS: No Access(0000) . When i try to consume frm the queue , application throws below error : org.springframework.cloud.stream.provisioning.ProvisioningException: Failed to provision durable queue GMMO.UCTRADE.DSLT01; nested…
-
In Spring cloud , i would like to print logs which will tell to which queue application is connected
Hi, I am working on spring-cloud-solace. In application i need logger to track which queue application is connected to. Could you pls help
-
How to solve :com.solacesystems.jcsmp.JCSMPTransportException: Unexpected error:Fatal reactor error
2019-12-24 07:20:46.556000+0000 [86052:Context_3_ReactorThread] INFO com.solacesystems.jcsmp.protocol.impl.TcpClientChannel: (Client name: gtosp-tibco/86052/#0bb60005/5jqZ4iMrCl Local addr: 10.0.0.8:57346 Remote addr: ...:55555) - handleException(): Channel Closed Event (smfclient 12) 2019-12-24 07:20:46.563000+0000…
-
spring cloud stream multi api version
The problem: A single spring cloud stream application, have to send out the same data via 2 major versions of the same api. spring: stream: bindings: myApiV1-out-0: destination: api/v1/the/topic myApiV2-out-0: destination: api/v2/the/topic Question: What is the most elegant solution for this problem? Idea / what i want to:…
-
Consume from Durable Topic Endpoint using JCSMP
I want to subscribe to a Durable Topic endpoint. I am able to subscribe to the direct topic. But my program is not working to when I try to subscribe from DTE. Program: final JCSMPProperties properties = new JCSMPProperties(); properties.setProperty(JCSMPProperties.HOST, host); // host:port…
-
Integrating Solace PubSub+ with Logstash
Logging is a crucial part of your applications, especially enterprise applications. If you're still writing logs to a database, you really need to read this :) This post shows how to use Solace as the pipeline to your ELK stack, replacing your slow and heavy JDBC insert operations with a JMS send operations. Let Solace be…
-
Issue subscribing durable queue to topic
Hello We are using Spring Cloud Stream solace binder to connect to Solace. We are facing an issue when durable queues subscribe to topic. Case 1: When the application is creating the queue we are not facing any issue. The durable queue gets subscribed to the topic and is able to consume message successfully. Case 2: When…
-
OPC-UA
Hi there Solace Community, My next device that will try to use has OPC-UA, but from what I read until now about this topic, the only way to connect to this to the broker will be through MQTT PubSub. Is there or do You know if it will in a future, a way to connect directly a device that uses the OPC-UA to the Solace Broker,…
-
Solace & Dapr
Has anyone integrated Solace with DAPR? (dapr.io) MQTT is supported, so should be possible : https://docs.dapr.io/reference/components-reference/supported-pubsub/ Interested to hear if anyone has tested it.
-
How to set ssl validate certificate to false in python
I am Implementing Solace pubsub solution in python and trying to disable ssl_validate_vertificate . It is working fine in Java but not how to set same in python I tried this way: "solace.messaging.ssl_validate_certificate":False"solace.messaging.ssl_validate_certificate_date":False But it's not working. getting error…
-
(403) - Publish ACL Denied
Team, I am using Solace JMS Spring Boot Starter for sending a message to a topic and getting the following error(403) - Publish ACL Denied solace.jms.host=tcps://hostname:30969solace.jms.msgVpn=integrationsolace.jms.clientUsername=usernamesolace.jms.clientPassword=passwordspring.main.allow-bean-definition-overriding=true…
-
Spring Boot JMS Retry Connect configuration
I am using SpringBoot Solace JMS AutoConfig and i would like to know how can we add connect retires and reconnect-retries to the JMSTemplate and JMSListener. We are using the Solace Java client Library and we can handle this configuration through the below properties . solace.java.connect-retries…
-
Solace Spring JMSListner
Team, I am new to the Solace and i am currently using in the Solace SpringBoot JMS. I have created a Queue and Published 500 Message to it. I want to implement a Multithreading behavior to my consumer which will consume the message parallelly and process instead of one by one. I have added the minimum concurrency as 5 and…
-
Consumer Application Server going down
We are seeing below error in JVM Heap Dump and our Consumer Application servers going down everytime: "Context_115_jms_1868_ConsumerDispatcher" #6387 daemon prio=5 os_prio=0 cpu=0.21ms elapsed=70319.77s tid=0x00007fda7031d800 nid=0x1e08 waiting on condition [0x00007fda26f16000] java.lang.Thread.State: WAITING (parking) at…
-
Tibco BusinessWorks 6.x integration with Solace
Hi, I learnt from the link (https://docs.solace.com/Developer-Tools/Integration-Guides/Solace-JMS-Integration-TIBCO-ActiveMatrix-BusinessWorks.pdf) that Solace can be integrated with Tibco BusinessWorks 5.x. But not able to find any materials on how to integrate Solace with Tibco BusinessWorks 6.x. Is there a way to…
-
Secure connection on Local Host
Hi, I am using the Solace Software as a Docker container. I am able to establish a default connection (localhost:55555) and compressed connection (localhost:55003) with the broker. For the secured connection, I enabled the port 55443 while running the container, but when I try to establish a secure connection it gives me…
-
Solace PubSub+ Authentication against Oracle IDAM
Hi, In my architecture the clients connect to event broker either via JMS or REST. These clients need to be authenticated via Oracle IDAM. I know that other messaging platforms such as TIBCO EMS provide JAAS module which can be configured to get authenticated against IAM servers. Does Solace provide such feature so that…
-
Solace-Kafka connectors ready for deployment in a distributed Kubernetes environment
Hello, my name is Rodrigo Félix and I'm a Computer Science and Software Engineering student that’s currently doing an internship in Link Consulting. My goal was to instantiate Solace-Kafka connectors in a distributed kubernetes environment. Since there wasn’t any guide of how to deploy them in kubernetes and no images…
-
Subscription concurrency to speed up data consumption
Hi, In solace I pre-configured a Non-exclusive queue and now trying to consume data in spring cloud steam app , by providing spring.cloud.stream.bindings.fn-name.consumer.concurrency=4 , In logs i can see it's trying to start four subscriber but all four are getting timed out. If we make this number as 1 or remove this…
-
BOOMI : Publish Events to PubSub+ with custom headers & Listen to events and get headers
I write this post to share how to do the following things in Boomi : * Publish a message to Solace with custom headers * Listen for message and get the headers, parsing the custom headers stored in "userProperties" header Boomi is an iPaaS solution (other well known iPaaS : TIBCO Cloud Integration, Mulesoft) You can read…
-
How to use Solace-Kafka-Connectors in a Kubernetes distributed environment
Hi, I'm trying to connect my solace broker, running in a kubernetes cluster on a cloud provider, with my kafka pods also running in kubernetes on another cloud provider. In order to do so (using the solace-kafka-connectors) do i need to create my own kafka image with the connectors already inside and configured? or is…
-
New Tutorial Available - Spring Cloud Streams
A new tutorial has been posted to the Solace Samples pages! Be sure to check it out. https://tutorials.solace.dev/spring/spring-cloud-stream/
-
Not getting data from Queue while consumed using Spring Boot ,But Solace end its showing data sent
I am facing while consume(""q-51685-stavi-pymt-rtgs-outward") the data from Solace queue not getting any data , but in Solace its showing data consumed , its happening in System integration Testing. While publishing we are able to publish the data in 2 different topics to Solace. Already 2 days gone our solace team also…
-
Logstash input and output plugins for Solace
Hi everyone! Just a quick note to say that I've started writing some dedicated/native plugins for Logstash using JCSMP, both an input plugin (reads messages off Solace and injects into Logstash), and output plugin (takes Logstash events and publishes as Solace messages). Logstash has been around forever, and integrates…
