How to NOT send an assured message via solace JMS
I have a very simple producer type program that tries to send a ByteMessage to a topic.
My program is receiving the error com.solacesystems.jms.ConfigurationException: Error sending message - operation not supported on router (Cannot send assured message: Assured message delivery is not enabled on this channel.)
How do I go about ensuring that the message sent is not an assured message? Is this some solace configuration variable? Here is the simple JMS related code Im trying to use where bytes is the object I'm trying to send:
val connection = connectionFactory.createConnection()
val session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE)
val publishDestination = session.createTopic(solace.TOPIC)
val message = new SolBytesMessage()
message.writeBytes(bytes)
val producer = session.createProducer(publishDestination)
producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT)
log.info("Sending message")
producer.send(publishDestination, message)
Solution
Please verify that Direct Transport is checked in the connection factory settings on the appliance.
The Direct Transport setting in the connection factory controls the transport to use for non-persistent messages.
- Trying to write a test with a closure in the end fails on Specs2
- How to preserve time zone in Joda-Time timestamp?
- How is compare different from compareTo in this Scala code?
- Including null values in an Apache Spark Join
- Generic function output for covariance type is wrong, is it a type system bug or expected?
- is it possible to have a circular dependency between .java and .scala classes?
- Better type checking on match in Scala
- Why is the following Java NIO API so slow when compared to netty
- Pyspark write option to csv file for double quote not working properly
- Scala strict type system vs C++ type system
- Spark Dataframe :How to add a index Column : Aka Distributed Data Index
- scala jrebel superclass change
- Getting the element from a 1-element Scala collection
- Testing multiple data sets with ScalaTest
- Scala Execute Shell file
- Gatling: Get cookie value with Gatling 2
- How to modify the csv feed file in gatling
- gatling & elastic : invalid basic authentication header encoding
- Access randomly a line in an array of map using feeders
- Gatling - execute scenarios sequentialy
- Gatling Proxy configuration fails
- What scala-library dependenecy version can be used with Gradle 7.2 for Gatling performance testing
- How to convert the said curl to equivalent scala Gatling code?
- How do I actually run the Gatling test via SBT
- Gatling: check binary response not empty
- How to add a new Struct column to a DataFrame
- How do I compile my code so that it becomes an executable Jar and can be opened and used on any computer?
- How to Acces a Wrappedarray from Dataframe's Map
- Gatling load testing and running scenarios
- Run http tests until AMQ msgs consumed