Namespace: OpenEdge.Messaging
Interface
IProducer
Parent classes:
Inherits: Progress.Lang.Object

/*
Copyright © 2021 Progress Software Corporation and/or its subsidiaries or affiliates. All Rights Reserved.
Purpose:
A producer is fully configured record producer that can be used
to send record to a messaging system.




Method Summary
Options Name Purpose
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. */

Property Summary
Options Name Purpose
CHARACTER ImplementationName
CHARACTER ImplementationVersion
OpenEdge.Messaging.RecordBuilder RecordBuilder


Method Detail
Top

LOGICAL Flush (integer)
Purpose:
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.
Parameters:
timeout INTEGER
The number of milliseconds to wait for any inflight messages to be sent and acknowledgements received.
Returns LOGICAL
true if all messages in producer queue are delivered, false if Flush does not finish due to specified time out
Top

OpenEdge.Messaging.ISendResponse Send (IProducerRecord)
Purpose:
Produce a record (message) to the topic specified in the record.
Parameters:
producerRecord OpenEdge.Messaging.IProducerRecord
Returns OpenEdge.Messaging.ISendResponse


Property Detail
Top

CHARACTER ImplementationName
Returns CHARACTER
Top

CHARACTER ImplementationVersion
Returns CHARACTER
Top

OpenEdge.Messaging.RecordBuilder RecordBuilder
Returns OpenEdge.Messaging.RecordBuilder


Copyright © 2022 Progress Software Corporation. All rights Reserved.

Progress® OpenEdge® Release 12.5.0