\Pydio\Notification\CoreIMessageExchanger

Summary

Methods
Constants
suscribeToChannel()
unsuscribeFromChannel()
consumeInstantChannel()
consumeWorkerChannel()
publishWorkerMessage()
publishInstantMessage()
No constants found
No protected methods found
N/A
No private methods found
N/A

Methods

suscribeToChannel()

suscribeToChannel(\Pydio\Core\Model\ContextInterface  $ctx,   $channelName,   $clientId) : mixed

Parameters

\Pydio\Core\Model\ContextInterface $ctx
$channelName
$clientId

Returns

mixed

unsuscribeFromChannel()

unsuscribeFromChannel(\Pydio\Core\Model\ContextInterface  $ctx,   $channelName,   $clientId) : mixed

Parameters

\Pydio\Core\Model\ContextInterface $ctx
$channelName
$clientId

Returns

mixed

consumeInstantChannel()

consumeInstantChannel(\Pydio\Core\Model\ContextInterface  $ctx,   $channelName,   $clientId,   $userId,   $userGroup) : mixed

Parameters

\Pydio\Core\Model\ContextInterface $ctx
$channelName
$clientId
$userId
$userGroup

Returns

mixed

consumeWorkerChannel()

consumeWorkerChannel(\Pydio\Core\Model\ContextInterface  $ctx,   $channelName,   $filter = null) : mixed

Parameters

\Pydio\Core\Model\ContextInterface $ctx
$channelName
$filter

Returns

mixed

publishWorkerMessage()

publishWorkerMessage(\Pydio\Core\Model\ContextInterface  $ctx, string  $channel, object  $message) : mixed

Parameters

\Pydio\Core\Model\ContextInterface $ctx
string $channel

Name of the persistant queue to create

object $message

Message to send

Returns

mixed

publishInstantMessage()

publishInstantMessage(\Pydio\Core\Model\ContextInterface  $ctx,   $channel,   $message) : mixed

Parameters

\Pydio\Core\Model\ContextInterface $ctx
$channel
$message

Returns

mixed