添加材料排序

common-lib/pom.xml

@@ -53,6 +53,13 @@
             <artifactId>guava</artifactId>
         </dependency>
 
+
+        <dependency>
+            <groupId>com.rabbitmq</groupId>
+            <artifactId>amqp-client</artifactId>
+            <version>4.8.0</version>
+        </dependency>
+
         <dependency>
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-amqp</artifactId>

common-lib/src/main/java/com/mortals/xhx/system/RabbitConfig.java

-package com.mortals.xhx.system;
-
-import org.springframework.amqp.rabbit.AsyncRabbitTemplate;
-import org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory;
-import org.springframework.amqp.rabbit.connection.ConnectionFactory;
-import org.springframework.amqp.rabbit.core.RabbitTemplate;
-import org.springframework.boot.autoconfigure.amqp.SimpleRabbitListenerContainerFactoryConfigurer;
-import org.springframework.context.annotation.Configuration;
-
-@Configuration
-public class RabbitConfig {
-
-    //@Bean(name = "consumerBatchContainerFactory")
-    public SimpleRabbitListenerContainerFactory consumerBatchContainerFactory(
-            SimpleRabbitListenerContainerFactoryConfigurer configurer, ConnectionFactory connectionFactory) {
-        // 创建 SimpleRabbitListenerContainerFactory 对象
-        SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
-        configurer.configure(factory, connectionFactory);
-        // 额外添加批量消费的属性
-        factory.setBatchListener(true);
-        factory.setBatchSize(10);
-        factory.setReceiveTimeout(30 * 1000L);
-        factory.setConsumerBatchEnabled(true);
-        return factory;
-    }
-
-    //修改系列和与反序列化转换器
-//    @Bean
-//    public MessageConverter messageConverter() {
-//        return new Jackson2JsonMessageConverter();
-//    }
-
-
-    //@Bean
-    public AsyncRabbitTemplate asyncRabbitTemplate(RabbitTemplate rabbitTemplate) {
-        AsyncRabbitTemplate asyncRabbitTemplate = new AsyncRabbitTemplate(rabbitTemplate);
-        asyncRabbitTemplate.setReceiveTimeout(10000);
-        return asyncRabbitTemplate;
-    }
-
-}