Revision 60441
Added by Claudio Atzori about 3 years ago
modules/dnet-openaireplus-workflows/trunk/src/main/java/eu/dnetlib/msro/openaireplus/workflows/nodes/dhp/message/DnetMessageManager.java | ||
---|---|---|
20 | 20 |
private long maxNumberOfMessages; |
21 | 21 |
|
22 | 22 |
public synchronized void registerMessage(final Message message) throws MSROException { |
23 |
log.debug(String.format("Received %s message", message.getMessageType()));
|
|
23 |
log.debug(String.format("Received %s message wfId: %s", message.getMessageType(), message.getWorkflowId()));
|
|
24 | 24 |
|
25 | 25 |
if (Objects.isNull(message.getMessageType())) { |
26 | 26 |
throw new MSROException("missing message type in: " + message.toString()); |
Also available in: Unified diff
updated hadoop aggregation workflow reporting