【发布时间】:2018-04-27 11:37:16
【问题描述】:
我在替换这个特定示例时遇到问题:
Consumer consumer = new DefaultConsumer(channel) {
@Override
public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body)
throws IOException {
String message = new String(body, "UTF-8");
System.out.println(" [x] Received '" + message + "'");
}
};
是否可以用 lambda 替换它,因为它使用 DefaultConsumer 的非默认构造函数?
来自rabbitMQ java教程 -> LINK to whole class
【问题讨论】:
-
这取决于
DefaultConsumer。有不止一种抽象方法吗?你是如何使用Consumer consumer的? -
@slim,谢谢,这就是回答我的问题,不,它不能用于它!
-
如果您为 multiple
DefaultConsumers 执行此操作,您可以创建一个辅助方法,将lambda作为输入并返回Defaultconsumer的匿名子类.