CodeExplorer NoHandlerMessage example
$stats =
$pool->
list('message_queue_stats'
);
static::
assertEquals(1,
$stats[FooMessage::
class]['count'
]);
static::
assertEquals(3,
$stats[BarMessage::
class]['count'
]);
$this->
runWorker();
$stats =
$pool->
list('message_queue_stats'
);
static::
assertEquals(0,
$stats[FooMessage::
class]['count'
]);
static::
assertEquals(0,
$stats[BarMessage::
class]['count'
]);
$bus->
dispatch(new NoHandlerMessage());
$stats =
$pool->
list('message_queue_stats'
);
static::
assertEquals(1,
$stats[NoHandlerMessage::
class]['count'
]);
$this->
runWorker();
$stats =
$pool->
list('message_queue_stats'
);
static::
assertEquals(0,
$stats[NoHandlerMessage::
class]['count'
]);
}}