@@ 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 | { |