public class MessageHandler extends Object
限定符和类型 | 字段和说明 |
---|---|
static Map<String,Class> |
queueMessageClassMap
队列消息数据对应的类型
|
static Map<String,RabbitmqConsumerHandler> |
queueMessageConsumerHandlerMap
队列消息数据对应的处理器
|
构造器和说明 |
---|
MessageHandler() |
public static Map<String,RabbitmqConsumerHandler> queueMessageConsumerHandlerMap
public static <T> void parseMessage(org.springframework.amqp.core.Message message, Class<T> messageClass, RabbitmqConsumerHandler<T> handler) throws IOException
T
- message
- messageClass
- handler
- IOException