-
How to get the number of current consumers using SEMP V2
Hi, We're trying to find out how to retrieve the current number of queue consumers (TCP sessions) using the SEMP V2 API. The response of "GET SEMP/v2/monitor/msgVpns/{msgVpnName}/queues/{queueName}" does not contain this. Thank you :smile:
-
Durability of events in Solace PubSub+
As in Apache Kafka, the messages are durable on the partition for 7 days by default but can be configured based on the time or size, how is the durability aspect in Solace. Also where to configure the durability of messages. Is it a broker level setting or topic level setting?
-
Is solace 10.11 compatible with log4j2 (v2.15)?
Hi there. Because of the actual log4j issue (Log4j2 Vulnerability (CVE-2021-44228)), i was asked to change our jms client implemtation to use the latest version of log4j2 (v2.15). The previous log4j version used by the client was log4j-1.2.16. Everything was working fine there. I know this old version is not affected,…
-
Can you set compression port on JMS client?
When connecting to Solace via JMS JNDI LookUp with compression the lookup occurs over 55555 but the connection then connects of 55003. I have a network configuration where we port translate to multiple solace instances and trying to figure out how to map different servers to different ports but I can't seem to figure out…
-
How to integrate unity3d and Solace pubsub?
Hi I am very happy that I can join to your community. Since some months ago I was working with solace pub sub+ and now I want to integrate Solace to unity3d for publishing messages from unity to Solace I didn't have any problem but to receive data from Solace and using unity as a subscriber I had lots of problem and I…
-
How to push Syslog to ELK ?
We need to push Syslog to ELK, so that we can have end-to-end message flow dashboard.
-
Want to use same topic across multiple environments like QA, Staging and Prod.
I want to use same topic across multiple environments like QA, Staging and Prod. Is it possible to use Event broker with topic name domain/test/{env}/supply, where {env} is the variable dynamically replaced with a value sent from client in message header? I know the actual Topic name is required to be provided from…
-
5 minute vmr-solaudit cpu spikes
python3 /usr/sw/loads/soltr_9.9.0.34/scripts/vmr-solaudit -d --daemonize does anyone else see a curious 5 minute cpu spike on the PubSub+ 02:40:46 PM 1000001 18428 16.00 6.00 0.00 22.00 2 python3 02:40:47 PM 1000001 18428 76.00 24.00 0.00 100.00 2 python3 02:40:48 PM 1000001 18428 55.00 21.00 0.00 76.00 3 python3 02:45:49…
-
Clone Message in Java ? (for DMQ move to Main Queue)
I have a problem with functionality which is not implemented in all offered programming languages. The use case i work on is a utility to move messages from DMQ back to main queue to re-publish the messages). The problem is that there is a flag DMQ eligible…
-
How to delete a subscription using Solace CLI
Hello, I created a subscription using 6f09e644721e(configure/message-spool/queue)# subscription topic entity/created How do I delete this subscription? Thanks.
-
Is there a way to run Solace without a container?
Hello, I'm looking for a way to run Solace standalone on a server without any sort of container and not on any cloud platform. I can't see any executables provided on the developer site, are there any available?
-
Spring cloud stream support solace
Give the autogenerated binding a friendlier name spring.cloud.stream.function.bindings.supplyLoan-out-0=output what would be the equivalent of this in solace configuration ? =================================================== Supplier loanSupplier = () -> { Loan loan = new Loan(UUID.randomUUID().toString(), names.get(new…
-
What username will Bridge use if no username is mentioned?
Hi, I created two bridges on the same appliance for two different VPN's from two different software brokers for two different VPN's, I haven't mentioned client username in both the bridges. And I observed that one of the bridge is using #client-username and the other is using default. There are no configuration changes as…
-
Purge or Delete Queue message via C#.net
We have few application services currently using Message Queue and currently transitioning to use Solace Messaging. In .Net Message Queue, it has a feature the Purge all the Messages. These application services require to Purge all messages when it is starting. I do aware Solace Application do have this in Queues -> Queue…
-
TTL - Message Expiry check on the queue..
If TTL on a message is set to 180secs (say), wondering when the expiry is checked and removal of expired events occur? Just curious how the following scenarios are handled: a) If DMQ is enabled, the dequeue from current queue and enqueue on the DMQ has to occur at the exact time when the message expired, right? b) If no…
-
C++, Max clients exceeded for queue
Hi, I would like to send Guaranteed messages to a queue and then read them back within a C++ project. I have managed to create a session (solClient_session_create), then I created a transacted session (solClient_session_createTransactedSession). When creating a flow (solClient_transactedSession_createFlow), I get the…
-
Test REST Consumers against a Mock
Hello, I am trying to test the following scenario: I publish a mesage to a topic called rest, and then A rest Consumer picks that mesasge up and sends it to the mock server. Is this scenario possible? If so, i'll be running a postman mock and Solace will be running localy on Docker(I think i might run into some ssl…
-
How to get ReplicationGroupMessageId for message replay with Spring cloud stream
Hi , I was trying to find replayMsgId in message header using spring cloud stream , i printed all header which i received but not able to find any values as "rmid1:0117b-75462900ca8-00000000-00135082" Headers which i got as below: * solace_senderTimestamp --1628606024803 * solace_expiration -- 0 * deliveryAttempt -- 1 *…
-
MQTT connection to PubSub+ cloud
I have a working Solace instance running in Docker and I can connect using MQTT. Recently I configured a cloud service and I get NOT_AUTHORIZED when I try to connect to the MQTT service. The host, username and password are OK. I tried with wrong ones and then I get different errors (BAD_USER_NAME_OR_PASSWORD and "Name or…
-
Possible to track message ids ??
Hi solace support team, We are using solace hardware Appliance 3560, is it possible to track each and every message ids in solace?? If yes please let me know..
-
Proxy Solace Connection
Hi, Can we create proxy solace in our local to store the messages/data? Thanks, Prasoon
-
show debug commands
Hi, show debugCOMMAND:debug [process-name <process-name>] [process-instance <process-instance>] [timeout <seconds>] <command> [<parameter-list>]DESCRIPTION:Show internal debug informationMINIMUM REQUIRED SCOPE/ACCESS LEVEL:global/read-onlyPARAMETERS:<command> [string] - Debug command to execute.<parameter-list> [string] -…
-
how retries works in RDP
When message delivery got failure due to 503/504 does redelivery count will decrease or it will ignore that attempt? Ex: we have set 5 redelivery attempt and 3 times we got 503 for same message then does this means now it will do 2 attempts only.
-
PubSub+ Connector for Kafka Connect 2.1.0 is available now!
PubSub+ Connector for Kafka Connect 2.1.0 has been released and is available for download now. Release Summary: * (Sink) Added the capability for record processor implementations to be configurable through the connector configuration. * (Sink) Added the sol.emit.kafka.record.headers.enabled connector configuration option…
-
PubSub+ Connector for MuleSoft Anypoint Platform 1.0.0 is live now!
PubSub+ Connector for MuleSoft Anypoint Platform 1.0.0 has been released and is available for download! Release Summary: * Use the PubSub+ Connector to leverage PubSub+ Event Broker (event streaming) and PubSub+ Event Portal (event management) within the MuleSoft Anypoint Platform to make your MuleSoft integrations more…
-
Prevent Queue subscribing application to receive another message until ACK is sent
Hi there, I have a consuming application using the solace .NET client API which binds to an exclusive queue. May aim is to process messages in order without any loss. Suppose I have the following messages on the Queue: msg1, msg2, and msg3. Let's say I have received msg1 and am processing it on the FlowMessageHandler in my…
-
Sample code for request/reply design by using Spring Cloud Stream
Hi, I am new to solace and my application is using solace request/reply by using old approach. I have planned to use spring cloud stream in my project for the below scenarios. please refer the below use case and help me with samples: I have three microservice services in my application ServiceA -- > Request the message to…
-
How to keep message listener up and running to asynchronously keep receiving messages
Hi, I am using JCSMP API. For listening to messages. I am using asynchronous receiving by implementing XMLMessageListener. Once I started FlowReceiver, it starts listening to messages, my program terminates after some time. I want my listener to be up and running until I terminate my program. Is it possible keep the…
-
JMS Message Handling Scenarios
I am coming through the Solace docs trying to figure out the differences between various JMS pub/sub configurations and how the message and acks would be handled. Here are my scenarios. What I am trying to identify is when an ack is sent, when a message is spooled to disk vs retained in memory, and when/how a message may…
-
cli to legacy semp for session-idle-timeout
Hello Solace-Community, new Solace user here :smile: We are currently developing our own terraform solace provider and are now at a point where we want to be able to configure some broker settings through terraform. For that we are using the semp v2 api whenever possible but have to fall back to the legacy semp from time…
