Modelling
Messaging and Ecotone In Depth
Scheduling
Scheduling PHP
Scheduling
Ecotone comes with support for running period tasks or cron jobs using Scheduled.
Scheduled creates Message from given method and send it to requestChannelName.1
class CurrencyExchanger
2
{
3
#[Scheduled(requestChannelName: "exchange", endpointId: "currencyExchanger")]
4
#[Poller(fixedRateInMilliseconds=1000)]
5
public function callExchange() : array
6
{
7
return ["currency" => "EUR", "ratio" => 1.23];
8
}
9
}
10
​
11
#[CommandHandler("exchange")]
12
public function exchange(ExchangeCommand $command) : void;
Copied!
endpointId - Scheduled requires defined endpointId, it will be used in order to run Adapter.
requestChannelName - The channel name to which Message should be send
poller - Configuration how to execute Inbound Channel Adapter, read more in next section. This configuration tells Ecotone to execute Channel Adapter every second.Symfony
Laravel
Lite
1
console ecotone:list
2
+--------------------+
3
| Endpoint Names |
4
+--------------------+
5
| currencyExchanger |
6
+--------------------+
Copied!
1
artisan ecotone:list
2
+--------------------+
3
| Endpoint Names |
4
+--------------------+
5
| currencyExchanger |
6
+--------------------+
Copied!
1
$consumers = $messagingSystem->list()
Copied!
After setting up Scheduled endpoint we can run the endpoint:
Symfony
Laravel
Lite
1
console ecotone:run currencyExchanger -vvv
Copied!
1
artisan ecotone:run currencyExchanger -vvv
Copied!
1
$messagingSystem->run("currencyExchanger");
Copied!
After running
currencyExchanger endpoint it will poll message from callExchangeand call Command Handler exchangewith array payload ["currency" => "EUR", "ratio" => 1.23]. When the Message will arrive on the Command Handler it will be automatically converted to ExchangeCommand. If you want to understand how the conversion works, you may read about it in Conversion section.Last modified 8mo ago
Export as PDF
Copy link