Subscriber

public function postPersist(LifecycleEventArgs $args)
    {
        $offer = $args->getEntity();

        if ($offer instanceof Offer) {
            if (Offer::STATUS_READY_TO_QUEUE=== $offer->getStatus()) {
                $this->bus->dispatch(new OfferBidMessage($offer->getId(),(string) $offer->getBid()));
            }

            if(Offer::STATUS_NEED_PROCESS_PACK === $offer->getStatus()) {
                $this->bus->dispatch(new OfferProcessPackMessage($offer->getId()));
            }
        }
    }