public void receive(MessageIn message, String id, long timestamp)
{
TraceState state = Tracing.instance().initializeFromMessage(message);
if (state != null)
state.trace("Message received from {}", message.from);
message = SinkManager.processInboundMessage(message, id);
if (message == null)
return;