Como é implementada e funciona a interface Consumer em Java para processamento de mensagens?

No C#, a interface Consumer em si não existe, mas o conceito de processamento de mensagens é frequentemente implementado através de delegados, interfaces com um método de processamento ou através de tipos embutidos, como Action<T>.

Se falarmos de processamento de mensagens, geralmente cria-se uma interface com um método que aceita a mensagem e realiza as ações necessárias:

public interface IConsumer<T>
{
    void Consume(T message);
}

public class MessageConsumer : IConsumer<string>
{
    public void Consume(string message)
    {
        Console.WriteLine($"Mensagem recebida: {message}");
        // processamento da mensagem
    }
}

Funcionamento:

• Um objeto que implementa IConsumer<T> recebe a mensagem através do método Consume.
• Dentro do método, a lógica de processamento é implementada — por exemplo, gravar em um banco de dados, chamar outros serviços, etc.

Em algumas bibliotecas (por exemplo, para trabalhar com filas de mensagens), Consumer é um componente que se inscreve no fluxo de mensagens e chama o método de processamento ao receber novos dados.