class TopicDispatcher implements TopicDispatcherInterface

Class TopicDispatcher

Constants

SUBSCRIPTION

UNSUBSCRIPTION

PUBLISH

PUSH

Properties

protected TopicRegistry $topicRegistry
protected WampRouter $router
protected TopicPeriodicTimer $topicPeriodicTimer
protected LoggerInterface|null $logger
protected TopicManager $topicManager

Methods

__construct(TopicRegistry $topicRegistry, WampRouter $router, TopicPeriodicTimer $topicPeriodicTimer, TopicManager $topicManager, LoggerInterface $logger = null)

No description

onSubscribe(ConnectionInterface $conn, Topic $topic, WampRequest $request)

No description

onPush(WampRequest $request, array|string $data, string $provider)

No description

onUnSubscribe(ConnectionInterface $conn, Topic $topic, WampRequest $request)

No description

onPublish(ConnectionInterface $conn, Topic $topic, WampRequest $request, string $event, array $exclude, array $eligible)

No description

bool
dispatch(string $calledMethod, ConnectionInterface $conn = null, Topic $topic, WampRequest $request, null $payload = null, null $exclude = null, null $eligible = null, null $provider = null)

No description

Details

at line 53
__construct(TopicRegistry $topicRegistry, WampRouter $router, TopicPeriodicTimer $topicPeriodicTimer, TopicManager $topicManager, LoggerInterface $logger = null)

Parameters

TopicRegistry $topicRegistry
WampRouter $router
TopicPeriodicTimer $topicPeriodicTimer
TopicManager $topicManager
LoggerInterface $logger

at line 74
onSubscribe(ConnectionInterface $conn, Topic $topic, WampRequest $request)

Parameters

ConnectionInterface $conn
Topic $topic
WampRequest $request

Exceptions

Exception

at line 84
onPush(WampRequest $request, array|string $data, string $provider)

Parameters

WampRequest $request
array|string $data
string $provider

at line 96
onUnSubscribe(ConnectionInterface $conn, Topic $topic, WampRequest $request)

Parameters

ConnectionInterface $conn
Topic $topic
WampRequest $request

Exceptions

Exception

at line 111
onPublish(ConnectionInterface $conn, Topic $topic, WampRequest $request, string $event, array $exclude, array $eligible)

Parameters

ConnectionInterface $conn
Topic $topic
WampRequest $request
string $event
array $exclude
array $eligible

Exceptions

Exception

at line 133
bool dispatch(string $calledMethod, ConnectionInterface $conn = null, Topic $topic, WampRequest $request, null $payload = null, null $exclude = null, null $eligible = null, null $provider = null)

Parameters

string $calledMethod
ConnectionInterface $conn
Topic $topic
WampRequest $request
null $payload
null $exclude
null $eligible
null $provider

Return Value

bool

Exceptions

Exception