TsgcWSPServer_sgc › Metodi › Publish
Pubblica un messaggio a tutti i client iscritti a un canale.
procedure Publish(const aMessage, aChannel: String; const aExclude: String = ''; const aInclude: String = ''; const aQueue: TwsQueue = queueLevel0);
| Nome | Tipo | Descrizione |
|---|---|---|
aMessage | const String | Payload da pubblicare; consegnato agli iscritti tramite il loro gestore OnEvent. |
aChannel | const String | Canale su cui il messaggio viene pubblicato; i caratteri jolly come news* si distribuiscono a ogni canale corrispondente che abbia sottoscrittori attivi. |
aExclude | const String | Elenco separato da punto e virgola di GUID di connessione da escludere durante la distribuzione a ventaglio. |
aInclude | const String | Elenco separato da punto e virgola dei GUID di connessione a cui la pubblicazione è limitata. |
aQueue | const TwsQueue | Criterio di conservazione: queueLevel0 (nessuna conservazione), queueLevel1 (mantieni l'ultimo messaggio per canale) o queueLevel2 (accoda ogni messaggio) in modo che i sottoscrittori che si connettono successivamente li ricevano. |
Overload completo. Espande i canali wildcard rispetto alle sottoscrizioni correnti, scrive una copia conservata nella coda lato server quando aQueue è queueLevel1 o queueLevel2, e quindi trasmette il payload a tutti i sottoscrittori corrispondenti rispettando i filtri Exclude/Include.
oProtocol.Publish('breaking news', 'news');
oProtocol.Publish('sticky banner', 'news', '', '', queueLevel1);
procedure Publish(const aMessage, aChannel: String; const aQueue: TwsQueue);
| Nome | Tipo | Descrizione |
|---|---|---|
aMessage | const String | Payload da pubblicare; consegnato agli iscritti tramite OnEvent. |
aChannel | const String | Canale su cui pubblicare; i caratteri jolly sono supportati. |
aQueue | const TwsQueue | Politica di conservazione (queueLevel0, queueLevel1, queueLevel2) per i sottoscrittori in ritardo. |
Overload di comodità che delega all'overload completo con i filtri Exclude e Include vuoti. Lo utilizzi quando deve solo selezionare un livello di conservazione e desidera che ogni subscriber corrispondente riceva il messaggio.
oProtocol.Publish('tick', 'prices', queueLevel1);