lib/fluent/plugin/in_azure_queue.rb in fluent-plugin-azure-queue-0.0.8.pre vs lib/fluent/plugin/in_azure_queue.rb in fluent-plugin-azure-queue-0.0.11.pre

@@ -1,7 +1,7 @@
 require 'fluent/input'
-require 'azure/storage'
+require 'azure/storage/queue'
 require 'concurrent'
 
 module Fluent
   class AzureQueueInput < Input
     Fluent::Plugin.register_input('azure_queue', self)
@@ -25,12 +25,12 @@
       super
     end
 
     def start
       super
-      @queue_client = Azure::Storage::Client.create(
+      @queue_client = Azure::Storage::Queue::QueueService.create(
         :storage_account_name => @storage_account_name,
-        :storage_access_key => @storage_access_key).queue_client
+        :storage_access_key => @storage_access_key)
       log.debug("Succeeded to creating azure queue client")
       @running = true
 
       @delete_pool = Concurrent::ThreadPoolExecutor.new(
         min_threads: 1,
\ No newline at end of file