Change exception msg.
@@ -181,21 +181,12 @@ public class RocketMQMessageChannelBinder extends
}
}
- /**
- * The abstract binder should not call this method.
- * @param destination
- * @param producerProperties
- * @param errorChannel
- * @return
- * @throws Exception
- * @see RocketMQMessageChannelBinder#createProducerMessageHandler(ProducerDestination,
- * ExtendedProducerProperties, MessageChannel, MessageChannel)
- */
@Override
protected MessageHandler createProducerMessageHandler(ProducerDestination destination,
ExtendedProducerProperties<RocketMQProducerProperties> producerProperties,
MessageChannel errorChannel) throws Exception {
- throw new UnsupportedOperationException();
+ throw new UnsupportedOperationException(
+ "The abstract binder should not call this method");
}
@Override
