private void fireOnOpen ( ChannelEvent e ) { if ( readyState == ReadyState . OPEN ) { // If the channel has already been opened, then we should not fire // any events. return ; } readyState = ReadyState . OPEN ; List < EventListener > listeners = changes . getListenerList ( AMQP ) ; for ( EventListener listener : listeners ) { ChannelListener amqpListener = ( ChannelListener ) listener ; amqpListener . onOpen ( e ) ; } }
Fired when channel is opened