Spring AMQP - отправитель и получение сообщений

это приводит к исключению

Какое исключение?

TypeId: com.diff.approach.JobListenerDTO

Это означает, что вы отправляете DTO, а не хеш-карту, как вы описываете в вопросе.

Если вы хотите удалить заголовок typeId, вы можете использовать обработчик сообщений ...

rabbitTemplate.convertAndSend(Constants.INPUT_QUEUE, dto, m -> {
    m.getMessageProperties.getHeaders().remove("__TypeId__");
    return m;
});

(или , new MessagePostProcessor() {...}, если вы не используете Java 8).

ИЗМЕНИТЬ

Какую версию Spring AMQP вы используете? В версии 1.6 вам даже не нужно удалять заголовок __TypeId__ - фреймворк смотрит на тип параметра слушателя и сообщает преобразователю Джексона тип, чтобы он автоматически преобразовал в него (если может). Как вы можете видеть здесь; он отлично работает без удаления идентификатора типа ...

package com.example;

import java.util.HashMap;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.TimeUnit;

import org.springframework.amqp.core.Queue;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory;
import org.springframework.amqp.rabbit.connection.ConnectionFactory;
import org.springframework.amqp.rabbit.core.RabbitAdmin;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.amqp.support.converter.Jackson2JsonMessageConverter;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.ConfigurableApplicationContext;
import org.springframework.context.annotation.Bean;

@SpringBootApplication
public class So39443850Application {

    private static final String QUEUE = "so39443850";

    public static void main(String[] args) throws Exception {
        ConfigurableApplicationContext context = SpringApplication.run(So39443850Application.class, args);
        context.getBean(RabbitTemplate.class).convertAndSend(QUEUE, new DTO("baz", "qux"));
        context.getBean(So39443850Application.class).latch.await(10, TimeUnit.SECONDS);
        context.getBean(RabbitAdmin.class).deleteQueue(QUEUE);
        context.close();
    }

    private final CountDownLatch latch = new CountDownLatch(1);

    @RabbitListener(queues = QUEUE, containerFactory = "adapterOPListenerContainerFactory")
    public void listen(HashMap<String, Object> message) {
        System.out.println(message.getClass() + ":" + message);
        latch.countDown();
    }

    @Bean
    public Queue queue() {
        return new Queue(QUEUE);
    }

    @Bean
    public RabbitTemplate rabbitTemplate(ConnectionFactory connectionFactory) {
        RabbitTemplate template = new RabbitTemplate(connectionFactory);
        template.setMessageConverter(new Jackson2JsonMessageConverter());
        return template;
    }

    @Bean
    public SimpleRabbitListenerContainerFactory adapterOPListenerContainerFactory(ConnectionFactory connectionFactory) {
        SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
        factory.setConnectionFactory(connectionFactory);
        factory.setMessageConverter(new Jackson2JsonMessageConverter());
        return factory;
    }

    public static class DTO {

        private String foo;

        private String baz;

        public DTO(String foo, String baz) {
            this.foo = foo;
            this.baz = baz;
        }

        public String getFoo() {
            return this.foo;
        }

        public void setFoo(String foo) {
            this.foo = foo;
        }

        public String getBaz() {
            return this.baz;
        }

        public void setBaz(String baz) {
            this.baz = baz;
        }

    }

}

Результат:

class java.util.HashMap:{foo=baz, baz=qux}

Это описано в документации. ...

В версиях до 1.6 информация о типе для преобразования JSON должна была быть предоставлена ​​в заголовках сообщений, либо требовался специальный ClassMapper. Начиная с версии 1.6, при отсутствии заголовков информации о типе тип может быть выведен из аргументов целевого метода.

Вы также можете настроить пользовательский ClassMapper, чтобы всегда возвращать HashMap.

• Хотите использовать "другой" Java-вызов при получении сообщения?

  Настройте @Bean Jackson2JsonMessageConverter с пользовательским ClassMapper

• Хотите использовать "много" разных Java-программ при получении сообщения? Такие как :

  @MyAmqpMsgListener
  void handlerMsg(
          // Main message class, by MessageConverter
          @Payload MyMsg myMsg, 
  
          // Secondary message class - by MessageConverter->ConversionService
          @Payload Map<String, String> map,
  
          org.springframework.messaging.Message<MyMsg> msg,
          org.springframework.amqp.core.Message amqpMsg
  ) {
      // ...
  }
  

  Предоставьте собственный @Bean Converter, ConversionService ， RabbitListenerAnnotationBeanPostProcessor:

  @Bean
  FormattingConversionServiceFactoryBean rabbitMqCs(
          Set<Converter> converters
  ) {
      FormattingConversionServiceFactoryBean fac = new FormattingConversionServiceFactoryBean();
      fac.setConverters(converters);
      return fac;
  }
  @Bean
  DefaultMessageHandlerMethodFactory messageHandlerMethodFactory(
          @Qualifier("rabbitMqCs")
          FormattingConversionService rabbitMqCs
  ) {
      DefaultMessageHandlerMethodFactory defaultFactory = new DefaultMessageHandlerMethodFactory();
      defaultFactory.setConversionService(rabbitMqCs);
      return defaultFactory;
  }
  
  // copied from RabbitBootstrapConfiguration
  @Bean(name = RabbitListenerConfigUtils.RABBIT_LISTENER_ANNOTATION_PROCESSOR_BEAN_NAME)
  @Role(BeanDefinition.ROLE_INFRASTRUCTURE)
  public RabbitListenerAnnotationBeanPostProcessor rabbitListenerAnnotationProcessor(
          MessageHandlerMethodFactory handlerFac
  ) {
      RabbitListenerAnnotationBeanPostProcessor bpp = new RabbitListenerAnnotationBeanPostProcessor();
      bpp.setMessageHandlerMethodFactory(handlerFac);
      return bpp;
  }
  
  @Bean(name = RabbitListenerConfigUtils.RABBIT_LISTENER_ENDPOINT_REGISTRY_BEAN_NAME)
  public RabbitListenerEndpointRegistry defaultRabbitListenerEndpointRegistry() {
      return new RabbitListenerEndpointRegistry();
  }
  

Использованная литература:

• Jackson2JsonMessageConverter
• AMQP-461
• Отладка исходного кода PayloadArgumentResolver