Connects to an instance of the Event Stream Processor via the Command and Control and Gateway interfaces and subscribes to transaction streaming data. The received records are converted to XML (or optionally delimited format) and written to the standard output.
esp_subscribe -p host:port/workspace/project -c user[:password] [OPTION...]
The outbound records are marked with insert, update, and delete, even when the SQL statement might not include the key columns of the stream. To give insert/update/delete meaning in these cases, you can specify a special column ESP_SEQNO. For example, the statement select *, ESP_SEQNO from Vwap order by Price automatically fills in values for the ESP_SEQNO column. With order by, the ESP_SEQNO reflects the ordering of the rows in the output set.
esp_subscribe -c user:pass -s PreprocessorTransactions,DebitMovements -p localhost:11180/default/prj1
esp_subscribe -c user:pass -d "|" -s PreprocessorTransactions,DebitMovements -p localhost:11180/default/prj1
esp_subscribe -c user:pass -d "|" -s PreprocessorTransactions -p localhost:11180/default/prj1
esp_subscribe -c user:pass -Q "select intData_1, 10*intData_1+dblData_1 from baseInput where intData_1 > 20" -p localhost:11180/default/prj1
esp_subscribe -p localhost:11180/default/prj1 -Q "select e.*, recordDataToString(e.sourceStreamName, e.errorRecord ) errorRecord from ErrorStream e"