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 BrokerService
broker
-
Constructor Summary
Constructors Constructor Description DefaultIOExceptionHandler()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected void
allowIOResumption()
String
getNoSpaceMessage()
long
getResumeCheckSleepPeriod()
String
getSqlExceptionMessage()
void
handle(IOException exception)
protected boolean
hasLockOwnership()
boolean
isIgnoreAllErrors()
boolean
isIgnoreNoSpaceErrors()
boolean
isIgnoreSQLExceptions()
boolean
isStopStartConnectors()
boolean
isSystemExitOnShutdown()
void
setBrokerService(BrokerService broker)
void
setIgnoreAllErrors(boolean ignoreAllErrors)
void
setIgnoreNoSpaceErrors(boolean ignoreNoSpaceErrors)
void
setIgnoreSQLExceptions(boolean ignoreSQLExceptions)
void
setNoSpaceMessage(String noSpaceMessage)
void
setResumeCheckSleepPeriod(long resumeCheckSleepPeriod)
void
setSqlExceptionMessage(String sqlExceptionMessage)
void
setStopStartConnectors(boolean stopStartConnectors)
void
setSystemExitOnShutdown(boolean systemExitOnShutdown)
-
-
-
Field Detail
-
broker
protected BrokerService broker
-
-
Method Detail
-
handle
public void handle(IOException exception)
- Specified by:
handle
in interfaceIOExceptionHandler
-
allowIOResumption
protected void allowIOResumption()
-
hasLockOwnership
protected boolean hasLockOwnership() throws IOException
- Throws:
IOException
-
setBrokerService
public void setBrokerService(BrokerService broker)
- Specified by:
setBrokerService
in 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()
-
-