Как я могу найти номер текущей подписки с использованием PrivatePub и Фей в рельсах

Question

Я использую рубин драгоценный камень под названием PrivatePub и это использует Faye предложить PubSub обмен сообщениям

Жемчужина PrivatePub предлагает несколько помощников на основе просмотра, чтобы подписаться/отправить сообщение по определенной теме. Я хочу расширить PrivatePub, чтобы включить вызов API, который даст мне идентификатор каждого из текущих объектов подписки, связанных с Faye. Может кто-нибудь объяснить, как это может быть достигнуто, или помочь мне найти другой способ выработать все текущие подписки из PrivatePub api.

Answer 1

Начиная с версии 0.7, Faye включает в себя API для мониторинга активности, происходящей внутри двигателя. Это означает, что вы можете присоединить прослушиватели событий для мониторинга создания и уничтожения клиентских сеансов, узнавать, когда подписываются клиенты и отписываются от каналов, а также просматривать опубликованные сообщения.

Вы придаете прослушиватель событий на сервер так:

var bayeux = new Faye.NodeAdapter({mount: '/faye', timeout: 45}) 

bayeux.on('handshake', function(clientId) { 
    // event listener logic 
}) 

Доступные события:

• рукопожатие [ClientId] - Вызывается, когда новый клиент подключается и выдается с идентификатором.

• подписаться на [clientId, channel] - Запускается, когда клиент подписывается на канал. Это не срабатывает, если получено сообщение/meta/subscribe для уже существующей подписки.

• отписаться [clientId, channel] - Запускается, когда клиент отказывается от канала. Это может привести к пожару либо потому, что клиент явно отправил сообщение/meta/unsubscribe, либо потому, что его сеанс был отключен сервером.

• Публиковать [clientId, channel, data] - Запускается, когда публикуется сообщение non/meta/**. Включает идентификатор клиента издателя (который может быть нулевым), канал, на который было отправлено сообщение, и полезную нагрузку данных.

• разъединение [ClientId] - Срабатывает, когда клиент сессии заканчивается, либо потому, что он явно послал/мета-сообщение о разъединении/или потому, что его сессии истекло сервером.

Я надеюсь, что это помогает