private[jms] def populateMessageProperties()

in jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl/JmsMessageProducer.scala [86:102]

• 17 lines of code
• 13 McCabe index (conditional complexity)

  private[jms] def populateMessageProperties(message: javax.jms.Message, jmsMessage: JmsEnvelope[_]): Unit =
    jmsMessage.properties.foreach {
      case (key, v) =>
        v match {
          case v: String      => message.setStringProperty(key, v)
          case v: Int         => message.setIntProperty(key, v)
          case v: Boolean     => message.setBooleanProperty(key, v)
          case v: Byte        => message.setByteProperty(key, v)
          case v: Short       => message.setShortProperty(key, v)
          case v: Float       => message.setFloatProperty(key, v)
          case v: Long        => message.setLongProperty(key, v)
          case v: Double      => message.setDoubleProperty(key, v)
          case v: Array[Byte] => message.setObjectProperty(key, v)
          case null           => message.setObjectProperty(key, null)
          case _              => throw UnsupportedMessagePropertyType(key, v, jmsMessage)
        }
    }