-
JCSMP Blocking Publisher Example: Timeout configurable
Hi Community, I have a question on the JCSMP BlockingSynchronousSendGuaranteed.java sample: What happens, if the broker doesn't respond with either an ACK or a NACK? Is this even possible or under which conditions could that occur? (I read something about disk full could be one potential situation.) Is there a timeout for…
-
how to stop message from being sent to next solace topic while going through chain of function?
how to stop message from being sent to next solace topic while going through chain of function? e.g. inTechVal|inFuncVal|map|persist|report-in-0: input inTechVal|inFuncVal|map|persist|report-out-0: output here message goes through inTechVal|inFuncVal|map|persist|report all of these functions but if i want to terminate and…
-
Can we discard or reject message in solace streaming?
this is our declaration spring: cloud: function: definition: inTechVal|inFuncVal|map|persist|report stream: function: bindings: inTechVal|inFuncVal|map|persist|report-in-0: input inTechVal|inFuncVal|map|persist|report-out-0: output here solace streaming is sending message out to solace as per out mapping e.g. after…
-
Is it possible to have DMQ configured with a remote Queue using VPN Bridge/DMR
Hi, Is it possible to have a DMQ configured with a Queue that is not in the current VPN but in another remote VPN/Data Center ? This will help in handling cases when a Queue events/messages are not being processed due to inactive client in one VPN/Data center , so it can be sent to a DMQ in a different active VPN/data…
-
Can we have application connect to multiple Data Centers to achieve active/active capability
We have a use case where we have 2 data centers with guaranteed messaging , currently we want HA hence both data centers are active all the time, so we have DC1.VPN1 with Q1 that is consumed by Client 1 DC2.VPN2 with Q2 that is consumed by Client 2 The publishing of events happen either in DC1.VPN1 or DC2.VPN2 based on…
-
How To Create Docker Image For Go Client ?
Hi Team, Tried Creating the Docker image for Go client, but Facing the Below Error seems the Go package has issues, can someone help on this? # solace.dev/go/messaging/internal/impl/constants 53 /go/pkg/mod/solace.dev/go/messaging@v1.0.1/internal/impl/constants/default_properties.go:35:2: undefined:…
-
How can i gurantee sequence of events to be consistent.
Lets assume i have 4 events Event A producing message to Queue AQ Event B producing message to Queue BQ Event C producing message to Queue CQ Event D producing message to Queue DQ Lets assume consumer named TestConsumer consumer consumes messages from all 4 queues. I want to make sure when solace emit these events it will…
-
Spring cloud stream solace binder connection
Hi Team, I am trying to connect to solace using spring cloud stream solace binder with all the properties in application.yaml . It keeps giving error for connecting to localhost. Error creating bean with name 'com.solace.spring.cloud.stream.binder.config.SolaceMessageChannelBinderConfiguration': Invocation of init method…
-
Solace docker pubsub Image for Apple silicon M1 Chip
I was not able to run the solace image on my M1 chip, is there any plan to release solace image for M1 chip. Even my organisation is planning to make use of M1 chip , Apple so they would be testing the solace image. Let me know if there is any plan.
-
ITransactedSession in .Net
Is there any sample on how ITransactedSession work in .Net with Confirm Delivery (Acknowledged) ? Is CreateFlow require when work on Producer and how its Acknowledgement work within a commit?
-
Node JS typescript compiler not liking Solace API reference to 'long'
I'm running into this error when I try to run my TS compiler: node_modules/solclientjs/index.d.ts:2:10 - error TS2616: 'Long' can only be imported by using 'import Long = require("long")' or a default import. 2 import { Long } from "long"; ~~~~ node_modules/solclientjs/index.d.ts:2:22 - error TS2497: This module can only…
-
What's the best Java based API (JCMSP, JMS or new Java) to achieve blocking publish behaviour?
Hi All, What's the best Java based API (JCMSP, JMS or new Java) to achieve blocking publish behaviour? The application team is using JCSMP currently and having a hard time achieving the behaviour they are looking for, which is: Publish a message Wait for Ack or Nack (and do error handling) Repeat They have strict ordering…
-
Spring Boot XA Transaction Autoconfiguration?
Hello, I am working on a Spring Boot Java project where we are trying to incorporate XA transactions using the Atomikos implementation of JTA. However, we are struggling to see how to easily create the XAConnectionFactory. There does not seem to be any way to autoconfigure the creation of this bean and we are having to…
-
Solace health checks
Hi, I'm currently implementing health checks endpoints for my Asp.Net Core services. Most of them are connected to Solace, so I'd like to have one of the health checks to check if service can be connected to VPN. What would be the best/"cheap" way of doing this? Creating Solace Session each time and trying to connect? My…
-
Special characters for topic addresses
Dear Community I just started learning Solace and I'm doing hands-on from the Solace Essentials training course. Although I was instructed to create a topic address like below, <YOUR_NAME>/rideshare/ride/accepted/2.0.5/{location}/json/{customer_id}/{request_id}/{driver} it gives me an error when I try to download a…
-
Docker container for broker in macbook air M1 is getting existed every time
I have macbook air m1 and I am trying to deploy pubsub+ on docker container but its showing AMD sign with '!' sign and container is immediately existing. can anyone knows how to resolve the issue.
-
Connecting to Solace
Hi All, I am trying to connect to solace using the below details but have to use a truststore instead of a password using C#. SessionProperties sessionProps = new SessionProperties(); sessionProps.Host = "********"; sessionProps.VPNName = "*******"; sessionProps.UserName = "*******"; sessionProps.SSLValidateCertificate =…
