From: Mike Schonberg <mschonberg@...> When shutting down, don't wait forever for the internal queue to stop. If the queue does not stop within the default queue timeout (mama.defaultqueue.timeout prop

From: Mike Schonberg <mschonberg@...> For TCP socket based middleware, allow transports to disconnect individual clients. This is usefull for eliminating slow consumers or other applications that may

From: Mike Schonberg <mschonberg@...> The CM subscription can not be freed until it destruction completes and invokes the onDestroy() callback. This avoids potential core dumps on cleanup. Signed-off-

From: Mike Schonberg <mschonberg@...> When formatting a date time with a time, separate the date and time with a space. Added parameter checking to makeTime to handle invalid values sanely: set the ye

From: Mike Schonberg <mschonberg@...> Since the caller may pass messages with the reserved files (ie. senderid, seqno, etc.) populated, the dq publisher should try to be robust and update the fields i

From: Mike Schonberg <mschonberg@...> This method allows applications to use a reply handle rather than detaching and holding on to the original message. Since OpenMAMA attempts to reuse messages this

From: Mike Schonberg <mschonberg@...> These are both application supplied callbacks. The closure is intended for application specific context for the publisher and the cache is for caching data that t

From: Mike Schonberg <mschonberg@...> Only invoke the application on create callback if it is not NULL. This avoids core dumps if the application does not provide a callback. The manager was not maint

From: Mike Schonberg <mschonberg@...> Added proper destroy implementation for dqpublisher to allow applications to clean up and shutdown properly. Signed-off-by: Mike Schonberg <mschonberg@...> --- ma

From: Mike Schonberg <mschonberg@...> The dqStratgyScheme deterines whether or not OpenMAMA ignores duplicate messages. Valid values are: DQ_SCHEME_DELIVER_ALL deliver all messages including duplicats

From: Mike Schonberg <mschonberg@...> Added code to avoid race conditions when enqueing shutdown logic on the throttle. Signed-off-by: Mike Schonberg <mschonberg@...> --- mama/c_cpp/src/c/mama/subscri

From: Mike Schonberg <mschonberg@...> OpenMAMA creates a dedicated internal transport for publishing statistics for monitoring and other internal communication. This transport disables some features o

From: Mike Schonberg <mschonberg@...> Allow applications to set high and low watermarks for internal write queues if the underlying middleware queues writes. Socket based middlewares that use scatter/

From: Mike Schonberg <mschonberg@...> Add method to MAMA API that allows connection based middlewares (TCP) to disconnect poorly behaved clients. Signed-off-by: Mike Schonberg <mschonberg@...> --- mam

From: Mike Schonberg <mschonberg@...> This change avoids rare instances of deadlock when starting, stoping, opening and closing OpenMAMA. Signed-off-by: Mike Schonberg <mschonberg@...> --- common/c_cp

From: Mike Schonberg <mschonberg@...> Properly cleanup the StatsGenerator, StatsCollector and StatsPublisher to avoid resource leaks. Signed-off-by: Mike Schonberg <mschonberg@...> --- mama/c_cpp/src/

From: Mike Schonberg <mschonberg@...> Moved MAMA_PAYLOAD_MAX from mama.c to mamainternal.h. Removed uncessary comments and conditionally compiled debug blocks. Moved #includes out extern "C" block in

From: Mike Schonberg <mschonberg@...> Added a closure to mamaQueue to allow applcations to store queue specific context. The new methods are: mamaQueue_setClosure() mamaQueue_getClosure() Signed-off-b

From: Mike Schonberg <mschonberg@...> For some middlewares with "zero-copy" semantics like shared memory or RDMA, applications share message payloads. Others may re-use buffers. In these cases, modify

From: Mike Schonberg <mschonberg@...> On receiving a message with a status of MAMA_MSG_STATUS_UNKNOWN, log the message if at FINEST and track it update the statistics for the transport, queue and appl