This closes #775

This commit is contained in:
Clebert Suconic 2016-09-14 11:54:51 -04:00
commit afee9247ef
8 changed files with 13 additions and 3 deletions

View File

@ -113,6 +113,7 @@ public abstract class ActiveMQScheduledComponent implements ActiveMQComponent, R
}
@Override
public void run() {
delayed.decrementAndGet();
}

View File

@ -72,6 +72,7 @@ public class ActiveMQProtonConnectionCallback implements AMQPConnectionCallback
return result;
}
@Override
public boolean isSupportsAnonymous() {
boolean supportsAnonymous = false;
try {

View File

@ -82,6 +82,7 @@ public class ProtonServerConnectionContext extends AbstractConnectionContext imp
}
}
@Override
public Symbol[] getConnectionCapabilitiesOffered() {
return new Symbol[]{DELAYED_DELIVERY};
}

View File

@ -76,6 +76,7 @@ final class PageSyncTimer extends ActiveMQScheduledComponent {
syncOperations.add(ctx);
}
@Override
public void run() {
super.run();
tick();

View File

@ -90,6 +90,7 @@ public final class PagingManagerImpl implements PagingManager {
this(pagingSPI, addressSettingsRepository, -1);
}
@Override
public void addBlockedStore(PagingStore store) {
blockedStored.add(store);
}
@ -164,10 +165,12 @@ public final class PagingManagerImpl implements PagingManager {
return diskFull;
}
@Override
public boolean isUsingGlobalSize() {
return maxSize > 0;
}
@Override
public boolean isGlobalFull() {
return diskFull || maxSize > 0 && globalSizeBytes.get() > maxSize;
}

View File

@ -72,6 +72,7 @@ public class FileStoreMonitor extends ActiveMQScheduledComponent {
}
@Override
public void run() {
super.run();
tick();

View File

@ -42,6 +42,7 @@ public class ReloadManagerImpl extends ActiveMQScheduledComponent implements Rel
super(scheduledExecutorService, executor, checkPeriod, TimeUnit.MILLISECONDS, false);
}
@Override
public void run() {
super.run();
tick();

View File

@ -115,9 +115,10 @@ public final class FakePagingManager implements PagingManager {
}
/*
* (non-Javadoc)
* @see org.apache.activemq.artemis.core.paging.PagingManager#isGlobalFull()
*/
* (non-Javadoc)
* @see org.apache.activemq.artemis.core.paging.PagingManager#isGlobalFull()
*/
@Override
public boolean isGlobalFull() {
return false;
}