scalajmssolace
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.
- Scala initialization order object vs. val
- How do I find the min() or max() of two Option[Int]
- convert from Option[String] to Long in Scala?
- How to run Multi threaded jobs in apache spark using scala or python?
- Including null values in an Apache Spark Join
- Multiple parameter closure argument type not inferred
- Specs2 spec fails to compile after upgrade to latest version
- Pass system property to spark-submit and read file from classpath or custom path
- Put if absent to map in scala
- Finding type of List on Scala case class declared field via reflection
- Why a stack overflow from my Scala implicit conversion?
- Filtering rows based on column values in Spark dataframe Scala
- Spark - load CSV file as DataFrame?
- Scala Spark Streaming Via Apache Toree
- Apache Spark: how to cancel job in code and kill running tasks?
- Mockito doReturn: ambiguous reference to overloaded definition
- Scala: Pattern match on regex
- How to load local csv file in spark via --files option
- How to extract the matching object with 1 operation in Scala?
- Difference between flatMap, flatTap, evalMap and evalTap
- Apache Spark: ERROR local class incompatible when initiating a SparkContext class
- I am trying to check if a list is palindrome or not in scala through recursive method
- In Scala 3 with DOT calculus, is `this.type` a path-dependent type? What makes it special?
- Scala3 "as" and "with" keywords used with "given"
- Trying to declare an array of a certain size in Scala
- When to use ZIO environment vs constructor arguments
- java.lang.OutOfMemoryError: UTF16 String size exceeding default value
- Scala: join an iterable of strings
- How can I add a message body to a Play2.2 Scala WS GET?
- Case class equals with list of byte array