forumhouseteam/laravel-amqp

Method __construct has 10 arguments (exceeds 4 allowed). Consider refactoring.

Open

        AMQPStreamConnection $connection,
        $defaultQueueName = null,
        $queueFlags = [],
        $declareQueues = true,
        $messageProperties = [],

Method connect has 27 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    public function connect(array $config)
    {
        $connection = new AMQPStreamConnection(
            $config['host'],
            $config['port'],

Similar blocks of code found in 2 locations. Consider refactoring.

Open

    public function addMessageToBatch($job, $data = '', $queue = null)
    {
        $queue = $this->prepareQueue($queue);
        $payload = new AMQPMessage($this->createPayload($job, $queue, $data), $this->messageProperties);
        $this->channel->batch_basic_publish($payload, $this->exchangeName, $this->getRoutingKey($queue));

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

    public function push($job, $data = '', $queue = null)
    {
        $queue = $this->prepareQueue($queue);
        $payload = new AMQPMessage($this->createPayload($job, $queue, $data), $this->messageProperties);
        $this->channel->basic_publish($payload, $this->exchangeName, $this->getRoutingKey($queue));

• Read up
  Read up