class EventStoreClient::HTTP::Commands::PersistentSubscriptions::Create
Public Instance Methods
call(stream_name, subscription_name, options: {})
click to toggle source
# File lib/event_store_client/adapters/http/commands/persistent_subscriptions/create.rb, line 8 def call(stream_name, subscription_name, options: {}) stats = options[:stats] || true start = options[:start] || 0 retries = options[:retries] || 5 max_checkpoint_count = options[:max_checkpoint_count] || 0 min_checkpoint_count = options[:min_checkpoint_count] || 0 connection.call( :put, "/subscriptions/#{stream_name}/#{subscription_name}", body: { extraStatistics: stats, startFrom: start, maxRetryCount: retries, maxCheckPointCount: max_checkpoint_count, minCheckPointCount: min_checkpoint_count, resolveLinkTos: true }, headers: { 'Content-Type' => 'application/json' } ) end