SmartGecko /
GovernorBundle
| @@ 41-57 (lines=17) @@ | ||
| 38 | class AmqpDebugCommand extends ContainerAwareCommand |
|
| 39 | { |
|
| 40 | ||
| 41 | protected function configure() |
|
| 42 | { |
|
| 43 | $this |
|
| 44 | ->setName('governor:amqp-debug') |
|
| 45 | ->addArgument( |
|
| 46 | "exchange", |
|
| 47 | InputArgument::REQUIRED, |
|
| 48 | "Name of the exchange to listen read from" |
|
| 49 | ) |
|
| 50 | ->addArgument( |
|
| 51 | "connection", |
|
| 52 | InputArgument::OPTIONAL, |
|
| 53 | "Name of the connection to use", |
|
| 54 | "default" |
|
| 55 | ) |
|
| 56 | ->setDescription('Displays events routed to the AMQP terminal.'); |
|
| 57 | } |
|
| 58 | ||
| 59 | protected function execute(InputInterface $input, OutputInterface $output) |
|
| 60 | { |
|
| @@ 44-52 (lines=9) @@ | ||
| 41 | class ReplayEventsCommand extends ContainerAwareCommand |
|
| 42 | { |
|
| 43 | ||
| 44 | protected function configure() |
|
| 45 | { |
|
| 46 | $this->setName('governor:replay-events') |
|
| 47 | ->addArgument('exchange', InputArgument::REQUIRED, |
|
| 48 | 'Destination exchange') |
|
| 49 | ->addArgument('connection', InputArgument::OPTIONAL, |
|
| 50 | 'Name of the AMQP connection to use.', 'default') |
|
| 51 | ->setDescription('Replays the events from the event store to the given AMQP exchange.'); |
|
| 52 | } |
|
| 53 | ||
| 54 | protected function execute(InputInterface $input, OutputInterface $output) |
|
| 55 | { |
|
