聊聊cheddar的events

public interface Event {

    String type();

    String serialize();

}

public abstract class AbstractEvent implements Event {

    private static final ObjectMapper MAPPER = new ObjectMapper();

    static {
        MAPPER.configure(SerializationFeature.FAIL_ON_EMPTY_BEANS, false);
        MAPPER.configure(SerializationFeature.WRITE_DATES_AS_TIMESTAMPS, false);
        MAPPER.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);
        MAPPER.registerModule(new JodaModule());
    }

    @Override
    public abstract String type();

    public static <T extends Event> T newEvent(final Class<T> eventClass, final String serializedEvent) {
        try {
            return MAPPER.readValue(serializedEvent, eventClass);
        } catch (final IOException e) {
            throw new IllegalStateException("Could not instantiate event " + eventClass.getName());
        }
    }

    @Override
    public final String serialize() {
        try {
            return MAPPER.writeValueAsString(this);
        } catch (final Exception e) {
            throw new IllegalStateException("Could not serialize event: [" + this + "]", e);
        }
    }

}

public interface EventHandler<E extends Event> {

    void handle(final E event);

    Class<? extends E> getEventClass();

}

public abstract class EventPublisher<E extends Event> {

    private final Logger logger = LoggerFactory.getLogger(getClass());
    private final MessagePublisher<TypedMessage> messagePublisher;

    protected EventPublisher(final MessagePublisher<TypedMessage> messagePublisher) {
        this.messagePublisher = messagePublisher;
    }

    public void publishEvent(final E event) {
        logger.debug("Publishing: " + event);
        final TypedMessage typedMessage = new SimpleMessage(event.type(), event.serialize());
        messagePublisher.publish(typedMessage);
    }

}