123456789101112131415161718192021222324252627 |
- 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);
- }
- }
- }
|