Revision 60441
Added by Claudio Atzori about 3 years ago
| 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