|
|
|
LOGICAL Flush (integer)
|
/**
Ensure all inflight messages are sent and acknowledged. Typically called before Dispose() is called.
Timeout is number of milliseconds to wait for all outstanding messages to be sent.
@param timeout The number of milliseconds to wait for any inflight messages to be sent and acknowledgements received.
@return true if all messages in producer queue are delivered, false if Flush does not finish due to specified time out
*/
|
|
|
|
OpenEdge.Messaging.ISendResponse Send (IProducerRecord)
|
/**
Produce a record (message) to the topic specified in the record.
@param A record to be sent.
*/
|