@ SuppressWarnings ( "unchecked" ) @ Override public void start ( final Listener < ? > listener , final Infrastructure infra ) throws MessageTransportException { this . listener = ( Listener < Object > ) listener ; }
A receiver is started with a Listener and a threading model .