A description of the functionality required to implement guaranteed processing for an out-of-process adapter and the corresponding Sybase CEP C/C++ out-of-process API functions you use for each.
Action |
Function |
---|---|
Establish a session |
C8PublisherCreateGD |
Create and publish batches of messages |
C8PublisherSendMessageBatch |
Re-establish a session after a failure |
C8PublisherCreateGD (only required after an adapter restart) |
Request the ID of the last batch processed by Sybase CEP Engine |
C8PublisherGetLastBatchId |
If you are converting an existing out-of-process adapter to Guaranteed Delivery, you may find it easier to use these functions for publishing messages instead:
Create and publish batches of messages |
C8PublisherSendMessage or C8PublisherSendMessages, followed by C8PublisherCommit |
See C/C++ API Interface adaptersAPI Interface for specific syntax and usage information.
Sybase CEP provides an example input adapter that implements Guaranteed Delivery, called example_gd_input_adapter.c. You can find it under your Sybase CEP Server or Sybase CEP Studio installation directory, in the sdk/c/examples directory.