DefaultEvent.java 557 B

123456789101112131415161718192021222324252627
  1. package com.dianping.cat.message.internal;
  2. import com.dianping.cat.message.Event;
  3. import com.dianping.cat.message.spi.MessageManager;
  4. public class DefaultEvent extends AbstractMessage implements Event {
  5. private MessageManager m_manager;
  6. public DefaultEvent(String type, String name) {
  7. super(type, name);
  8. }
  9. public DefaultEvent(String type, String name, MessageManager manager) {
  10. super(type, name);
  11. m_manager = manager;
  12. }
  13. @Override
  14. public void complete() {
  15. setCompleted(true);
  16. if (m_manager != null) {
  17. m_manager.add(this);
  18. }
  19. }
  20. }