我在使用Rocket MQ(v4.1.0-孵化)客户端时遇到严重问题,如下所示:
2017-10-16 16:18:12:457[ERROR][SimpleProducer$1.onException(SimpleProducer.java:44)] - send message to mq fail:
org.apache.rocketmq.remoting.exception.RemotingTooMuchRequestException: invokeAsyncImpl invoke too fast
at org.apache.rocketmq.remoting.netty.N
我在我的服务器上构建了一个rocketmq服务,它是2m-noslave集群,它可以向rocketmq发送消息,但我的消费者无法接收消息,有人告诉我哪里错了,thinks...this是我的消费者CLass代码:
public class Consumer{
public static final String CONSUMER_GROUP_NAME = "broker-b";
public static final String CLUSTER_ADDR = "120.27.128.207:9876;120.27.146.42:9876";
我正在运行为.NET SDK RocketMQ提供的演示示例。
但是它抛出了下面的异常。
An unhandled exception of type 'System.TypeInitializationException'
Additional information: The type initializer for 'ons.ONSClient4CPPPINVOKE' threw an exception.
我没有得到任何解决方案的issue.Can,任何人请给出一个解决方案的异常。
我有一个cron作业,它在开发时按预期运行,但在生产上停止工作:
models/user.rb
def self.recalculate_age
User.all.each do |user|
user.recalculate
end
end
def recalculate
self.age = self.age + 1.37
self.save!
end
配置/调度.rb
every 1.day, :at => '12:00 am' do
runner "User.recalculate_age", :environment