Producer producer = new Producer(); Consumer consumer = new Consumer(); @Override public void handleMessage(Message message) { } });