// Path: hangout-core/src/main/java/com/ctrip/ops/sysdev/decoders/Decode.java
// public interface Decode {
//     Map<String, Object> decode(String message);
// 
//     default Map<String, Object> createDefaultEvent(String message) {
//         return new HashMap<String, Object>(2) {
//             {
//                 put("message", message);
//                 put("@timestamp", DateTime.now());
//             }
//         };
//     }
// }
// 
// Path: hangout-core/src/main/java/com/ctrip/ops/sysdev/decoders/JsonDecoder.java
// @Log4j2
// public class JsonDecoder implements Decode {
// 
//     public Map<String, Object> decode(final String message) {
//         Map<String, Object> event = null;
//         try {
//             event = (HashMap) JSONValue.parseWithException(message);
//         } catch (Exception e) {
//             log.warn("failed to json parse message to event", e);
//         } finally {
//             if (event == null) {
//                 event = createDefaultEvent(message);
//             }
//             return event;
//         }
//     }
// }
// 
// Path: hangout-core/src/main/java/com/ctrip/ops/sysdev/decoders/PlainDecoder.java
// public class PlainDecoder implements Decode {
// 
// 	public Map<String, Object> decode(final String message) {
// 		return createDefaultEvent(message);
// 	}
// }


import com.ctrip.ops.sysdev.decoders.Decode;
import com.ctrip.ops.sysdev.decoders.JsonDecoder;
import com.ctrip.ops.sysdev.decoders.PlainDecoder;
import lombok.extern.log4j.Log4j2;
import java.util.*;
package com.ctrip.ops.sysdev.baseplugin;





@Log4j2
public abstract class BaseInput extends Base {
    protected Map<String, Object> config;
// Path: hangout-core/src/main/java/com/ctrip/ops/sysdev/decoders/Decode.java
// public interface Decode {
//     Map<String, Object> decode(String message);
// 
//     default Map<String, Object> createDefaultEvent(String message) {
//         return new HashMap<String, Object>(2) {
//             {
//                 put("message", message);
//                 put("@timestamp", DateTime.now());
//             }
//         };
//     }
// }
// 
// Path: hangout-core/src/main/java/com/ctrip/ops/sysdev/decoders/JsonDecoder.java
// @Log4j2
// public class JsonDecoder implements Decode {
// 
//     public Map<String, Object> decode(final String message) {
//         Map<String, Object> event = null;
//         try {
//             event = (HashMap) JSONValue.parseWithException(message);
//         } catch (Exception e) {
//             log.warn("failed to json parse message to event", e);
//         } finally {
//             if (event == null) {
//                 event = createDefaultEvent(message);
//             }
//             return event;
//         }
//     }
// }
// 
// Path: hangout-core/src/main/java/com/ctrip/ops/sysdev/decoders/PlainDecoder.java
// public class PlainDecoder implements Decode {
// 
// 	public Map<String, Object> decode(final String message) {
// 		return createDefaultEvent(message);
// 	}
// }


// Path: hangout-core/src/main/java/com/ctrip/ops/sysdev/baseplugin/BaseInput.java
import com.ctrip.ops.sysdev.decoders.Decode;
import com.ctrip.ops.sysdev.decoders.JsonDecoder;
import com.ctrip.ops.sysdev.decoders.PlainDecoder;
import lombok.extern.log4j.Log4j2;
import java.util.*;

package com.ctrip.ops.sysdev.baseplugin;





@Log4j2
public abstract class BaseInput extends Base {
    protected Map<String, Object> config;
    protected Decode decoder;