Create a new wrapperparamlistener the listenerparamconsumer the consumer this.listener = listener; this.consumer = consumer;
this.listener = listener; this.consumer = consumer;
message = consumer.wrapMessage(message); listener.onMessage(message);