protected Channel createChannel ( ) throws IOException { LOGGER . debug ( "Creating channel" ) ; Connection connection = connectionFactory . newConnection ( ) ; Channel channel = connection . createChannel ( ) ; LOGGER . debug ( "Created channel" ) ; return channel ; }
Creates a channel to be used for consuming from the broker .