// app/Process/ImProcess.php
use Mine\NextCoreX\Queue;
use Hyperf\WebSocketServer\Sender;
class ImProcess extends AbstractProcess
{
    public function __construct(
      private readonly Queue $queue,
      private readonly Sender $sender
    ) {}
    public function handle()
    {
        $data = Queue::pull('user_messages');
        foreach ($data as $item) {
            
        }
    }
}