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.

Parameters

config $config
dispatcher $dispatcher
service_collection $messenger_method_collection
string $cache_file

at line 71
void init(string $object, int $package_size)

Init a queue object

Parameters

string $object

Queue object type: email/jabber/etc

int $package_size

Size of the messenger package to send

Return Value

void

at line 85
void put(string $object, array $message_data)

Put message into the messenger file queue

Parameters

string $object

Queue object type: email/jabber/etc

array $message_data

Message data to send

Return Value

void

at line 95
void process()

Process the messenger file queue (using lock file)

Return Value

void

at line 162
void save()

Save message data to the messenger file queue

Return Value

void