}
@Override
public boolean shouldWait() {
final QueueContainer container = getOrCreateContainer();
return getWaitTimeout() != 0 && (container.size() + container.txMapSize()) == 0;
}
@Override
public void onWaitExpire() {
getResponseHandler().sendResponse(null);