Как использовать Spring Expression Language для массива в аннотации с Scala - PullRequest
Новая
       15

Как использовать Spring Expression Language для массива в аннотации с Scala

0 голосов
/ 04 февраля 2020

У меня есть простой Scala проект, который выглядит следующим образом ... 

@Configuration
public class CommonConfiguration{
    ...
    @Value("${spring.kafka.topic}")
    public String topic;
    ...
}
@Service
class KafkaService @Autowired()(producer: KafkaTemplate[String, Array[Byte]], config: CommonConfiguration){

  def sendMessage(msg: String): Unit = {
    println(s"Writing the message $msg ${config.topic}")
    producer.send(config.topic, msg.getBytes());
  }

  @KafkaListener(id="test", topics="#{'${spring.kafka.topic}'.split(',')}")
  def consume(record: ConsumerRecord[String, String]): Unit = {
    System.out.println(s"Consumed Strinsg Message : ${record.value()}")
  }

}

Это дает мне ошибку ... 

KafkaService.scala:26: error: type mismatch;
[ERROR]  found   : String("#{\'${spring.kafka.topic}\'.split(\',\')}")
[ERROR]  required: Array[String]
[ERROR]   @KafkaListener(id="test", topics= "#{'${spring.kafka.topic}'.split(',')}")

Я пытался использовать #{'${spring.kafka.topic}'.split(',')} за это предложение, но я не могу заставить его работать. Производитель получает топи c просто отлично. Как использовать Spring Expression Language с Scala?

Вот рабочая Java Версия ... 

@Service
public class KafkaJavaService {
    @KafkaListener(id="test", topics="#{'${spring.kafka.topic}'.split(',')}")
    public void consume(ConsumerRecord<String, String> record){
        System.out.println("Consumed String Message : "+record.value())
    }
}

1 Ответ

1 голос
/ 05 февраля 2020

Согласно этот вопрос выглядит так: topics = Array("...") должно работать.

Чтение документации @RequestMapping: http://static.springsource.org/spring/docs/2.5.x/api/org/springframework/web/bind/annotation/RequestMapping.html

Он принимает параметр массива String для своего сопоставления пути.

Так что это работает с использованием java:

@RequestMapping("MYVIEW")

, но в scala I необходимо использовать:

@RequestMapping(Array("MYVIEW"))

Версия scala имеет смысл, так как аннотация ожидает массив String. Но почему вышеприведенное работает в java, не должно ли это дать ошибку времени компиляции?

EDIT

Технически это не то же самое, потому что другой способ, которым я мог бы использовать CSV. Даже если сработало, это был бы массив из 1 строки, если конструктор Array не придумал.

Это не должно иметь значения; как я уже сказал, если выражение в элементе String[] преобразуется в String[], мы рекурсивно разбиваем его на части (сглаживаем). См. здесь и здесь .

Попробуйте установить точку останова в этих методах; У меня не установлено Scala, иначе я бы посмотрел.

...