Утешитель Весенний Облачный Поток AMQP (S)

Question

Я бы хотел подключить мое приложение Spring Boot к экземпляру Solace PubSub +, используя следующий URL amqps://localhost:5671. Я хотел бы использовать Spring Cloud Stream и Solace Spring Cloud Stream Binder для этого.

Я попробовал следующую конфигурацию в моем application.yml:

solace:
  java:
    host: amqps://localhost:5671
    clientUsername: admin
    clientPassword: admin

Но это не работает. Я продолжаю получать сообщения о том, что amqps не является допустимой схемой. То же самое касается простых amqp:// URI.

Я немного углубился в код Solace Spring Cloud Stream Binder, и я не уверен, что это вообще возможно вообще. Похоже, что приведенная выше конфигурация работает только для URI tcp:// и tcps://, в результате оба сообщения отправляются по проприетарному SMF-протоколу Solace.

Это работает:

solace:
  java:
    host: tcp://localhost:55555
    clientUsername: admin
    clientPassword: admin

... но не использует AMQP, а использует SMF.

Как настроить Solace Spring Cloud Stream Binder для связи через AMQP и AMQPS?

Answer 1

Связыватели Spring Cloud Stream от Solace не поддерживают AMQP. Они написаны с использованием Solace Java API JCSMP и используют SMF, который вы наблюдали.

Я не уверен, существует ли связыватель SCS сообщества, использующий AMQP 1.0. Есть ли причина, по которой он нужен для работы в AMQP 1.0?