-
spring cloud stream
cloud: stream: bindings: inbound: destination: TestQueue group: perf concurrency: 2 I get 403 Permission Not allowed whenever i add a group name what is causing issue ? TcpClientChannel : Error Response (403) - Permission Not Allowed - Queue
-
CloudEvents reference
Do we have any API specification or reference to enable CloudEvents part of webhooks?
-
Looking for ttl setup on each message in spring cloud stream
i am able to set ttl on queue persistence message , using solace cloud broker GUI, but this settings is applied on each message with uniform value, is there any way keep this value in application.yaml or properties file and during message published time it will be applied for each messages. In solace doc it's says you can…
-
Android. Request interrupted error
Is there any how meet "Request interrupted" error? my you tell what was your reason to get it? i have one request that constantly throws this error on android 7.0 and 7.1 Http logs says, that i call disconnect and send it information to server. and server received it. but i "send disconnect despite on i dont do it. and…
-
c-Api solClient_flow_sendAck & solClient_msg_BinaryAttachmentPtr
Hi , Apologies this is less of a discussion and more of a question. via the c-api, is it valid to access the pointer obtained in the call to solClient_msg_BinaryAttachmentPtr, after calling solClient_flow_sendAck ( for the msgId for which the binaryAttachmentPtr was called) i.e will the sendAck invalidate the pointer. Many…
-
Spring Cloud Stream Microservice Deserialize Messages
Hello, I have set up a Spring Cloud Stream microservice with the solace configuration. This microservice has been able to take in payloads of type string or java object, but I am now receiving SpB (protobuf) messages through solace. My goal is to deserialize these messages to JSON or POJO to be able to actually work with…
-
Code sample to push data from solace to GCS bucket on GCP
Code sample to push data from solace to GCS bucket on GCP. Also does it support Outh 2.0 for authentication
-
Do we have dataflow batch connector for solace
Do we have dataflow batch connector for solace on GCP which can be scheduled .
-
PubSub+ connection with NATS
Hello I need to get messages from a NATS (nats.io) plateform and publish them into PubSub+ where all our systems are connected I tried to find on nats.io a connector to PubSub+ (https://nats.io/download/#connectors-and-utilities) with no success. I tried to dig the forum with no success either. Is there already a connector…
-
Solace PubSub+ Connector for Mulesoft(Integration)
Hi Everyone, A month back, I have received this link from @Tamimi about Integrating PubSub + with MuleSoft Solace Connector. The Solace connector for MuleSoft is still not publicly available in MuleSoft Anypoint Exchange. It is available as an open source project in Solace Github repository. Once the Solace connector will…
-
Solace Dynamic routing
Is dynamic routing is same as dynamic destination binding Dynamic routing as per rabbit all producer published to same queue, configured on routingKeyExpression for producer and consumer listener receives it based on bindingRoutingKey. does this can be accomplished using stream bridge or BinderAwareChannelResolver??
-
Router does not support guaranteed subscriber flows
Hi SolaceDevs, We are facing below error while consuming the messages from the queue. Seems we will need to enable the Guaranteed message on message vpn and client-profile level but how can we enable on PubSub+ Cloud. Thanks, NaGG
-
NodeJS troubleshooting help
Hi all, I'm not very good at JavaScript coding. I spent some time on the weekend coding up a simple app that does REST polling every minute (gathering arrival times from a bus stop, via an open API), and publishing the values via MQTT onto Solace broker using MQTT.js. Now... I've been running the program using nohup node…
-
Api to unsubscribe to a topic and delete the queue
I have a queue and topic created like this. Now I want to unsubscribe to the topic and delete the created queue. Is there any api to do this? curl http://localhost:8080/SEMP/v2/config/msgVpns/aaron/queues-X POST \- u admin:admin \- H “Content-type-type:application/json” \- d ‘{…
-
Publishing the event in existing microservice
How can we publish event in running existing microservice using solace and spring cloud stream.
-
Mobile Apps
The JavaScript libraries make mention of mobile client applications, can they be used in react-native? if not what is the recommended approach for integrating solace with mobile apps?
-
ERROR : Data sync from oracle to solace with golden gate via jms handler
*Hi Experts, I am new on solace and using oracle golden gate for bigdata JMS handler to sync message from oracle database to solace (docker) I can receive message though the try me! module on topic topic/solace/q1 but after starting ogg replication process then met below can not found topic error, please kindly help…
-
Solace API (C#) on Document Too Large
https://docs.solace.com/Configuring-and-Managing/Managing-Event-Delivery-Resources.htm#managing_msg_delivery_resources_2491525118_198860 According to "Ingress Data Buffer Management", "All SMF messages larger than the event broker's maximum message size—generally 30MB for guaranteed messages or 64MiB for direct…
-
How can we achieve exception handling in spring-cloud-stream using solace binder?
We tried following the exception handling as per spring-cloud-stream documentation (https://docs.spring.io/spring-cloud-stream/docs/current/reference/html/spring-cloud-stream.html#_consumer_properties). But it is not working as expected. I have attached the spring application yaml for your review to find if something needs…
-
Scalable solution for republish a message WITHOUT the payload
For analysis purposes, we want to consume messages and republish them on a new queue without the payload (only the topic that is was published on and the header/properties info do we need). What can be a scalable solution for this? The environment can be on-prem, AWS/Google/Azure cloud so need to run everywhere :) any…
-
JMSToolBox: Topic name associated to Queue is not displaying when I browse Destination Information
Hi Team, Could you please help me how to retrieve the Topic name associated to Queue using JMSToolBox Step1.I've logged into Soldadmin and Created Queue ( e.g Order) Step2.Seleected Queue, Operations, Manage Topics option and associated Queue to Topic Name ( e.g abc/Test1) Step3. Logged into JMSToolBox, Clicked on Queue…
-
JMSToolBox: List of Queues to be displayed based on the User owned by the Queues in VPN
Hi Team, There is a requirement to display only the Queues owned by Subscriber when they login to JMSToolBox(User/Password : User allowed to connect to get a JMS Connection ) but the JMSToolBox is making call to SEMP request(https://hostname:PortNumber/SEMP/v2/config/msgVpns/VPNName/queues?select=queueName&count=1000 GET)…
-
Solace integration with Kafka over TCPS failing
I am trying to connect Solace cloud broker with Kafka. I have a topic in Solace cloud. I want to subscribe into the Solace topic through the pub-sub-plus source connector. Here are my Source Connector Configuration: { "name": "solaceSource", "config": { "name":"solaceSource", "kafka.topic":"solace-connector-test",…
-
Develop spring cloud stream code to manually send acknowledgement post message consumption
Develop spring cloud stream code to manually send acknowledgement post message consumption "pick up message from Solace broker --> do some business logic --> if business logic successful --> ack the message so that it gets deleted from queue (if not, don't ack)"
-
How to set Message TTL when using Spring Cloud Stream Binder Solace
Hi there, I am wondering whether it is possible to set a Message's TTL if you are on the Spring Cloud Stream layer. I wrote a message listener using Spring Cloud Stream, and at most I get access to a GenericMessage from the Spring Cloud Stream framework - but that class does not offer any methods to set a TTL. Is there any…
-
How to implement async request/response with Boomi?
I'm interested in how to implement async request/response using correlation ID's and using the Boomi connector? See https://solace.com/samples/solace-samples-c/request-reply/
-
Dynamically chaging the concurrency value for spring cloud stream
Hi , Is there a way to dynamically changing this "concurrency" value without application down? I am using solace and spring cloud stream for listining message . There is a need to reduce/increase number of consumer on demand to manage application throughput.
-
Spring Cloud Stream Binder - Sending Persistent Messages with StreamBridge
Good morning everyone, using the spring-cloud-stream-binder-solace sending Messages via the StreamBridge, is there a possibility to send persistent Messages? "show client ... stats" only reports non-persistent messages beeing sent by the application. Thank you guys for your support and have a great day! Timo
-
Boomi/Solace: how to set dmq-eligeble=true by default for REST end points
Hi, We have the following use case * Apps are using Solace REST endpoints to send messages to Solace topics * Multiple queues are subscribed to this topic * It appears that REST clients need to set a HTTP header "Solace-DMQ-Eligible: [true|false]" in order to use the DMQ feature Question: can we somehow set the default to…
-
Graylog Content Pack
To ease of support, I am wondering any Graylog content pack is available for Solace
