Fix queue name used in amqp10
This commit is contained in:
parent
c4d9a840c2
commit
713c7c9a53
|
@ -42,12 +42,12 @@ module.exports = {
|
|||
})
|
||||
let connection = container.connect(getConnectionOptions())
|
||||
let receiver = connection.open_receiver({
|
||||
source: 'examples',
|
||||
source: 'my-queue',
|
||||
target: 'receiver-target',
|
||||
name: 'receiver-link'
|
||||
})
|
||||
let sender = connection.open_sender({
|
||||
target: 'examples',
|
||||
target: 'my-queue',
|
||||
source: 'sender-source',
|
||||
name: 'sender-link'
|
||||
})
|
||||
|
|
Loading…
Reference in New Issue