1 | Producer = require '../lib/nodelib/producer'
|
2 | TestHelper = (require './test_helper')
|
3 |
|
4 | describe 'Producer', ->
|
5 |
|
6 | before -> @topicName = 'test-topic'
|
7 |
|
8 | beforeEach (done) ->
|
9 | TestHelper.connect().done (@connection) =>
|
10 | @producer = new Producer connection, TestHelper.logger('warn')
|
11 | done()
|
12 |
|
13 | after (done) ->
|
14 | return done() unless @connection
|
15 | TestHelper.deleteExchange(@connection, @topicName)
|
16 | .then =>
|
17 | @connection.close()
|
18 | .done ->
|
19 | done()
|
20 |
|
21 | context '#prepare', ->
|
22 | it 'resolves when done', (done) ->
|
23 | @producer.prepare(@topicName).done =>
|
24 | done()
|
25 |
|
26 | context 'when prepared', ->
|
27 | beforeEach (done) ->
|
28 | @producer.prepare(@topicName).done =>
|
29 | done()
|
30 |
|
31 | context '#produce', ->
|
32 | it 'produces successfully', ->
|
33 | produced = @producer.produce 'test-dest', { test: 'data' }
|
34 | produced.should.be.ok
|