@Component public class MQDynamicHandler extends Object
| 构造器和说明 |
|---|
MQDynamicHandler() |
| 限定符和类型 | 方法和说明 |
|---|---|
void |
consumerGenerate(String beanName,
String exchangeName,
String queueName,
String routingKey,
boolean autoDelete,
boolean durable,
String acknowledgeMode,
EnumsExchangeType exchangeType) |
void |
publishMsg(String exchange,
String routingKey,
Object msg)
将消息发送到指定的交换器上
|
public void publishMsg(String exchange, String routingKey, Object msg)
exchange - routingKey - msg - public void consumerGenerate(String beanName, String exchangeName, String queueName, String routingKey, boolean autoDelete, boolean durable, String acknowledgeMode, EnumsExchangeType exchangeType) throws Exception
beanName - exchangeName - queueName - routingKey - autoDelete - durable - acknowledgeMode - exchangeType - ExceptionCopyright © 2019. All rights reserved.