Skip to content

Commit 758327d

Browse files
committed
Check if it's an entity before handling an entity
See #107.
1 parent f009e28 commit 758327d

File tree

1 file changed

+8
-4
lines changed

1 file changed

+8
-4
lines changed

metamorph/src/main/java/org/metafacture/metamorph/Metamorph.java

Lines changed: 8 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -326,16 +326,20 @@ private void send(final String path, final String value, final List<NamedValueRe
326326
for (final NamedValueReceiver data : dataList) {
327327
String key=path;
328328
if (fallback && value != null && passEntityEvents) {
329-
outputStreamReceiver.startEntity(flattener.getCurrentEntityName());
330-
key=literalPatternOfEntityMarker.split(path)[1];
329+
if (flattener.getCurrentEntityName() != null) {
330+
outputStreamReceiver.startEntity(flattener.getCurrentEntityName());
331+
key = literalPatternOfEntityMarker.split(path)[1];
332+
}
331333
}
332334
try {
333335
data.receive(key, value, null, recordCount, currentEntityCount);
334336
} catch (final RuntimeException e) {
335337
errorHandler.error(e);
336338
}
337-
if (fallback && value!=null && passEntityEvents) {
338-
outputStreamReceiver.endEntity();
339+
if (fallback && value != null && passEntityEvents) {
340+
if (flattener.getCurrentEntityName() != null) {
341+
outputStreamReceiver.endEntity();
342+
}
339343
}
340344
}
341345
}

0 commit comments

Comments
 (0)