Collector/RSQueueCollector.php
public function onPublisherAction(RSQueuePublisherEvent $event)
    {
        $this->data['total']++;
        $this->data['publ'][] = array(
            'payload'   =>  $event->getPayloadSerialized(),
            'queue'     =>  $event->getChannelName(),
            'alias'     =>  $event->getChannelAlias(),
        );

        return $this;
    }
public function onPublisherAction(RSQueuePublisherEvent $event)
    {
        $this->data['total']++;
        $this->data['publ'][] = array(
            'payload'   =>  $event->getPayloadSerialized(),
            'queue'     =>  $event->getChannelName(),
            'alias'     =>  $event->getChannelAlias(),
        );

        return $this;
    }
public function onPublisherAction ( RSQueuePublisherEvent $ event ) { $ this -> data [ 'total' ] ++ ; $ this -> data [ 'publ' ] [ ] = array ( 'payload' => $ event -> getPayloadSerialized ( ) , 'queue' => $ event -> getChannelName ( ) , 'alias' => $ event -> getChannelAlias ( ) , ) ; return $ this ; }
Subscribed to RSQueuePublisher event.

Add to collect data a new publisher action

@param RSQueuePublisherEvent $event Event fired

@return QueueCollector self Object
Subscribed to RSQueuePublisher event .