queue
class queue
Handling messenger file queue
Properties
protected string | $cache_file | ||
protected config | $config | ||
protected array | $data | ||
protected dispatcher | $dispatcher | ||
protected filesystem_interface | $filesystem | ||
protected service_collection | $messenger_method_collection | ||
protected array | $queue_data |
Methods
__construct(config $config, dispatcher $dispatcher, service_collection $messenger_method_collection, string $cache_file)
Messenger queue constructor.
void
init(string $object, int $package_size)
Init a queue object
void
put(string $object, array $message_data)
Put message into the messenger file queue
void
process()
Process the messenger file queue (using lock file)
void
save()
Save message data to the messenger file queue
Details
at line 55
__construct(config $config, dispatcher $dispatcher, service_collection $messenger_method_collection, string $cache_file)
Messenger queue constructor.
at line 71
void
init(string $object, int $package_size)
Init a queue object
at line 85
void
put(string $object, array $message_data)
Put message into the messenger file queue
at line 95
void
process()
Process the messenger file queue (using lock file)
at line 162
void
save()
Save message data to the messenger file queue