import io.pify.Framework; import io.pify.annotations.MessageHandler; import io.pify.message.MessageEnvelope; public class DistributedSystem { public static void main(String[] args) { Framework framework = Framework.getInstance(); framework.registerHandler(new MessageHandlerImpl()); framework.start(); } public static class MessageHandlerImpl { @MessageHandler(topic = "example-topic") public void handleMessage(MessageEnvelope envelope) { System.out.println("Received message: " + envelope.getMessage()); } } }