import org.springframework.amqp.support.converter.MessageConverter; //导入依赖的package包/类
@Test
public void 回復可能例外の場合はデフォルトの指定回数リトライが実行されて回復可能例外キューに配信される() throws Exception {
    container.setQueues(ctx.getBean("retryTestQueue", Queue.class));
    container.setMessageListener(new MessageListenerAdapter(new ApplicationRecoverableExceptionTestHandler(), ctx.getBean(MessageConverter.class)));
    recoverableContainer.setQueues(ctx.getBean("recoverableExceptionQueue", Queue.class));
    recoverableContainer.setMessageListener(new MessageListenerAdapter(new RecoverableTestHandler(), ctx.getBean(MessageConverter.class)));
    container.start();
    recoverableContainer.start();
    template.convertAndSend("retry.test.exchange", "retry.test.binding", new RetryTestBean("test"));
    assertThat(retry.await(30, TimeUnit.SECONDS), is(true));
    assertThat(retry.getCount(), is(0L));
    assertThat(recover.await(3, TimeUnit.SECONDS), is(true));
    assertThat(recover.getCount(), is(0L));
    container.stop();
    recoverableContainer.stop();
}
 

import org.springframework.amqp.support.converter.MessageConverter; //导入依赖的package包/类
public RabbitTemplateMock(
    AmqpTemplateMockManager mockManager,
    MessageConverter messageConverter,
    String defaultExchange) {
  this.mockManager = mockManager;
  this.messageConverter = messageConverter;
  this.setConnectionFactory(Mockito.mock(ConnectionFactory.class));
  this.setExchange(defaultExchange);
}
 

import org.springframework.amqp.support.converter.MessageConverter; //导入依赖的package包/类
@Bean
@Autowired
public RabbitTemplate commandBusRabbitTemplate(final ConnectionFactory commandBusConnectionFactory, final MessageConverter commandBusMessageConverter) {

    log.info("Creating command bus RabbitMQ template with a custom JSON converter");
    final RabbitTemplate rabbitTemplate = new RabbitTemplate(commandBusConnectionFactory);
    rabbitTemplate.setMessageConverter(commandBusMessageConverter);

    return rabbitTemplate;
}
 

import org.springframework.amqp.support.converter.MessageConverter; //导入依赖的package包/类
@Bean
@Autowired
public RabbitTemplate eventBusRabbitTemplate(final ConnectionFactory eventBusConnectionFactory, final MessageConverter eventBusMessageConverter) {

    log.info("Creating query event bus RabbitMQ template with a custom JSON converter");
    final RabbitTemplate rabbitTemplate = new RabbitTemplate(eventBusConnectionFactory);
    rabbitTemplate.setMessageConverter(eventBusMessageConverter);

    return rabbitTemplate;
}
 

import org.springframework.amqp.support.converter.MessageConverter; //导入依赖的package包/类
@Bean
@Autowired
@Primary
public RabbitTemplate eventBusRabbitTemplate(final ConnectionFactory eventBusConnectionFactory, final MessageConverter eventBusMessageConverter) {

    log.info("Creating event bus RabbitMQ template with a custom JSON converter");
    final RabbitTemplate rabbitTemplate = new RabbitTemplate(eventBusConnectionFactory);
    rabbitTemplate.setMessageConverter(eventBusMessageConverter);

    return rabbitTemplate;
}
 

import org.springframework.amqp.support.converter.MessageConverter; //导入依赖的package包/类
@Bean
public MessageConverter jsonMessageConverter()
{
    final Jackson2JsonMessageConverter converter = new Jackson2JsonMessageConverter();
    converter.setClassMapper(classMapper());
    return converter;
}
 

import org.springframework.amqp.support.converter.MessageConverter; //导入依赖的package包/类
@Bean
public RabbitTemplate replicationRabbitTemplate(
        ConnectionFactory connectionFactory,
        MessageConverter replicationMessageConverter
) {
    RabbitTemplate template = new RabbitTemplate(connectionFactory);
    template.setReceiveTimeout(listeningTimeout);
    template.setExchange(replicationExchange);
    template.setMessageConverter(replicationMessageConverter);

    return template;
}
 

