Package org.apache.activemq.util
Class DefaultIOExceptionHandler
- java.lang.Object
-
- org.apache.activemq.util.DefaultIOExceptionHandler
-
- All Implemented Interfaces:
BrokerServiceAware,IOExceptionHandler
- Direct Known Subclasses:
JDBCIOExceptionHandler,LeaseLockerIOExceptionHandler
public class DefaultIOExceptionHandler extends Object implements IOExceptionHandler
-
-
Field Summary
Fields Modifier and Type Field Description protected BrokerServicebroker
-
Constructor Summary
Constructors Constructor Description DefaultIOExceptionHandler()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected voidallowIOResumption()StringgetNoSpaceMessage()longgetResumeCheckSleepPeriod()StringgetSqlExceptionMessage()voidhandle(IOException exception)protected booleanhasLockOwnership()booleanisIgnoreAllErrors()booleanisIgnoreNoSpaceErrors()booleanisIgnoreSQLExceptions()booleanisStopStartConnectors()booleanisSystemExitOnShutdown()voidsetBrokerService(BrokerService broker)voidsetIgnoreAllErrors(boolean ignoreAllErrors)voidsetIgnoreNoSpaceErrors(boolean ignoreNoSpaceErrors)voidsetIgnoreSQLExceptions(boolean ignoreSQLExceptions)voidsetNoSpaceMessage(String noSpaceMessage)voidsetResumeCheckSleepPeriod(long resumeCheckSleepPeriod)voidsetSqlExceptionMessage(String sqlExceptionMessage)voidsetStopStartConnectors(boolean stopStartConnectors)voidsetSystemExitOnShutdown(boolean systemExitOnShutdown)
-
-
-
Field Detail
-
broker
protected BrokerService broker
-
-
Method Detail
-
handle
public void handle(IOException exception)
- Specified by:
handlein interfaceIOExceptionHandler
-
allowIOResumption
protected void allowIOResumption()
-
hasLockOwnership
protected boolean hasLockOwnership() throws IOException- Throws:
IOException
-
setBrokerService
public void setBrokerService(BrokerService broker)
- Specified by:
setBrokerServicein interfaceBrokerServiceAware
-
isIgnoreAllErrors
public boolean isIgnoreAllErrors()
-
setIgnoreAllErrors
public void setIgnoreAllErrors(boolean ignoreAllErrors)
-
isIgnoreNoSpaceErrors
public boolean isIgnoreNoSpaceErrors()
-
setIgnoreNoSpaceErrors
public void setIgnoreNoSpaceErrors(boolean ignoreNoSpaceErrors)
-
getNoSpaceMessage
public String getNoSpaceMessage()
-
setNoSpaceMessage
public void setNoSpaceMessage(String noSpaceMessage)
-
isIgnoreSQLExceptions
public boolean isIgnoreSQLExceptions()
-
setIgnoreSQLExceptions
public void setIgnoreSQLExceptions(boolean ignoreSQLExceptions)
-
getSqlExceptionMessage
public String getSqlExceptionMessage()
-
setSqlExceptionMessage
public void setSqlExceptionMessage(String sqlExceptionMessage)
-
isStopStartConnectors
public boolean isStopStartConnectors()
-
setStopStartConnectors
public void setStopStartConnectors(boolean stopStartConnectors)
-
getResumeCheckSleepPeriod
public long getResumeCheckSleepPeriod()
-
setResumeCheckSleepPeriod
public void setResumeCheckSleepPeriod(long resumeCheckSleepPeriod)
-
setSystemExitOnShutdown
public void setSystemExitOnShutdown(boolean systemExitOnShutdown)
-
isSystemExitOnShutdown
public boolean isSystemExitOnShutdown()
-
-