fix vyuldashev#362, fix vyuldashev#363

Author: vyuldashev

src/Console/ConsumeCommand.php

@@ -10,6 +10,7 @@ class ConsumeCommand extends WorkCommand
 {
     protected $signature = 'rabbitmq:consume
                             {connection? : The name of the queue connection to work}
+                            {--name=default : The name of the consumer}
                             {--queue= : The names of the queues to work}
                             {--once : Only process the next job on the queue}
                             {--stop-when-empty : Stop when the queue is empty}
@@ -33,6 +34,7 @@ public function handle(): void
         $consumer = $this->worker;
 
         $consumer->setContainer($this->laravel);
+        $consumer->setName($this->option('name'));
         $consumer->setConsumerTag($this->consumerTag());
         $consumer->setPrefetchSize((int) $this->option('prefetch-size'));
         $consumer->setPrefetchCount((int) $this->option('prefetch-count'));

src/Horizon/RabbitMQQueue.php

@@ -4,10 +4,10 @@
 
 use Illuminate\Contracts\Container\BindingResolutionException;
 use Illuminate\Contracts\Events\Dispatcher;
+use Illuminate\Support\Str;
 use Laravel\Horizon\Events\JobDeleted;
 use Laravel\Horizon\Events\JobPushed;
 use Laravel\Horizon\Events\JobReserved;
-use Laravel\Horizon\JobId;
 use Laravel\Horizon\JobPayload;
 use PhpAmqpLib\Exception\AMQPProtocolChannelException;
 use VladimirYuldashev\LaravelQueueRabbitMQ\Queue\Jobs\RabbitMQJob;
@@ -125,6 +125,6 @@ protected function event($queue, $event): void
      */
     protected function getRandomId(): string
     {
-        return JobId::generate();
+        return Str::uuid();
     }
 }

src/Queue/RabbitMQQueue.php

@@ -544,7 +544,7 @@ protected function createPayloadArray($job, $queue, $data = '')
      */
     protected function getRandomId(): string
     {
-        return Str::random(32);
+        return Str::uuid();
     }
 
     /**