import org.springframework.amqp.support.converter.MessageConverter; //导入依赖的package包/类
@Bean
public RabbitTemplate rabbitTemplate(
        ConnectionFactory connectionFactory,
        MessageConverter messageConverter
) {
    RabbitTemplate template = new RabbitTemplate(connectionFactory);
    template.setReceiveTimeout(listeningTimeout);
    template.setMessageConverter(messageConverter);

    return template;
}
 

import org.springframework.amqp.support.converter.MessageConverter; //导入依赖的package包/类
@Bean
public RabbitTemplate outRabbitTemplate(
        ConnectionFactory outConnectionFactory,
        MessageConverter outMessageConverter
) {
    RabbitTemplate template = new RabbitTemplate(outConnectionFactory);
    template.setReceiveTimeout(listeningTimeout);
    template.setQueue(resultQueue);
    template.setMessageConverter(outMessageConverter);

    return template;
}
 

import org.springframework.amqp.support.converter.MessageConverter; //导入依赖的package包/类
@Bean
public RabbitTemplate fileServerRabbitTemplate(
        ConnectionFactory serverConnectionFactory,
        MessageConverter fileServerMessageConverter
) {
    RabbitTemplate template = new RabbitTemplate(serverConnectionFactory);
    template.setReceiveTimeout(listeningTimeout);
    template.setMessageConverter(fileServerMessageConverter);

    return template;
}
 

import org.springframework.amqp.support.converter.MessageConverter; //导入依赖的package包/类
@Test
public void デフォルト値が設定されて指定のインスタンスがDIコンテナに登録される() {
    assertThat(config.host, is("127.0.0.1"));
    assertThat(config.port, is("5672"));
    assertThat(config.username, is("guest"));
    assertThat(config.password, is("guest"));
    assertThat(config.channelCacheSize, is(10));
    assertThat(context.getBean(ConnectionFactory.class), is(notNullValue()));
    assertThat(context.getBean(RabbitTemplate.class), is(notNullValue()));
    assertThat(context.getBean(MessageConverter.class), is(notNullValue()));
}
 

import org.springframework.amqp.support.converter.MessageConverter; //导入依赖的package包/类
@Bean
public MessageConverter jsonConverter() {
    return new Jackson2JsonMessageConverter();
}
 

import org.springframework.amqp.support.converter.MessageConverter; //导入依赖的package包/类
@Bean
public MessageConverter messageConverter() {
  return new ContentTypeDelegatingMessageConverter();
}
 

import org.springframework.amqp.support.converter.MessageConverter; //导入依赖的package包/类
@Bean
public RabbitTemplate rabbitTemplate(
    AmqpTemplateMockManager mockManager, MessageConverter messageConverter) {
  return new RabbitTemplateMock(mockManager, messageConverter, "my-default-exchange");
}
 

import org.springframework.amqp.support.converter.MessageConverter; //导入依赖的package包/类
@Bean
public MessageConverter messageConverter() {
    return new Jackson2JsonMessageConverter();
}
 

import org.springframework.amqp.support.converter.MessageConverter; //导入依赖的package包/类
@Bean
public MessageListenerAdapter listenerAdapter(MQAwareListener listener, MessageConverter converter) {
    return new MessageListenerAdapter(listener, converter);
}
 

import org.springframework.amqp.support.converter.MessageConverter; //导入依赖的package包/类
@Bean(name = RabbitUtils.DEFAULT_MESSAGE_CONVERTER_BEAN_NAME)
public MessageConverter messageConverter() {
    // 原生的Jackson2JsonMessageConverter对泛型处理有些问题,所以我继承了这个类重写了反序列化生成泛型JavaType的方法,如果以后这段代码可以,将原生的Jackson2JsonMessageConverter返回即可
    return new LodsveJackson2JsonMessageConverter();
}
 

import org.springframework.amqp.support.converter.MessageConverter; //导入依赖的package包/类
@Bean
public MessageConverter jsonMessageConverter() {
    return new Jackson2JsonMessageConverter();
}
 

import org.springframework.amqp.support.converter.MessageConverter; //导入依赖的package包/类
@Bean 
MessageConverter jacksonAmqpMessageConverter(ObjectMapper aObjectMapper) {
  return new Jackson2JsonMessageConverter(aObjectMapper);
}
 

import org.springframework.amqp.support.converter.MessageConverter; //导入依赖的package包/类
@Bean
public MessageConverter commandBusMessageConverter() {
    return new Jackson2JsonMessageConverter();
}