private void fireOnClosed ( ConnectionEvent e ) { List < EventListener > listeners = changes . getListenerList ( AMQP ) ; for ( EventListener listener : listeners ) { ConnectionListener amqpListener = ( ConnectionListener ) listener ; amqpListener . onConnectionClose ( e ) ; } }
Occurs when the connection to the AMQP server is closed