Metamorphosis
Metamorphosis copied to clipboard
A high available,high performance distributed messaging system.
如果我对MessageConsumer进行了shutdown,是否可以将其再次开启,或者有没有方法断开当前程序的长连接,过段时间后又重连metaq
align mysql-connector-java version to avoid inconsistent API behaviors.
Hi. I have implemented a tool to detect library version inconsistencies. Your project have 1 inconsistent library and 9 false consistent libraries. Take mysql:mysql-connector-java for example, this library is declared...
图挂了
如何发送延时消息
如何发送延时消息
这么通用的中间件,原码为何不用utf-8,而用GBK?造成编译很容易出问题。
不明白为什么编码一直是gbk。 在eclipse查看java doc的提示时,总是显示乱码,基本是没用。 另外,代码里还有很多地方即使用gbk,还是显示乱码。
MonitorLog.java 的 static 块中显式用到了 log4j的不常用类:FileAppender、DailyRollingFileAppender 而 log4j.jar 作者后续的 log4j-over-self4j.jar,没有这两个类(NoClassDefFoundError), 只有 log4j 标准 API 用法的同名类 和 Appender/RollingFileAppender 等有限类。 感觉MetaStatLog实际没多大用处,这个是否可以直接去掉? 或者改为简单地写文件,不依赖具体的log的实现,或者改用slf4j?

情况偶现,症状就是程序不退出,进入死循环,CPU使用率100%,关键的堆栈如下: "Thread-48" daemon prio=10 tid=0x00007f47a8048000 nid=0x73d2 in Object.wait() [0x00007f4796dec000] java.lang.Thread.State: TIMED_WAITING (on object monitor) at java.lang.Object.wait(Native Method) at java.lang.Thread.join(Thread.java:1289) - locked (a java.lang.Thread) at com.taobao.metamorphosis.client.consumer.SimpleFetchManager.interruptRunners(SimpleFetchManager.java:146) at com.taobao.metamorphosis.client.consumer.SimpleFetchManager.stopFetchRunner(SimpleFetchManager.java:128) at com.taobao.metamorphosis.client.consumer.SimpleMessageConsumer.shutdown(SimpleMessageConsumer.java:162) -...