package Ġes . spring 5 . rem oran . twitter gather ing . infra . rabbitmq Ċ Ċ import Ġcom . fasterxml . jackson . databind . ObjectMapper Ċ import Ġcom . fasterxml . jackson . module . kotlin . Kotlin Module Ċ import Ġorg . springframework . amqp . core . Queue Ċ import Ġorg . springframework . amqp . core . Topic Exchange Ċ import Ġorg . springframework . amqp . support . converter . Jack son 2 Json Message Converter Ċ import Ġorg . springframework . beans . factory . annotation . Value Ċ import Ġorg . springframework . context . annotation . Bean Ċ import Ġorg . springframework . context . annotation . Configuration Ċ import Ġjava . util .* Ċ Ċ @ Configuration Ċ class ĠRabbit MQ Configuration (@ Value ("\ ${ queue . twitter }") Ġprivate Ġval Ġqueue : ĠString , ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ@ Value ("\ ${ exchange . twitter }") Ġprivate Ġval Ġexchange : ĠString , ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ@ Value ("\ ${ routing - key . track }") Ġprivate Ġval Ġrouting Key : ĠString ) Ġ{ ĊĊĠĠĠ Ġ@ Bean ĊĠĠĠ Ġopen Ġfun Ġqueue (): ĠQueue Ġ{ ĊĠĠĠĠĠĠĠ Ġreturn ĠQueue ( this . queue , Ġfalse ); ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġ@ Bean ĊĠĠĠ Ġopen Ġfun Ġexchange (): Topic Exchange Ġ{ ĊĠĠĠĠĠĠĠ Ġreturn ĠTopic Exchange ( this . exchange ) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġ@ Bean ĊĠĠĠ Ġopen Ġfun Ġconverter (): ĠJack son 2 Json Message Converter Ġ{ ĊĠĠĠĠĠĠĠ Ġreturn ĠJack son 2 Json Message Converter ( ObjectMapper (). register Module ( Kotlin Module ())) ĊĠĠĠ Ġ} Ċ }