import org.springframework.amqp.support.converter.DefaultClassMapper; //导入依赖的package包/类
@Bean
public DefaultClassMapper classMapper()
{
    DefaultClassMapper typeMapper = new DefaultClassMapper();
    typeMapper.setDefaultType(Shipment.class);
    return typeMapper;
}
 

import org.springframework.amqp.support.converter.DefaultClassMapper; //导入依赖的package包/类
@Bean
    public DefaultClassMapper classMapper()
    {
        DefaultClassMapper typeMapper = new DefaultClassMapper();
        typeMapper.setDefaultType(ScrapingResultMessage.class);
//        Map<String, Class<?>> idClassMapping = new HashMap<String, Class<?>>();
//        idClassMapping.put("scrapingResult", UnitAmqpMessage.class);
//        typeMapper.setIdClassMapping(idClassMapping);
        return typeMapper;
    }
 

import org.springframework.amqp.support.converter.DefaultClassMapper; //导入依赖的package包/类
@Bean
public DefaultClassMapper classMapper()
{
    DefaultClassMapper typeMapper = new DefaultClassMapper();

    typeMapper.setDefaultType(TaskMessage.class);

    Map<String, Class<?>> idClassMapping = new HashMap<String, Class<?>>();
    idClassMapping.put("com.gurkensalat.osm.mosques.jobs.ImportDataMessage", ImportDataMessage.class);
    idClassMapping.put("com.gurkensalat.osm.mosques.jobs.TaskMessage", TaskMessage.class);
    typeMapper.setIdClassMapping(idClassMapping);

    return typeMapper;
}