-
Simplest way to read a Java MapMessage in .NET
I'm replacing an old TibRv system we have where the message producer is a Java application and the message consumer is a .NET application. Using a MapMessage seemed the most natural way to go, since that had a very similar interface to the TibRv libraries we had been using. After porting the Java applications over, it came…
-
null payload close the consumer flow receiver
Hi All, I am using cloud stream lib for message consuming from solace. If the inbound message has 'null' payload, then InboundXMLMessageListener.xmlMessageMapper.map(bytesXMLMessage) throws SolaceMessageConversionException. And as a result, it ends with "Closing flow receiver to destination ...". And no further messages…
-
Browse Message Payloads in Queues
Dear Team, Could anyone please share the best possible approach to view the content of the messages queued in solace queues/topics. 1) Do we have any solace apis available to view the message payload? 2) Is it possible via CLI? Please suggest any better approaches. Thanks, Vempati
-
How to know total number of Endpoints are present in msgVpn via SEMP V2 ?
Is there any way to query(SEMP V2) to get: 1) Total number(count) of queues in a given msgVpn? 2) Total number of subscriptionTopics in a queue? 3) Total number of TopicEndpoints in a given msgVpn?
-
uOttawa Hackathon - Welcome to the Solace Developer Community!
Introduce your self! Answer the following questions * What is your name * What school and year are you in * Favourite programming language * How many hackathons have you done in the past * What is your team name * Anything else? Keep the thread going and let us know what are you most excited to do/learn during this…
-
Granular access for a Message-VPN user on Solace Cloud.
Hi, Two general questions: 1> Do we have any granular level access on Message-VPN ? For now I can see only these two READ and READ-WRITE. We want to have users on Message VPN but with controlled access. 2> Is there any provision (or suggestion) to have the logic (consumer business logic) and configuration (queue creation +…
-
Microservices - approaches to multiple container instance -> single event consumption
Hi all, I would like to ask your opinion on a microservice use-case, and what would be the best approach to tackle it. The Context Let's say you have 10 microservices, each one implementing a given bounded-context, as per DDD. Each microservice is constantly publishing its own events so that the others who subscribe to…
-
How to use where condition in SEMP V2 for subcripticTopics?
http://xx.x.xx.x/SEMP/v2/config/msgVpns/xxxxx-xxxx-xx/queues/xxx_xxx_xxx_Xxxx/subscriptions?where=subscriptionTopic==SLOG//* --> 400 error -->Cannot query an ancestor http://xx.x.xx.x/SEMP/v2/config/msgVpns/xxxxx-xxxx-xx/queues/xxx_xxx_xxx_Xxxx/subscriptions?where=subscriptionTopic==#SLOG// -->200 but empty response…
-
How to create the dead message queue
How to create the #Dead_message_queue for the MQTT qos 1?
-
How to use where condition in SEMP V2 for subscriptionTopic
http://xx.xx.xx/SEMP/v2/config/msgVpns/xx.xx.xx.xx/queues/xx.xx.xx/subscriptions?where=subscriptionTopic==#SLOG// http://xx.xx.xx/SEMP/v2/config/msgVpns/xx.xx.xx.xx/queues/xx.xx.xx/subscriptions?where=subscriptionTopic==#*…
-
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…
-
Last Value Queues
Does a Last Value Queue store only a single message, or a single message per unique topic? What are some common use cases for them?
-
JMS With Proxy
I cannot seem to find a way to use the Solace Java JMS library to create a client that will connect to an existing publisher outside my company network. The documentation seems to allude to being able to set a SOCKS5 proxy in the host property, but when I try to do that, I receive an error that there are too many colons in…
-
[Live Coding] Event-enabling Serverless architecture using Solace and Azure Functions -- February 16
In this event we will be leveraging Solace Rest Delivery Point (RDP) to trigger azure functions on events. Tune in to this live coding session to get an idea on how to event-enable your Serverless architecture in an overall event-driven architecture (EDA). During this session, you will learn about Solace, the importance of…
-
Graylog Content Pack
To ease of support, I am wondering any Graylog content pack is available for Solace
-
Horizontal scaling of event brokers?
I am investigating creating a HA PubSub+ broker setup, but a single primary broker will not have enough capacity for my needs. Do I need to create multiple triplet clusters and connect them? If so, how is load distributed between the clusters?
-
Getting BeanDefinitionOverrideException: Invalid Bean definition with name 'Queue_name.Group_name
Getting BeanDefinitionOverrideException: Invalid Bean definition with name 'Queue_name.Group_name.errors.recoverer' defined in null: Can not register bean definition[ErrorMessageSendingRecoverer] Help Me solve this issue
-
Solace Channel Interceptors
I am trying to implement common functionality in my methods marked with @StreamListener. I tried registering a GlobalChannelInterceptor but found that the postReceive/afterReceive methods are not triggered when a message is received. Only the preSend/postSend/afterSendCompletion callbacks are executed when sending a…
-
Any reference on how to map RabbitMQ patterns to Solace patterns
Hi, I am looking out for any reference material which describes how to migrate a messaging solution from RabbitMQ to Solace? For example, RabbitMQ describes certain messaging patterns @ https://www.rabbitmq.com/getstarted.html , what I am looking for is a short guide which helps map these patterns and how to realize them…
-
How to put a timeout on receiving messages in asynchronous mode in C Solace API?
Can anyone please share any idea. I want to pass a timeout value within which the message must be received in C Solace Api. receive(timeout) is there for Java Api. Is there anything similar in Solace C api.
-
"Request reply guaranteed messaging using Solace C Api" along with Timeout.
Hi Team, I went through this link "https://docs.solace.com/API-Developer-Online-Ref-Documentation/c/ex_2_r_r_guaranteed_requester_8c-example.html" . The link shows a way of doing it but is there any other way? I came to know about "RRGuaranteedRequestor" and "RRGuaranteedReplier". I want to create a functionality which…
-
GARBAGE CHARACTER getting added in messages received in Request/Reply messaging method.
Hi Team, I am using request and reply mechanism to send and receive messages. After I have sent the message, in the receiving Callback method i found that a garbage character is getting added at the end of the message. So on receiving the message, i am getting the garbage character, Following is the way i am sending…
-
solace running in docker not able to connect to ws port
I am running solace using docker with the below command. But I am not able to connect to websocket from TryMe!.... ws://localhost:8080 docker run -d -p 8080:8080 -p 55555:55555 --shm-size=1g --env username_admin_globalaccesslevel=admin --env username_admin_password=admin --name=solace solace/solace-pubsub-standard
-
Which IOT Edge gateway product did you mention during the Solace EMEA community event?
This is a question for @TomF
-
[Livestream event] Solace Office Hours: EMEA - January 20
Event URL: https://www.youtube.com/watch?v=vcVx0SSbHro&ab_channel=Solace Time: 12:00pm GMT+1 (noon in Paris), January 20, 2021 Event Description Join Solace developer advocate, Aaron Lee, for an online, interactive office hour. This Q&A event will be live-streamed to YouTube, LinkedIn, and Twitch on Wednesday January 20th…
-
SEMP v2- get if any one of the condition (where parameter) is true
http://applianceIP/SEMP/v2/monitor/msgVpns?where=eventConnectionCountThreshold.clearPercent!=40,eventIngressMsgRateThreshold.clearValue==300,enabled==true&select=msgVpnName In the above example, i am getting the results if all conditions are true/satisfied. But is there any way to get if any one or more conditions are true?
-
Boomi Solace listener: com.solacesystems.jcsmp.PropertyMismatchException: Access Type mismatch
Hi, We have successfully tested Boomi and Solace Cloud. We're now testing Boomi with a Solace broker running on an EC2 AWS instance. We basically changed the connection settings on the Boomi side. * The Boomi connection connectivity test is successful * We're able to send messages from Boomi to Solace * The Boomi listener…
-
PubSub Docker image fails to start in an LXC/LXD container
Hi, I have Docker installed in an LXC/LXD container and I'm trying to start Solace PubSub with the latest image (9.8.0.12). Unfortunately, I keep running into the Unable to raise event; rc(would block) error: Host Boot ID: cdbf8a80-964d-4368-9174-90d6a004189dStarting VMR Docker Container: Fri Jan 15 15:59:41 UTC…
-
Solace .NET API
Hi, I am able to connect Solace through Solace API from C# and I have a query whenever I consume messages it reads one message at a time. If we have more than 1000 messages at a time do we have any properties to set how many messages to consume at a time? or we need to loop to the count of messages in the queue.? Could…
-
A Bootiful Podcast - Spring Cloud Stream Lead Oleg Zhurakousky
If you're interested in hearing about the latest with Spring Cloud Stream & Spring Cloud Function be sure to checkout the latest podcast from Josh Long. In this episode he talks to Oleg Zhurakousky, the lead of the Spring Cloud Stream and Spring Cloud Function project. While you give it a listen keep in mind that the…