Skip to content

Commit e322bfc

Browse files
author
Fernando Dias
authored
Added array with queues config to factory (#25)
1 parent d1eb428 commit e322bfc

1 file changed

Lines changed: 12 additions & 2 deletions

File tree

src/Adapter/FactoryAdapter.php

Lines changed: 12 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -7,9 +7,19 @@
77

88
class FactoryAdapter
99
{
10-
public function create(array $connection, array $logger)
10+
/**
11+
* @param array $connection
12+
* @param array $queues
13+
* @param array $logger
14+
* @return MessageQueuePHP\Adapter\AMQPAdapter
15+
*/
16+
public function create(array $connection, array $queues, array $logger)
1117
{
12-
$params = ['connection' => $connection, 'logger' => $logger];
18+
$params = [
19+
'connection' => $connection,
20+
'queues' => $queues,
21+
'logger' => $logger
22+
];
1323
return new AMQPAdapter(new Config($params));
1424
}
1525
}

0 commit comments

Comments
 (0)