fixed metadata push in case of already consumed messages
@@ -158,7 +158,9 @@ public class OPushManager implements OMetadataUpdateListener {
if (protocolBinary != null) {
try {
OBinaryPushRequest<?> request = pack.getRequest(database);
+ if (request != null) {
OBinaryPushResponse response = protocolBinary.push(request);
+ }
} catch (IOException e) {
synchronized (OPushManager.this) {
context.get(database).remove(ref);
