@@ -0,0 +1,1958 @@
+package kata.app;%0A%0Aimport com.fasterxml.jackson.core.JsonProcessingException;%0Aimport com.fasterxml.jackson.databind.ObjectMapper;%0Aimport org.apache.logging.log4j.LogManager;%0Aimport org.apache.logging.log4j.Logger;%0Aimport org.bushe.swing.event.EventBus;%0Aimport org.bushe.swing.event.EventTopicSubscriber;%0A%0Aimport static kata.app.CSVReader.MSG_STARTING;%0Aimport static kata.app.CSVReader.MSG_STOPPING;%0Aimport static kata.app.CSVReader.TOPIC_CSV2JSON;%0A%0Apublic class JSONWriter implements EventTopicSubscriber %7B%0A%0A    private static final Logger logger = LogManager.getLogger();%0A    private ObjectMapper mapper = new ObjectMapper();%0A    private Person person;%0A%0A    public JSONWriter() %7B%0A        EventBus.subscribe(TOPIC_CSV2JSON, this);%0A    %7D%0A%0A    public void onEvent(final String topic, final Object payload) %7B%0A        if (TOPIC_CSV2JSON.equalsIgnoreCase(topic)) %7B%0A            String message = payload.toString();%0A            switch (message) %7B%0A                case MSG_STARTING:%0A                    logger.info(message);%0A                    break;%0A                case MSG_STOPPING:%0A                    logger.info(message);%0A                    break;%0A                default:%0A                    String%5B%5D msg = message.split(%22,%22);%0A                    try %7B%0A                        switch (msg%5B0%5D) %7B%0A                            case %22first_name%22:%0A                                person = new Person(msg%5B1%5D);%0A                                break;%0A                            case %22last_name%22:%0A                                person.setLastName(msg%5B1%5D);%0A                                logger.info(mapper.writeValueAsString(person));%0A                                break;%0A                            default:%0A                                break;%0A                        %7D%0A                    %7D catch (JsonProcessingException jpe) %7B%0A                        jpe.printStackTrace();%0A                    %7D%0A                    break;%0A            %7D%0A        %7D%0A    %7D%0A%7D%0A

Create JSONWriter.java