wso2 / andes

Apache License 2.0
39 stars 128 forks source link

Fix wso2/product-ei/issues/1845 #958

Closed GDLMadushanka closed 6 years ago

GDLMadushanka commented 6 years ago

Purpose

Fix wso2/product-ei/issues/1845

Goals

Sends consume-ok before start sending messages to subscriber

Approach

Use a runnable object to send comsume-ok frame in AndesSubscriptionManager Class. Use a new setReadyToDeliver method to hold outbound from start sending messages to consumers. After consume-ok frame sent by the thread. We are releasing outbound using setReadyToDeliver(true)

Test environment

JDK 8, Ubuntu 16.04