private ReceiveQueueListener < Response < Object > > createResponseQueueListener ( ) { return new ReceiveQueueListener < Response < Object > > ( ) { @ Override public void receive ( final Response < Object > response ) { if ( debug ) { logger . debug ( "createResponseQueueListener() Received a response: " + response ) ; } handleResponseFromServiceBundle ( response , response . request ( ) . originatingRequest ( ) ) ; } @ Override public void limit ( ) { httpRequestServerHandler . checkTimeoutsForRequests ( ) ; webSocketHandler . checkResponseBatchSend ( ) ; } @ Override public void empty ( ) { httpRequestServerHandler . checkTimeoutsForRequests ( ) ; webSocketHandler . checkResponseBatchSend ( ) ; } @ Override public void idle ( ) { httpRequestServerHandler . checkTimeoutsForRequests ( ) ; webSocketHandler . checkResponseBatchSend ( ) ; } } ; }
Creates the queue listener for method call responses from the client bundle .