midium/l5-stomp-queue

Stomp Queue Driver for Laravel 5

l5-stomp-queue

STOMP Queue and Broadcaster Driver for Laravel 5. This is a fork if the original one from here. The only change is the support for latest Laravel versions., _(*1)

Installation

In order to install l5-stomp-queue, just add, _(*2)

"midium/l5-stomp-queue": "dev-master"

to your composer.json. Then run composer install or composer update., _(*3)

Add the Service Provider to the providers array in config/app.php:, _(*4)

'providers' => array(
    ...
    'Mayconbordin\L5StompQueue\StompServiceProvider',
)

And add the driver configuration to the connections array in config/queue.php:, _(*5)

'connections' => array(
    'stomp' => [
        'driver'     => 'stomp',
        'broker_url' => 'tcp://localhost:61613',
        'queue'      => 'default',
        'system'     => 'activemq'
    ]
)

And for the broadcaster add the same configuration to the connections array in config/broadcasting.php:, _(*6)

'connections' => array(
    'stomp' => [
        'driver'     => 'stomp',
        'broker_url' => 'tcp://localhost:61613',
        'queue'      => 'default',
        'system'     => 'activemq'
    ]
)

Configuration Options

queue

The name of the queue., _(*7)

system

The name of the system that implements the Stomp protocol. Default: null., _(*8)

This value is used for setting custom headers (not defined in the protocol). In the case of ActiveMQ, it will set the AMQ_SCHEDULED_DELAY (see docs) header in order to give support for the later method, defined at Illuminate\Contracts\Queue., _(*9)

sync

Whether the driver should be synchronous or not when sending messages. Default: false., _(*10)

prefetchSize

The number of messages that will be streamed to the consumer at any point in time. Applicable only to ActiveMQ. Default: 1., _(*11)

For more information see the ActiveMQ documentation., _(*12)

clientId

Used for durable topic subscriptions. It will set the activemq.subcriptionName property. See documentation for more information., _(*13)

username and password

Used for connecting to the Stomp server., _(*14)