Sha256: 79073c976676dd667c6e26cd546c0b93313175bf774a4bfd30353ffbb2acbad0
Contents?: true
Size: 1.45 KB
Versions: 7
Compression:
Stored size: 1.45 KB
Contents
# Copyright 2021 The NATS Authors
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
#
module NATS
class JetStream
# PushSubscription is included into NATS::Subscription so that it
#
# @example Create a push subscription using JetStream context.
#
# require 'nats/client'
#
# nc = NATS.connect
# js = nc.jetstream
# sub = js.subscribe("foo", "bar")
# msg = sub.next_msg
# msg.ack
# sub.unsubscribe
#
# @!visibility public
module PushSubscription
# consumer_info retrieves the current status of the pull subscription consumer.
# @param params [Hash] Options to customize API request.
# @option params [Float] :timeout Time to wait for response.
# @return [JetStream::API::ConsumerInfo] The latest ConsumerInfo of the consumer.
def consumer_info(params={})
@jsi.js.consumer_info(@jsi.stream, @jsi.consumer, params)
end
end
private_constant :PushSubscription
end
end
Version data entries
7 entries across 7 versions & 2 rubygems