DefaultEvent.java
584 Bytes
package com.dianping.cat.message.internal;
import com.dianping.cat.message.Event;
import com.dianping.cat.message.spi.MessageManager;
public class DefaultEvent extends AbstractMessage implements Event {
private MessageManager m_manager;
public DefaultEvent(String type, String name) {
super(type, name);
}
public DefaultEvent(String type, String name, MessageManager manager) {
super(type, name);
m_manager = manager;
}
@Override
public void complete() {
setCompleted(true);
if (m_manager != null) {
m_manager.add(this);
}
}
}