Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- <rabbit:connection-factory id="amqpConnectionFactory" addresses="${amqp.host}:${amqp.port}"
- thread-factory="rabbitThreadFactory"
- cache-mode="CHANNEL"
- channel-cache-size="25"
- username="${amqp.user}"
- password="${amqp.pass}"
- virtual-host="${amqp.vhost}"/>
- <rabbit:admin connection-factory="amqpConnectionFactory" id="rabbitAdmin"/>
- <rabbit:topic-exchange id="motoTopicExchange" name="moto.ex.topic" >
- <rabbit:bindings>
- <rabbit:binding pattern="moto.*.speed" queue="motoQueue8"/>
- <rabbit:binding pattern="moto.*.tour" queue="motoQueue9"/>
- <rabbit:binding pattern="moto.*.naked" queue="motoQueue10"/>
- </rabbit:bindings>
- </rabbit:topic-exchange>
- <rabbit:queue id="motoQueue8" name="moto.queue.8"/>
- <rabbit:queue id="motoQueue9" name="moto.queue.9"/>
- <rabbit:queue id="motoQueue10" name="moto.queue.10"/>
- <rabbit:template id="rabbitTemplate"
- connection-factory="amqpConnectionFactory"
- retry-template="retryTemplate"
- message-converter="rabbitJsonConverter"/>
- <bean id="rabbitJsonConverter" class="org.springframework.amqp.support.converter.Jackson2JsonMessageConverter"/>
- <rabbit:listener-container connection-factory="amqpConnectionFactory" message-converter="rabbitJsonConverter"
- max-concurrency="10" acknowledge="auto">
- <rabbit:listener ref="amqpService8" method="handleSimple" queues="motoQueue8"/>
- <rabbit:listener ref="amqpService9" method="handleSimple" queues="motoQueue9"/>
- <rabbit:listener ref="amqpService10" method="handleSimple" queues="motoQueue10"/>
- </rabbit:listener-container>
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement