in collector/eventadmin/src/main/java/org/apache/karaf/decanter/collector/eventadmin/EventCollector.java [50:79]
public void handleEvent(Event event) {
String topic = event.getTopic();
Map<String, Object> data = new HashMap<>();
data.put("type", "eventadmin");
for (String property : event.getPropertyNames()) {
if (property.equals("type")) {
if (event.getProperty(property) != null) {
data.put("eventType", (event.getProperty(property) != null) ? event.getProperty(property).toString() : null);
} else {
data.put("eventType", "eventadmin");
}
} else if (property.equalsIgnoreCase("subject")) {
if (event.getProperty(property) != null && (event.getProperty(property) instanceof Subject)) {
data.put(property, convertSubject((Subject) event.getProperty(property)));
}
} else {
data.put(property, event.getProperty(property));
}
}
try {
PropertiesPreparator.prepare(data, config);
} catch (Exception e) {
// nothing to do
}
Event bridge = new Event("decanter/collect/eventadmin/" + topic, data);
dispatcher.sendEvent(bridge);
}