PHP code example of alesima / laravel-azure-service-bus

    
        
<?php
require_once('vendor/autoload.php');

/* Start to develop here. Best regards https://php-download.com/ */

    

alesima / laravel-azure-service-bus example snippets

'connections' => [
    // Other connections...

    'azureservicebus' => [
        'driver' => 'azureservicebus',
        'endpoint' => sprintf('https://%s.servicebus.windows.net/', env('SERVICE_BUS_NAMESPACE')),
        'shared_access_key_name' => env('SERVICE_BUS_SHARED_ACCESS_KEY_NAME'),
        'shared_access_key' => env('SERVICE_BUS_SHARED_ACCESS_KEY'),
        'queue' => 'default',
        'UseTopic' => false,
    ],
],

$app->register(Alesima\LaravelAzureServiceBus\Providers\ServiceProvider::class);

$app->bind(Illuminate\Queue\QueueManager::class, function ($app) {
    return $app['queue'];
});

use App\Jobs\MyJob;

dispatch(new MyJob($data)); // Push to the default queue

dispatch((new MyJob($data))->delay(60)); // Delay by 60 seconds

$interval = new \DateInterval('PT10M'); // 10 minutes
dispatch((new MyJob($data))->delay($interval));

$releaseTime = new \DateTime('+1 hour');
dispatch((new MyJob($data))->delay($releaseTime));

public function handle()
{
    // Your job logic here
}

use LaravelAzureServiceBus\Services\AzurePubSubService;

$pubSub = app(AzurePubSubService::class);

// Publish to a specific topic
$pubSub->publishMessage('topic1', [
    'event' => 'user.created',
    'data' => ['user_id' => 123],
]);

use LaravelAzureServiceBus\Services\AzurePubSubService;

$pubSub = app(AzurePubSubService::class);

// Subscribe to messages from 'topic1'
$messages = $pubSub->retrieveMessages('topic1', 'subscription1');

foreach ($messages as $message) {
    echo $message; // Process the message
}

use LaravelAzureServiceBus\Services\AzurePubSubService;

$pubSub = app(AzurePubSubService::class);

// Retrieve messages from multiple topics
$topics = ['topic1', 'topic2', 'topic3'];

foreach ($topics as $topic) {
    $messages = $pubSub->retrieveMessages($topic, 'subscription1');
    foreach ($messages as $message) {
        echo "From {$topic}: " . $message;
    }
}

bash
php artisan vendor:publish --provider="LaravelAzureServiceBus\Providers\ServiceProvider" --tag=config

bash
docker run --rm \
    -v $(pwd):/app \
    -w /app \
    php:7.4-cli \
    bash -c "apt-get update && apt-get install -y zip unzip git && curl -sS https://getcomposer.org/installer | php && php composer.phar install"

bash
docker run --rm \
    -v $(pwd):/app \
    -w /app \
    php:7.4-cli \
    bash -c "apt-get update && apt-get install -y zip unzip git && curl -sS https://getcomposer.org/installer | php && php composer.phar install && vendor/bin/phpunit --no-coverage"