don't requeue too many status entries ex, fix typo of ex
Signed-off-by: Michael Hirsch <michael.hirsch@bosch-si.com>
This commit is contained in:
@@ -41,7 +41,7 @@ import org.eclipse.hawkbit.repository.RepositoryConstants;
|
|||||||
import org.eclipse.hawkbit.repository.eventbus.event.TargetAssignDistributionSetEvent;
|
import org.eclipse.hawkbit.repository.eventbus.event.TargetAssignDistributionSetEvent;
|
||||||
import org.eclipse.hawkbit.repository.exception.EntityNotFoundException;
|
import org.eclipse.hawkbit.repository.exception.EntityNotFoundException;
|
||||||
import org.eclipse.hawkbit.repository.exception.TenantNotExistException;
|
import org.eclipse.hawkbit.repository.exception.TenantNotExistException;
|
||||||
import org.eclipse.hawkbit.repository.exception.ToManyStatusEntriesException;
|
import org.eclipse.hawkbit.repository.exception.TooManyStatusEntriesException;
|
||||||
import org.eclipse.hawkbit.repository.model.Action;
|
import org.eclipse.hawkbit.repository.model.Action;
|
||||||
import org.eclipse.hawkbit.repository.model.Action.Status;
|
import org.eclipse.hawkbit.repository.model.Action.Status;
|
||||||
import org.eclipse.hawkbit.repository.model.ActionStatus;
|
import org.eclipse.hawkbit.repository.model.ActionStatus;
|
||||||
@@ -155,7 +155,7 @@ public class AmqpMessageHandlerService extends BaseAmqpService {
|
|||||||
return handleAuthentifiactionMessage(message);
|
return handleAuthentifiactionMessage(message);
|
||||||
} catch (final IllegalArgumentException ex) {
|
} catch (final IllegalArgumentException ex) {
|
||||||
throw new AmqpRejectAndDontRequeueException("Invalid message!", ex);
|
throw new AmqpRejectAndDontRequeueException("Invalid message!", ex);
|
||||||
} catch (final TenantNotExistException | ToManyStatusEntriesException e) {
|
} catch (final TenantNotExistException | TooManyStatusEntriesException e) {
|
||||||
throw new AmqpRejectAndDontRequeueException(e);
|
throw new AmqpRejectAndDontRequeueException(e);
|
||||||
} finally {
|
} finally {
|
||||||
SecurityContextHolder.setContext(oldContext);
|
SecurityContextHolder.setContext(oldContext);
|
||||||
@@ -196,8 +196,8 @@ public class AmqpMessageHandlerService extends BaseAmqpService {
|
|||||||
}
|
}
|
||||||
} catch (final IllegalArgumentException ex) {
|
} catch (final IllegalArgumentException ex) {
|
||||||
throw new AmqpRejectAndDontRequeueException("Invalid message!", ex);
|
throw new AmqpRejectAndDontRequeueException("Invalid message!", ex);
|
||||||
} catch (final TenantNotExistException teex) {
|
} catch (final TenantNotExistException | TooManyStatusEntriesException e) {
|
||||||
throw new AmqpRejectAndDontRequeueException(teex);
|
throw new AmqpRejectAndDontRequeueException(e);
|
||||||
} finally {
|
} finally {
|
||||||
SecurityContextHolder.setContext(oldContext);
|
SecurityContextHolder.setContext(oldContext);
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -19,7 +19,7 @@ import org.eclipse.hawkbit.repository.eventbus.event.DownloadProgressEvent;
|
|||||||
import org.eclipse.hawkbit.repository.exception.EntityAlreadyExistsException;
|
import org.eclipse.hawkbit.repository.exception.EntityAlreadyExistsException;
|
||||||
import org.eclipse.hawkbit.repository.exception.EntityNotFoundException;
|
import org.eclipse.hawkbit.repository.exception.EntityNotFoundException;
|
||||||
import org.eclipse.hawkbit.repository.exception.ToManyAttributeEntriesException;
|
import org.eclipse.hawkbit.repository.exception.ToManyAttributeEntriesException;
|
||||||
import org.eclipse.hawkbit.repository.exception.ToManyStatusEntriesException;
|
import org.eclipse.hawkbit.repository.exception.TooManyStatusEntriesException;
|
||||||
import org.eclipse.hawkbit.repository.model.Action;
|
import org.eclipse.hawkbit.repository.model.Action;
|
||||||
import org.eclipse.hawkbit.repository.model.Action.Status;
|
import org.eclipse.hawkbit.repository.model.Action.Status;
|
||||||
import org.eclipse.hawkbit.repository.model.ActionStatus;
|
import org.eclipse.hawkbit.repository.model.ActionStatus;
|
||||||
@@ -95,7 +95,7 @@ public interface ControllerManagement {
|
|||||||
*
|
*
|
||||||
* @throws EntityAlreadyExistsException
|
* @throws EntityAlreadyExistsException
|
||||||
* if a given entity already exists
|
* if a given entity already exists
|
||||||
* @throws ToManyStatusEntriesException
|
* @throws TooManyStatusEntriesException
|
||||||
* if more than the allowed number of status entries are
|
* if more than the allowed number of status entries are
|
||||||
* inserted
|
* inserted
|
||||||
*/
|
*/
|
||||||
|
|||||||
@@ -18,7 +18,7 @@ import org.eclipse.hawkbit.exception.AbstractServerRtException;
|
|||||||
*
|
*
|
||||||
*
|
*
|
||||||
*/
|
*/
|
||||||
public final class ToManyStatusEntriesException extends AbstractServerRtException {
|
public final class TooManyStatusEntriesException extends AbstractServerRtException {
|
||||||
/**
|
/**
|
||||||
*
|
*
|
||||||
*/
|
*/
|
||||||
@@ -28,7 +28,7 @@ public final class ToManyStatusEntriesException extends AbstractServerRtExceptio
|
|||||||
* Creates a new FileUploadFailedException with
|
* Creates a new FileUploadFailedException with
|
||||||
* {@link SpServerError#SP_REST_BODY_NOT_READABLE} error.
|
* {@link SpServerError#SP_REST_BODY_NOT_READABLE} error.
|
||||||
*/
|
*/
|
||||||
public ToManyStatusEntriesException() {
|
public TooManyStatusEntriesException() {
|
||||||
super(SpServerError.SP_ACTION_STATUS_TO_MANY_ENTRIES);
|
super(SpServerError.SP_ACTION_STATUS_TO_MANY_ENTRIES);
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -36,7 +36,7 @@ public final class ToManyStatusEntriesException extends AbstractServerRtExceptio
|
|||||||
* @param cause
|
* @param cause
|
||||||
* for the exception
|
* for the exception
|
||||||
*/
|
*/
|
||||||
public ToManyStatusEntriesException(final Throwable cause) {
|
public TooManyStatusEntriesException(final Throwable cause) {
|
||||||
super(SpServerError.SP_ACTION_STATUS_TO_MANY_ENTRIES, cause);
|
super(SpServerError.SP_ACTION_STATUS_TO_MANY_ENTRIES, cause);
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -44,7 +44,7 @@ public final class ToManyStatusEntriesException extends AbstractServerRtExceptio
|
|||||||
* @param message
|
* @param message
|
||||||
* of the error
|
* of the error
|
||||||
*/
|
*/
|
||||||
public ToManyStatusEntriesException(final String message) {
|
public TooManyStatusEntriesException(final String message) {
|
||||||
super(message, SpServerError.SP_ACTION_STATUS_TO_MANY_ENTRIES);
|
super(message, SpServerError.SP_ACTION_STATUS_TO_MANY_ENTRIES);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -26,7 +26,7 @@ import org.eclipse.hawkbit.repository.TargetManagement;
|
|||||||
import org.eclipse.hawkbit.repository.TenantConfigurationManagement;
|
import org.eclipse.hawkbit.repository.TenantConfigurationManagement;
|
||||||
import org.eclipse.hawkbit.repository.exception.EntityNotFoundException;
|
import org.eclipse.hawkbit.repository.exception.EntityNotFoundException;
|
||||||
import org.eclipse.hawkbit.repository.exception.ToManyAttributeEntriesException;
|
import org.eclipse.hawkbit.repository.exception.ToManyAttributeEntriesException;
|
||||||
import org.eclipse.hawkbit.repository.exception.ToManyStatusEntriesException;
|
import org.eclipse.hawkbit.repository.exception.TooManyStatusEntriesException;
|
||||||
import org.eclipse.hawkbit.repository.jpa.cache.CacheWriteNotify;
|
import org.eclipse.hawkbit.repository.jpa.cache.CacheWriteNotify;
|
||||||
import org.eclipse.hawkbit.repository.jpa.model.JpaAction;
|
import org.eclipse.hawkbit.repository.jpa.model.JpaAction;
|
||||||
import org.eclipse.hawkbit.repository.jpa.model.JpaActionStatus;
|
import org.eclipse.hawkbit.repository.jpa.model.JpaActionStatus;
|
||||||
@@ -326,7 +326,7 @@ public class JpaControllerManagement implements ControllerManagement {
|
|||||||
LOG_DOS.error(
|
LOG_DOS.error(
|
||||||
"Potential denial of service (DOS) attack identfied. More status entries in the system than permitted ({})!",
|
"Potential denial of service (DOS) attack identfied. More status entries in the system than permitted ({})!",
|
||||||
securityProperties.getDos().getMaxStatusEntriesPerAction());
|
securityProperties.getDos().getMaxStatusEntriesPerAction());
|
||||||
throw new ToManyStatusEntriesException(
|
throw new TooManyStatusEntriesException(
|
||||||
String.valueOf(securityProperties.getDos().getMaxStatusEntriesPerAction()));
|
String.valueOf(securityProperties.getDos().getMaxStatusEntriesPerAction()));
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user