@@ -28,17 +28,17 @@ Firstly you should define consumer, Example of consumer
2828
2929``` ruby
3030class V1 ::PaymentOrdersConsumer
31- include Asynk ::Consumer
31+ include Asynk ::Consumer
3232
3333 set_consume ' sample_app.v1.users.create' , ' sample_app.v1.users.notifications'
3434
3535 set_queue_options ack: true
3636 set_subscribe_arguments manual_ack: true
3737 set_concurrency 2
38- set_route_ending_as_action true
38+ set_route_ending_as_action true
3939
4040 # handling asynchronous request from amqp
41- def notifications (params )
41+ def notifications (params )
4242 # do here some works
4343 ensure
4444 ack! # required if you manually processing acknowledgments, available methods reject!, requeue!
@@ -132,7 +132,7 @@ Example using with Rails and MiniTest.
132132``` ruby
133133 # test_helper.rb
134134 class ActiveSupport ::TestCase
135- # include the test helper.
135+ # include the test helper.
136136 include Asynk ::TestHelper
137137
138138 # wrapping the response with Asynk::Response class, otherwise it will be just string value.
@@ -142,14 +142,14 @@ Example using with Rails and MiniTest.
142142 end
143143
144144
145- # some_consumer_test.rb
145+ # some_consumer_test.rb
146146
147147 test ' should show profile' do
148148 publish_sync ' some_route' , { name: ' Chris' }
149149
150150 assert asynk_response.success? # testing for status of the response
151151 assert asynk_response[:unread_messages ] # testing the returned data
152- assert asynk_response[:unread_message_count ]
152+ assert asynk_response[:unread_message_count ]
153153 end
154154```
155155## Disabling consumers
@@ -188,3 +188,5 @@ Asynk.config[:ignored_consumers] = ENV['IGNORED_CONSUMERS'].delete(' ').split(',
1881883 . Commit your changes (` git commit -am 'Add some feature' ` )
1891894 . Push to the branch (` git push origin my-new-feature ` )
1901905 . Create a new Pull Request
191+
192+ sdasdasd
0 commit comments