@Override
    public void mapAndSend(Event event, OptionHolder optionHolder,
                           Map<String, TemplateBuilder> payloadTemplateBuilderMap, SinkListener sinkListener) {
        String topic = topicOption.getValue(event);
        if (mapType) {
            for (TemplateBuilder templateBuilder : payloadTemplateBuilderMap.values()) {
                sinkListener.publish(new Event(System.currentTimeMillis(), new Object[]{sinkType, topic,
                        templateBuilder.isObjectMessage() + "-" + templateBuilder.getType().toString()}));
            }
        } else {
            //to change the topic as topic is picked from the original event
            event.getData()[0] = sinkType;
            sinkListener.publish(new Event(System.currentTimeMillis(), new Object[]{sinkType, topic, prefix}));
        }
    }
Implementation of {@link SinkMapper} representing pass-through scenario where no mapping is done and
{@link Event}s are send directly to transports.
modules/siddhi-core/src/test/java/io/siddhi/core/transport/TestSinkOptionSinkMapper.java