Skip to content

Commit

Permalink
Update CI
Browse files Browse the repository at this point in the history
Signed-off-by: Waldemar Quevedo <[email protected]>
  • Loading branch information
wallyqs committed Nov 21, 2023
1 parent 88a5f2d commit 8d3a969
Show file tree
Hide file tree
Showing 3 changed files with 8 additions and 6 deletions.
6 changes: 3 additions & 3 deletions .travis.yml
Original file line number Diff line number Diff line change
Expand Up @@ -28,14 +28,14 @@ jobs:
include:
- name: "Ruby: 3.3.0"
rvm: "3.3.0-preview1"
- name: "Ruby: 3.2.0 (nats-server@dev)"
- name: "Ruby: 3.2.0 (nats-server@v2.9)"
rvm: "3.2.0"
env:
- NATS_SERVER_VERSION=dev
- NATS_SERVER_VERSION=v2.9.24
- name: "Ruby: 3.2.0 (nats-server@main)"
rvm: "3.2.0"
env:
- NATS_SERVER_VERSION=main
allow_failures:
- name: "Ruby: 3.3.0"
- name: "Ruby: 3.2.0 (nats-server@dev)"
- name: "Ruby: 3.2.0 (nats-server@main)"
2 changes: 2 additions & 0 deletions spec/js_features_spec.rb
Original file line number Diff line number Diff line change
Expand Up @@ -31,6 +31,8 @@

it 'should create pull subscribers with multiple filter subjects' do
nc = NATS.connect(@s.uri)
skip 'requires v2.10' unless ENV['NATS_SERVER_VERSION'] == "main"

js = nc.jetstream
js.add_stream(name: "MULTI_FILTER", subjects: ["foo.one.*", "foo.two.*", "foo.three.*"])
js.add_stream(name: "ANOTHER_MULTI_FILTER", subjects: ["foo.five.*"])
Expand Down
6 changes: 3 additions & 3 deletions spec/js_spec.rb
Original file line number Diff line number Diff line change
Expand Up @@ -120,7 +120,7 @@
sub = js.pull_subscribe("hello", "psub", config: { max_waiting: 30 })
info = sub.consumer_info
expect(info.config.max_waiting).to eql(30)
expect(info.num_pending).to eql(3)
expect(info.num_pending).to eql(1)

msgs = sub.fetch(3)
msgs.each do |msg|
Expand All @@ -133,14 +133,14 @@
sub = js.pull_subscribe("hello", "psub2", config: config)
info = sub.consumer_info
expect(info.config.max_waiting).to eql(128)
expect(info.num_pending).to eql(3)
expect(info.num_pending).to eql(1)

msgs = sub.fetch(1)
msgs.each do |msg|
msg.ack_sync
end
info = sub.consumer_info
expect(info.num_pending).to eql(2)
expect(info.num_pending).to eql(0)
end

it 'should find the pull subscription by subject' do
Expand Down

0 comments on commit 8d3a969

Please sign in to comment.