Package org.apache.activemq.artemis.core.server

Class ActiveMQMessageBundle_impl

java.lang.Object

org.apache.activemq.artemis.core.server.ActiveMQMessageBundle_impl

All Implemented Interfaces:

ActiveMQMessageBundle

public class ActiveMQMessageBundle_impl
extends Object
implements ActiveMQMessageBundle

Field Summary

Fields inherited from interface org.apache.activemq.artemis.core.server.ActiveMQMessageBundle

BUNDLE

Constructor Summary

Constructors

Constructor	Description
ActiveMQMessageBundle_impl(Logger logger)

Method Summary

Modifier and Type	Method	Description
IllegalArgumentException	acceptorExists(Integer id)
IllegalArgumentException	acceptorNotExists(Integer id)
IllegalStateException	acceptorUnavailable()
String	activationForServer(ActiveMQServer server)
ActiveMQAddressExistsException	addressAlreadyExists(SimpleString address)
ActiveMQAddressDoesNotExistException	addressDoesNotExist(SimpleString address)
ActiveMQDeleteAddressException	addressHasBindings(SimpleString address)
ActiveMQAddressFullException	addressIsFull(String addressName)
IllegalArgumentException	addressIsNull()
IllegalArgumentException	addressWithNoRoutingType(String address)
ActiveMQIllegalStateException	alreadyHaveReplicationServer()
ActiveMQIllegalStateException	alreadyReplicating(boolean status)
ActiveMQIllegalStateException	backupServerNotInSync()
ActiveMQIllegalStateException	bindingAlreadyExists(String name, String binding)
ActiveMQQueueExistsException	bindingAlreadyExists(Binding binding)
IllegalArgumentException	bindingIdNotSpecified()
ActiveMQInternalErrorException	bindingNotDivert(SimpleString name)
IllegalArgumentException	bindingTypeNotSpecified()
ActiveMQIllegalStateException	bridgeOperationCannotBeExecuted(String bridgeName, String failedOp, BridgeImpl.State currentState)
IllegalArgumentException	cannotConvertToInt()
ActiveMQIllegalStateException	cannotCreateConsumerOnClosedSession(SimpleString queueName)
IllegalArgumentException	cannotCreateDir(String dir)
ActiveMQIllegalStateException	cannotDeleteQueueWithConsumers(SimpleString name, SimpleString queueName, String s)
ActiveMQIllegalStateException	cannotDeleteQueueWithMessages(SimpleString name, SimpleString queueName, long messageCount)
IllegalArgumentException	cannotFindResource(String resourceName)
IllegalStateException	cannotSetMBeanserver()
IllegalStateException	cannotSetSecurityManager()
ActiveMQIOErrorException	cannotWriteToClosedFile(SequentialFile file)
ActiveMQConnectionTimedOutException	clientExited(String remoteAddress, long ttl)
IllegalArgumentException	clusterNameIsNull()
ActiveMQException	connectionDestroyed(String remoteAddress)
IllegalArgumentException	connectionExists(Object id)
ActiveMQRoutingException	connectionRedirected(String connectionRouter, TransportConfiguration connector)
ActiveMQRemoteDisconnectException	connectionRejected(String connectionRouter)
ActiveMQRoutingException	connectionRouterNotReady(String connectionRouter)
ActiveMQInternalErrorException	connectionsClosedByManagement(String ipAddress)
ActiveMQInternalErrorException	connectionsForUserClosedByManagement(String userName)
ActiveMQInternalErrorException	connectionWithIDClosedByManagement(String ID)
ActiveMQInternalErrorException	consumerConnectionsClosedByManagement(String address)
ActiveMQIllegalStateException	consumerDoesntExist(long consumerID)
ActiveMQIllegalStateException	consumerNoReference(Long id, Long messageID, SimpleString name)
String	destroyConnectionWithSessionMetadataClosingConnection(String serverSessionString)	Message used on on ActiveMQServerImpl.destroyConnectionWithSessionMetadata(String, String)
String	destroyConnectionWithSessionMetadataHeader(String key, String value)	Message used on on ActiveMQServerImpl.destroyConnectionWithSessionMetadata(String, String)
String	destroyConnectionWithSessionMetadataNoSessionFound(String key, String value)	Message used on on ActiveMQServerImpl.destroyConnectionWithSessionMetadata(String, String)
ActiveMQDisconnectedException	destroyConnectionWithSessionMetadataSendException(String key, String value)	Exception used on on ActiveMQServerImpl.destroyConnectionWithSessionMetadata(String, String)
ActiveMQIOErrorException	diskBeyondLimit(String usableSpace, String totalSpace, String usage)
ActiveMQDivertDoesNotExistException	divertDoesNotExist(String divert)
ActiveMQInternalErrorException	divertWithNoName()
ActiveMQDuplicateMetaDataException	duplicateMetadata(String key, String data)
ActiveMQIllegalStateException	embeddedWebServerNotFound()
ActiveMQException	embeddedWebServerRestartFailed(Exception e)
ActiveMQTimeoutException	embeddedWebServerRestartTimeout(long timeout)
IllegalArgumentException	emptyOrNull(String name)
IllegalArgumentException	errorCreatingTransformerClass(String transformerClassName, Exception e)
IllegalStateException	failedToBind(String acceptor, String hostPort, Exception e)
ActiveMQIllegalStateException	failedToFindLoginModuleEntry(String entry)
ActiveMQIllegalStateException	failedToLoadRoleFile(String path)
ActiveMQIllegalStateException	failedToLoadSecurityConfig()
ActiveMQIllegalStateException	failedToLoadUserFile(String path)
ActiveMQIllegalStateException	failedToLocateConfigURL()
IllegalArgumentException	failedToParseJson(String json)
IllegalArgumentException	greaterThanMinusOne(String name, Number val)
IllegalArgumentException	greaterThanZero(Integer count)
IllegalArgumentException	greaterThanZero(String name, Number val)
IllegalArgumentException	greaterThanZeroOrMinusOne(String name, Number val)
ActiveMQException	groupWhileStopping()
RuntimeException	idGeneratorStopped()
ActiveMQIncompatibleClientServerException	incompatibleClientServer()
IllegalArgumentException	inRangeOfPositiveInt(String name, Number val)
IllegalArgumentException	inRangeOfPositiveIntThanMinusOne(String name, Number val)
IllegalArgumentException	invalidAddressFullPolicyType(String val)
IllegalArgumentException	invalidConnectionRouterKey(String val)
IllegalArgumentException	invalidDeletionPolicyType(String val)
ActiveMQInvalidFilterExpressionException	invalidFilter(SimpleString filter, Throwable e)
IllegalArgumentException	invalidJournal()
IllegalArgumentException	invalidJournalType(String val)
IllegalArgumentException	invalidJournalType2(JournalType journalType)
IllegalArgumentException	invalidMatch()
IllegalArgumentException	invalidMaxConsumers(String queueName, int value)
IllegalStateException	invalidMaxConsumersUpdate(String queueName, int maxConsumers, int consumers)
IllegalArgumentException	invalidMessageLoadBalancingType(String val)
IllegalArgumentException	invalidNewPriority(Integer period)
ActiveMQIllegalStateException	invalidPageIO()
ActiveMQIllegalStateException	invalidQueueName(SimpleString queueName)
IllegalArgumentException	invalidRoutingType(String val)
IllegalStateException	invalidRoutingTypeDelete(RoutingType routingType, String address)
IllegalArgumentException	invalidRoutingTypeForAddress(RoutingType routingType, String address, Set<RoutingType> supportedRoutingTypes)
IllegalStateException	invalidRoutingTypeUpdate(String queueName, RoutingType routingType, String address, Set<RoutingType> supportedRoutingTypes)
IllegalArgumentException	invalidSlowConsumerPolicyType(String val)
IllegalArgumentException	invalidSlowConsumerThresholdMeasurementUnit(String val)
IllegalArgumentException	invalidType(Object type)
IllegalStateException	invalidWebSocketEncoderType(String webSocketEncoderType)
ActiveMQIllegalStateException	journalsNotInSync()
ActiveMQIllegalStateException	largeMessageNotInitialised()
IllegalArgumentException	lessThanOrEqualToOne(String name, Number val)
ActiveMQTimeoutException	managementBusy()
ActiveMQQueueMaxConsumerLimitReached	maxConsumerLimitReachedForQueue(SimpleString address, SimpleString queueName)
ActiveMQIllegalStateException	messageIdNotAssigned()
IllegalStateException	metersAlreadyRegistered(String resource)
IllegalArgumentException	mustbeBetween(String name, Integer minPriority, Integer maxPriority, Object value)
ActiveMQIllegalStateException	noAddress()
ActiveMQInternalErrorException	noBindingForDivert(SimpleString name)
ActiveMQException	noConfigurationFoundForScaleDown()
IllegalArgumentException	nodeIdNull()
ActiveMQException	noDiscoveryGroupFound(DiscoveryGroupConfiguration dg)
IllegalArgumentException	noGetterMethod(String resourceName)
IllegalArgumentException	noOperation(String operation, Integer length)
IllegalArgumentException	noQueueFound(String otherQueueName)
IllegalArgumentException	noRetention()
ActiveMQNonExistentQueueException	noSuchQueue(SimpleString queueName)
ActiveMQInternalErrorException	notJournalImpl()
IllegalArgumentException	notPercent(String name, Number val)
IllegalArgumentException	notPercentOrMinusOne(String name, Number val)
IllegalArgumentException	nullMatch()
IllegalArgumentException	nullPassword()
IllegalArgumentException	nullUser()
IllegalArgumentException	periodMustGreaterThanZero(Long newPeriod)
IllegalArgumentException	positivePowerOfTwo(String name, Number val)
ActiveMQIllegalStateException	primaryBackupMismatch()
ActiveMQQueueExistsException	queueAlreadyExists(SimpleString queueName, SimpleString addressName)
ActiveMQSecurityException	queueLimitReached(String username, int limit)
IllegalArgumentException	queueNameIsNull()
ActiveMQInvalidTransientQueueUseException	queueSubscriptionBelongsToDifferentAddress(SimpleString queueName)
ActiveMQInvalidTransientQueueUseException	queueSubscriptionBelongsToDifferentFilter(SimpleString queueName)
ActiveMQIllegalStateException	rejectEmptyValidatedUser()
IllegalStateException	replicationFailureRepliTokenNull(String packet, String executorFactory)
ActiveMQReplicationTimeooutException	replicationSynchronizationTimeout(long timeout)
ActiveMQInternalErrorException	replicationUnhandledDataType()
ActiveMQInternalErrorException	replicationUnhandledError(Exception e)
ActiveMQInternalErrorException	replicationUnhandledFileType(ReplicationSyncFileMessage.FileType fileType)
ActiveMQIllegalStateException	replicatorIsNull()
IllegalArgumentException	routeNameIsNull()
String	serverDescribe(String identity, String describe)
ActiveMQIllegalStateException	serverNotBackupServer()
ActiveMQSessionCreationException	serverNotStarted()
ActiveMQSessionCreationException	sessionLimitReached(String username, int limit)
String	threadDump(Thread key, String name, Long id, ThreadGroup threadGroup)
ActiveMQClusterSecurityException	unableToValidateClusterUser(String user)
ActiveMQSecurityException	unableToValidateUser(String remoteAddress, String user, String certMessage)
ActiveMQIllegalStateException	unsupportedHAPolicyConfiguration(Object o)
RuntimeException	unsupportedHAPolicyPropertyType(String invalidHAPolicy)
RuntimeException	unsupportedStorePropertyType()
IllegalArgumentException	userAlreadyExists(String user)
IllegalArgumentException	userDoesNotExist(String user)
ActiveMQSecurityException	userNoPermissions(String username, CheckType checkType, SimpleString address)
ActiveMQSecurityException	userNoPermissionsQueue(String username, CheckType checkType, SimpleString queue, SimpleString address)
IllegalArgumentException	wrongLength(String name, String val, int actualLength, int requiredLength)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ActiveMQMessageBundle_impl

public ActiveMQMessageBundle_impl(Logger logger)

Method Details

activationForServer

public String activationForServer(ActiveMQServer server)

Specified by:

activationForServer in interface ActiveMQMessageBundle

threadDump

public String threadDump(Thread key,
 String name,
 Long id,
 ThreadGroup threadGroup)

Specified by:

threadDump in interface ActiveMQMessageBundle

serverDescribe

public String serverDescribe(String identity,
 String describe)

Specified by:

serverDescribe in interface ActiveMQMessageBundle

connectionsClosedByManagement

public ActiveMQInternalErrorException connectionsClosedByManagement(String ipAddress)

Specified by:

connectionsClosedByManagement in interface ActiveMQMessageBundle

notJournalImpl

public ActiveMQInternalErrorException notJournalImpl()

Specified by:

notJournalImpl in interface ActiveMQMessageBundle

replicationUnhandledError

public ActiveMQInternalErrorException replicationUnhandledError(Exception e)

Specified by:

replicationUnhandledError in interface ActiveMQMessageBundle

replicationUnhandledFileType

public ActiveMQInternalErrorException replicationUnhandledFileType(ReplicationSyncFileMessage.FileType fileType)

Specified by:

replicationUnhandledFileType in interface ActiveMQMessageBundle

replicationUnhandledDataType

public ActiveMQInternalErrorException replicationUnhandledDataType()

Specified by:

replicationUnhandledDataType in interface ActiveMQMessageBundle

noBindingForDivert

public ActiveMQInternalErrorException noBindingForDivert(SimpleString name)

Specified by:

noBindingForDivert in interface ActiveMQMessageBundle

bindingNotDivert

public ActiveMQInternalErrorException bindingNotDivert(SimpleString name)

Specified by:

bindingNotDivert in interface ActiveMQMessageBundle

clientExited

public ActiveMQConnectionTimedOutException clientExited(String remoteAddress,
 long ttl)

Specified by:

clientExited in interface ActiveMQMessageBundle

divertWithNoName

public ActiveMQInternalErrorException divertWithNoName()

Specified by:

divertWithNoName in interface ActiveMQMessageBundle

noSuchQueue

public ActiveMQNonExistentQueueException noSuchQueue(SimpleString queueName)

Specified by:

noSuchQueue in interface ActiveMQMessageBundle

bindingAlreadyExists

public ActiveMQQueueExistsException bindingAlreadyExists(Binding binding)

Specified by:

bindingAlreadyExists in interface ActiveMQMessageBundle

queueAlreadyExists

public ActiveMQQueueExistsException queueAlreadyExists(SimpleString queueName,
 SimpleString addressName)

Specified by:

queueAlreadyExists in interface ActiveMQMessageBundle

invalidFilter

public ActiveMQInvalidFilterExpressionException invalidFilter(SimpleString filter,
 Throwable e)

Specified by:

invalidFilter in interface ActiveMQMessageBundle

messageIdNotAssigned

public ActiveMQIllegalStateException messageIdNotAssigned()

Specified by:

messageIdNotAssigned in interface ActiveMQMessageBundle

journalsNotInSync

public ActiveMQIllegalStateException journalsNotInSync()

Specified by:

journalsNotInSync in interface ActiveMQMessageBundle

serverNotBackupServer

public ActiveMQIllegalStateException serverNotBackupServer()

Specified by:

serverNotBackupServer in interface ActiveMQMessageBundle

alreadyHaveReplicationServer

public ActiveMQIllegalStateException alreadyHaveReplicationServer()

Specified by:

alreadyHaveReplicationServer in interface ActiveMQMessageBundle

cannotDeleteQueueWithConsumers

public ActiveMQIllegalStateException cannotDeleteQueueWithConsumers(SimpleString name,
 SimpleString queueName,
 String s)

Specified by:

cannotDeleteQueueWithConsumers in interface ActiveMQMessageBundle

backupServerNotInSync

public ActiveMQIllegalStateException backupServerNotInSync()

Specified by:

backupServerNotInSync in interface ActiveMQMessageBundle

consumerNoReference

public ActiveMQIllegalStateException consumerNoReference(Long id,
 Long messageID,
 SimpleString name)

Specified by:

consumerNoReference in interface ActiveMQMessageBundle

consumerDoesntExist

public ActiveMQIllegalStateException consumerDoesntExist(long consumerID)

Specified by:

consumerDoesntExist in interface ActiveMQMessageBundle

noAddress

public ActiveMQIllegalStateException noAddress()

Specified by:

noAddress in interface ActiveMQMessageBundle

largeMessageNotInitialised

public ActiveMQIllegalStateException largeMessageNotInitialised()

Specified by:

largeMessageNotInitialised in interface ActiveMQMessageBundle

unableToValidateUser

public ActiveMQSecurityException unableToValidateUser(String remoteAddress,
 String user,
 String certMessage)

Specified by:

unableToValidateUser in interface ActiveMQMessageBundle

userNoPermissions

public ActiveMQSecurityException userNoPermissions(String username,
 CheckType checkType,
 SimpleString address)

Specified by:

userNoPermissions in interface ActiveMQMessageBundle

incompatibleClientServer

public ActiveMQIncompatibleClientServerException incompatibleClientServer()

Specified by:

incompatibleClientServer in interface ActiveMQMessageBundle

serverNotStarted

public ActiveMQSessionCreationException serverNotStarted()

Specified by:

serverNotStarted in interface ActiveMQMessageBundle

duplicateMetadata

public ActiveMQDuplicateMetaDataException duplicateMetadata(String key,
 String data)

Specified by:

duplicateMetadata in interface ActiveMQMessageBundle

invalidType

public IllegalArgumentException invalidType(Object type)

Specified by:

invalidType in interface ActiveMQMessageBundle

emptyOrNull

public IllegalArgumentException emptyOrNull(String name)

Specified by:

emptyOrNull in interface ActiveMQMessageBundle

greaterThanZero

public IllegalArgumentException greaterThanZero(String name,
 Number val)

Specified by:

greaterThanZero in interface ActiveMQMessageBundle

notPercent

public IllegalArgumentException notPercent(String name,
 Number val)

Specified by:

notPercent in interface ActiveMQMessageBundle

greaterThanMinusOne

public IllegalArgumentException greaterThanMinusOne(String name,
 Number val)

Specified by:

greaterThanMinusOne in interface ActiveMQMessageBundle

greaterThanZeroOrMinusOne

public IllegalArgumentException greaterThanZeroOrMinusOne(String name,
 Number val)

Specified by:

greaterThanZeroOrMinusOne in interface ActiveMQMessageBundle

mustbeBetween

public IllegalArgumentException mustbeBetween(String name,
 Integer minPriority,
 Integer maxPriority,
 Object value)

Specified by:

mustbeBetween in interface ActiveMQMessageBundle

invalidJournalType

public IllegalArgumentException invalidJournalType(String val)

Specified by:

invalidJournalType in interface ActiveMQMessageBundle

invalidAddressFullPolicyType

public IllegalArgumentException invalidAddressFullPolicyType(String val)

Specified by:

invalidAddressFullPolicyType in interface ActiveMQMessageBundle

greaterThanZero

public IllegalArgumentException greaterThanZero(Integer count)

Specified by:

greaterThanZero in interface ActiveMQMessageBundle

periodMustGreaterThanZero

public IllegalArgumentException periodMustGreaterThanZero(Long newPeriod)

Specified by:

periodMustGreaterThanZero in interface ActiveMQMessageBundle

invalidNewPriority

public IllegalArgumentException invalidNewPriority(Integer period)

Specified by:

invalidNewPriority in interface ActiveMQMessageBundle

noQueueFound

public IllegalArgumentException noQueueFound(String otherQueueName)

Specified by:

noQueueFound in interface ActiveMQMessageBundle

invalidJournal

public IllegalArgumentException invalidJournal()

Specified by:

invalidJournal in interface ActiveMQMessageBundle

invalidJournalType2

public IllegalArgumentException invalidJournalType2(JournalType journalType)

Specified by:

invalidJournalType2 in interface ActiveMQMessageBundle

cannotCreateDir

public IllegalArgumentException cannotCreateDir(String dir)

Specified by:

cannotCreateDir in interface ActiveMQMessageBundle

cannotConvertToInt

public IllegalArgumentException cannotConvertToInt()

Specified by:

cannotConvertToInt in interface ActiveMQMessageBundle

routeNameIsNull

public IllegalArgumentException routeNameIsNull()

Specified by:

routeNameIsNull in interface ActiveMQMessageBundle

clusterNameIsNull

public IllegalArgumentException clusterNameIsNull()

Specified by:

clusterNameIsNull in interface ActiveMQMessageBundle

addressIsNull

public IllegalArgumentException addressIsNull()

Specified by:

addressIsNull in interface ActiveMQMessageBundle

bindingTypeNotSpecified

public IllegalArgumentException bindingTypeNotSpecified()

Specified by:

bindingTypeNotSpecified in interface ActiveMQMessageBundle

bindingIdNotSpecified

public IllegalArgumentException bindingIdNotSpecified()

Specified by:

bindingIdNotSpecified in interface ActiveMQMessageBundle

connectionExists

public IllegalArgumentException connectionExists(Object id)

Specified by:

connectionExists in interface ActiveMQMessageBundle

acceptorExists

public IllegalArgumentException acceptorExists(Integer id)

Specified by:

acceptorExists in interface ActiveMQMessageBundle

acceptorNotExists

public IllegalArgumentException acceptorNotExists(Integer id)

Specified by:

acceptorNotExists in interface ActiveMQMessageBundle

nodeIdNull

public IllegalArgumentException nodeIdNull()

Specified by:

nodeIdNull in interface ActiveMQMessageBundle

queueNameIsNull

public IllegalArgumentException queueNameIsNull()

Specified by:

queueNameIsNull in interface ActiveMQMessageBundle

cannotFindResource

public IllegalArgumentException cannotFindResource(String resourceName)

Specified by:

cannotFindResource in interface ActiveMQMessageBundle

noGetterMethod

public IllegalArgumentException noGetterMethod(String resourceName)

Specified by:

noGetterMethod in interface ActiveMQMessageBundle

noOperation

public IllegalArgumentException noOperation(String operation,
 Integer length)

Specified by:

noOperation in interface ActiveMQMessageBundle

nullMatch

public IllegalArgumentException nullMatch()

Specified by:

nullMatch in interface ActiveMQMessageBundle

invalidMatch

public IllegalArgumentException invalidMatch()

Specified by:

invalidMatch in interface ActiveMQMessageBundle

nullUser

public IllegalArgumentException nullUser()

Specified by:

nullUser in interface ActiveMQMessageBundle

nullPassword

public IllegalArgumentException nullPassword()

Specified by:

nullPassword in interface ActiveMQMessageBundle

errorCreatingTransformerClass

public IllegalArgumentException errorCreatingTransformerClass(String transformerClassName,
 Exception e)

Specified by:

errorCreatingTransformerClass in interface ActiveMQMessageBundle

destroyConnectionWithSessionMetadataHeader

public String destroyConnectionWithSessionMetadataHeader(String key,
 String value)

Description copied from interface: ActiveMQMessageBundle

Message used on on ActiveMQServerImpl.destroyConnectionWithSessionMetadata(String, String)

Specified by:

destroyConnectionWithSessionMetadataHeader in interface ActiveMQMessageBundle

destroyConnectionWithSessionMetadataClosingConnection

public String destroyConnectionWithSessionMetadataClosingConnection(String serverSessionString)

Description copied from interface: ActiveMQMessageBundle

Message used on on ActiveMQServerImpl.destroyConnectionWithSessionMetadata(String, String)

Specified by:

destroyConnectionWithSessionMetadataClosingConnection in interface ActiveMQMessageBundle

destroyConnectionWithSessionMetadataSendException

public ActiveMQDisconnectedException destroyConnectionWithSessionMetadataSendException(String key,
 String value)

Description copied from interface: ActiveMQMessageBundle

Exception used on on ActiveMQServerImpl.destroyConnectionWithSessionMetadata(String, String)

Specified by:

destroyConnectionWithSessionMetadataSendException in interface ActiveMQMessageBundle

destroyConnectionWithSessionMetadataNoSessionFound

public String destroyConnectionWithSessionMetadataNoSessionFound(String key,
 String value)

Description copied from interface: ActiveMQMessageBundle

Message used on on ActiveMQServerImpl.destroyConnectionWithSessionMetadata(String, String)

Specified by:

destroyConnectionWithSessionMetadataNoSessionFound in interface ActiveMQMessageBundle

invalidPageIO

public ActiveMQIllegalStateException invalidPageIO()

Specified by:

invalidPageIO in interface ActiveMQMessageBundle

noDiscoveryGroupFound

public ActiveMQException noDiscoveryGroupFound(DiscoveryGroupConfiguration dg)

Specified by:

noDiscoveryGroupFound in interface ActiveMQMessageBundle

queueSubscriptionBelongsToDifferentAddress

public ActiveMQInvalidTransientQueueUseException queueSubscriptionBelongsToDifferentAddress(SimpleString queueName)

Specified by:

queueSubscriptionBelongsToDifferentAddress in interface ActiveMQMessageBundle

queueSubscriptionBelongsToDifferentFilter

public ActiveMQInvalidTransientQueueUseException queueSubscriptionBelongsToDifferentFilter(SimpleString queueName)

Specified by:

queueSubscriptionBelongsToDifferentFilter in interface ActiveMQMessageBundle

unableToValidateClusterUser

public ActiveMQClusterSecurityException unableToValidateClusterUser(String user)

Specified by:

unableToValidateClusterUser in interface ActiveMQMessageBundle

addressIsFull

public ActiveMQAddressFullException addressIsFull(String addressName)

Specified by:

addressIsFull in interface ActiveMQMessageBundle

noConfigurationFoundForScaleDown

public ActiveMQException noConfigurationFoundForScaleDown()

Specified by:

noConfigurationFoundForScaleDown in interface ActiveMQMessageBundle

groupWhileStopping

public ActiveMQException groupWhileStopping()

Specified by:

groupWhileStopping in interface ActiveMQMessageBundle

invalidSlowConsumerPolicyType

public IllegalArgumentException invalidSlowConsumerPolicyType(String val)

Specified by:

invalidSlowConsumerPolicyType in interface ActiveMQMessageBundle

consumerConnectionsClosedByManagement

public ActiveMQInternalErrorException consumerConnectionsClosedByManagement(String address)

Specified by:

consumerConnectionsClosedByManagement in interface ActiveMQMessageBundle

connectionsForUserClosedByManagement

public ActiveMQInternalErrorException connectionsForUserClosedByManagement(String userName)

Specified by:

connectionsForUserClosedByManagement in interface ActiveMQMessageBundle

unsupportedHAPolicyConfiguration

public ActiveMQIllegalStateException unsupportedHAPolicyConfiguration(Object o)

Specified by:

unsupportedHAPolicyConfiguration in interface ActiveMQMessageBundle

sessionLimitReached

public ActiveMQSessionCreationException sessionLimitReached(String username,
 int limit)

Specified by:

sessionLimitReached in interface ActiveMQMessageBundle

queueLimitReached

public ActiveMQSecurityException queueLimitReached(String username,
 int limit)

Specified by:

queueLimitReached in interface ActiveMQMessageBundle

cannotSetMBeanserver

public IllegalStateException cannotSetMBeanserver()

Specified by:

cannotSetMBeanserver in interface ActiveMQMessageBundle

invalidMessageLoadBalancingType

public IllegalArgumentException invalidMessageLoadBalancingType(String val)

Specified by:

invalidMessageLoadBalancingType in interface ActiveMQMessageBundle

replicationSynchronizationTimeout

public ActiveMQReplicationTimeooutException replicationSynchronizationTimeout(long timeout)

Specified by:

replicationSynchronizationTimeout in interface ActiveMQMessageBundle

primaryBackupMismatch

public ActiveMQIllegalStateException primaryBackupMismatch()

Specified by:

primaryBackupMismatch in interface ActiveMQMessageBundle

acceptorUnavailable

public IllegalStateException acceptorUnavailable()

Specified by:

acceptorUnavailable in interface ActiveMQMessageBundle

replicatorIsNull

public ActiveMQIllegalStateException replicatorIsNull()

Specified by:

replicatorIsNull in interface ActiveMQMessageBundle

diskBeyondLimit

public ActiveMQIOErrorException diskBeyondLimit(String usableSpace,
 String totalSpace,
 String usage)

Specified by:

diskBeyondLimit in interface ActiveMQMessageBundle

connectionWithIDClosedByManagement

public ActiveMQInternalErrorException connectionWithIDClosedByManagement(String ID)

Specified by:

connectionWithIDClosedByManagement in interface ActiveMQMessageBundle

maxConsumerLimitReachedForQueue

public ActiveMQQueueMaxConsumerLimitReached maxConsumerLimitReachedForQueue(SimpleString address,
 SimpleString queueName)

Specified by:

maxConsumerLimitReachedForQueue in interface ActiveMQMessageBundle

addressDoesNotExist

public ActiveMQAddressDoesNotExistException addressDoesNotExist(SimpleString address)

Specified by:

addressDoesNotExist in interface ActiveMQMessageBundle

addressAlreadyExists

public ActiveMQAddressExistsException addressAlreadyExists(SimpleString address)

Specified by:

addressAlreadyExists in interface ActiveMQMessageBundle

addressHasBindings

public ActiveMQDeleteAddressException addressHasBindings(SimpleString address)

Specified by:

addressHasBindings in interface ActiveMQMessageBundle

invalidMaxConsumers

public IllegalArgumentException invalidMaxConsumers(String queueName,
 int value)

Specified by:

invalidMaxConsumers in interface ActiveMQMessageBundle

invalidRoutingTypeForAddress

public IllegalArgumentException invalidRoutingTypeForAddress(RoutingType routingType,
 String address,
 Set<RoutingType> supportedRoutingTypes)

Specified by:

invalidRoutingTypeForAddress in interface ActiveMQMessageBundle

invalidRoutingType

public IllegalArgumentException invalidRoutingType(String val)

Specified by:

invalidRoutingType in interface ActiveMQMessageBundle

invalidRoutingTypeDelete

public IllegalStateException invalidRoutingTypeDelete(RoutingType routingType,
 String address)

Specified by:

invalidRoutingTypeDelete in interface ActiveMQMessageBundle

invalidMaxConsumersUpdate

public IllegalStateException invalidMaxConsumersUpdate(String queueName,
 int maxConsumers,
 int consumers)

Specified by:

invalidMaxConsumersUpdate in interface ActiveMQMessageBundle

invalidRoutingTypeUpdate

public IllegalStateException invalidRoutingTypeUpdate(String queueName,
 RoutingType routingType,
 String address,
 Set<RoutingType> supportedRoutingTypes)

Specified by:

invalidRoutingTypeUpdate in interface ActiveMQMessageBundle

invalidDeletionPolicyType

public IllegalArgumentException invalidDeletionPolicyType(String val)

Specified by:

invalidDeletionPolicyType in interface ActiveMQMessageBundle

userNoPermissionsQueue

public ActiveMQSecurityException userNoPermissionsQueue(String username,
 CheckType checkType,
 SimpleString queue,
 SimpleString address)

Specified by:

userNoPermissionsQueue in interface ActiveMQMessageBundle

notPercentOrMinusOne

public IllegalArgumentException notPercentOrMinusOne(String name,
 Number val)

Specified by:

notPercentOrMinusOne in interface ActiveMQMessageBundle

cannotDeleteQueueWithMessages

public ActiveMQIllegalStateException cannotDeleteQueueWithMessages(SimpleString name,
 SimpleString queueName,
 long messageCount)

Specified by:

cannotDeleteQueueWithMessages in interface ActiveMQMessageBundle

invalidQueueName

public ActiveMQIllegalStateException invalidQueueName(SimpleString queueName)

Specified by:

invalidQueueName in interface ActiveMQMessageBundle

cannotWriteToClosedFile

public ActiveMQIOErrorException cannotWriteToClosedFile(SequentialFile file)

Specified by:

cannotWriteToClosedFile in interface ActiveMQMessageBundle

failedToLocateConfigURL

public ActiveMQIllegalStateException failedToLocateConfigURL()

Specified by:

failedToLocateConfigURL in interface ActiveMQMessageBundle

failedToLoadSecurityConfig

public ActiveMQIllegalStateException failedToLoadSecurityConfig()

Specified by:

failedToLoadSecurityConfig in interface ActiveMQMessageBundle

failedToLoadUserFile

public ActiveMQIllegalStateException failedToLoadUserFile(String path)

Specified by:

failedToLoadUserFile in interface ActiveMQMessageBundle

failedToLoadRoleFile

public ActiveMQIllegalStateException failedToLoadRoleFile(String path)

Specified by:

failedToLoadRoleFile in interface ActiveMQMessageBundle

failedToFindLoginModuleEntry

public ActiveMQIllegalStateException failedToFindLoginModuleEntry(String entry)

Specified by:

failedToFindLoginModuleEntry in interface ActiveMQMessageBundle

userAlreadyExists

public IllegalArgumentException userAlreadyExists(String user)

Specified by:

userAlreadyExists in interface ActiveMQMessageBundle

userDoesNotExist

public IllegalArgumentException userDoesNotExist(String user)

Specified by:

userDoesNotExist in interface ActiveMQMessageBundle

rejectEmptyValidatedUser

public ActiveMQIllegalStateException rejectEmptyValidatedUser()

Specified by:

rejectEmptyValidatedUser in interface ActiveMQMessageBundle

inRangeOfPositiveInt

public IllegalArgumentException inRangeOfPositiveInt(String name,
 Number val)

Specified by:

inRangeOfPositiveInt in interface ActiveMQMessageBundle

inRangeOfPositiveIntThanMinusOne

public IllegalArgumentException inRangeOfPositiveIntThanMinusOne(String name,
 Number val)

Specified by:

inRangeOfPositiveIntThanMinusOne in interface ActiveMQMessageBundle

lessThanOrEqualToOne

public IllegalArgumentException lessThanOrEqualToOne(String name,
 Number val)

Specified by:

lessThanOrEqualToOne in interface ActiveMQMessageBundle

failedToParseJson

public IllegalArgumentException failedToParseJson(String json)

Specified by:

failedToParseJson in interface ActiveMQMessageBundle

failedToBind

public IllegalStateException failedToBind(String acceptor,
 String hostPort,
 Exception e)

Specified by:

failedToBind in interface ActiveMQMessageBundle

divertDoesNotExist

public ActiveMQDivertDoesNotExistException divertDoesNotExist(String divert)

Specified by:

divertDoesNotExist in interface ActiveMQMessageBundle

cannotCreateConsumerOnClosedSession

public ActiveMQIllegalStateException cannotCreateConsumerOnClosedSession(SimpleString queueName)

Specified by:

cannotCreateConsumerOnClosedSession in interface ActiveMQMessageBundle

cannotSetSecurityManager

public IllegalStateException cannotSetSecurityManager()

Specified by:

cannotSetSecurityManager in interface ActiveMQMessageBundle

invalidSlowConsumerThresholdMeasurementUnit

public IllegalArgumentException invalidSlowConsumerThresholdMeasurementUnit(String val)

Specified by:

invalidSlowConsumerThresholdMeasurementUnit in interface ActiveMQMessageBundle

bindingAlreadyExists

public ActiveMQIllegalStateException bindingAlreadyExists(String name,
 String binding)

Specified by:

bindingAlreadyExists in interface ActiveMQMessageBundle

invalidConnectionRouterKey

public IllegalArgumentException invalidConnectionRouterKey(String val)

Specified by:

invalidConnectionRouterKey in interface ActiveMQMessageBundle

connectionRedirected

public ActiveMQRoutingException connectionRedirected(String connectionRouter,
 TransportConfiguration connector)

Specified by:

connectionRedirected in interface ActiveMQMessageBundle

connectionRouterNotReady

public ActiveMQRoutingException connectionRouterNotReady(String connectionRouter)

Specified by:

connectionRouterNotReady in interface ActiveMQMessageBundle

noRetention

public IllegalArgumentException noRetention()

Specified by:

noRetention in interface ActiveMQMessageBundle

connectionRejected

public ActiveMQRemoteDisconnectException connectionRejected(String connectionRouter)

Specified by:

connectionRejected in interface ActiveMQMessageBundle

embeddedWebServerNotFound

public ActiveMQIllegalStateException embeddedWebServerNotFound()

Specified by:

embeddedWebServerNotFound in interface ActiveMQMessageBundle

embeddedWebServerRestartTimeout

public ActiveMQTimeoutException embeddedWebServerRestartTimeout(long timeout)

Specified by:

embeddedWebServerRestartTimeout in interface ActiveMQMessageBundle

embeddedWebServerRestartFailed

public ActiveMQException embeddedWebServerRestartFailed(Exception e)

Specified by:

embeddedWebServerRestartFailed in interface ActiveMQMessageBundle

metersAlreadyRegistered

public IllegalStateException metersAlreadyRegistered(String resource)

Specified by:

metersAlreadyRegistered in interface ActiveMQMessageBundle

managementBusy

public ActiveMQTimeoutException managementBusy()

Specified by:

managementBusy in interface ActiveMQMessageBundle

addressWithNoRoutingType

public IllegalArgumentException addressWithNoRoutingType(String address)

Specified by:

addressWithNoRoutingType in interface ActiveMQMessageBundle

invalidWebSocketEncoderType

public IllegalStateException invalidWebSocketEncoderType(String webSocketEncoderType)

Specified by:

invalidWebSocketEncoderType in interface ActiveMQMessageBundle

unsupportedStorePropertyType

public RuntimeException unsupportedStorePropertyType()

Specified by:

unsupportedStorePropertyType in interface ActiveMQMessageBundle

connectionDestroyed

public ActiveMQException connectionDestroyed(String remoteAddress)

Specified by:

connectionDestroyed in interface ActiveMQMessageBundle

wrongLength

public IllegalArgumentException wrongLength(String name,
 String val,
 int actualLength,
 int requiredLength)

Specified by:

wrongLength in interface ActiveMQMessageBundle

unsupportedHAPolicyPropertyType

public RuntimeException unsupportedHAPolicyPropertyType(String invalidHAPolicy)

Specified by:

unsupportedHAPolicyPropertyType in interface ActiveMQMessageBundle

replicationFailureRepliTokenNull

public IllegalStateException replicationFailureRepliTokenNull(String packet,
 String executorFactory)

Specified by:

replicationFailureRepliTokenNull in interface ActiveMQMessageBundle

alreadyReplicating

public ActiveMQIllegalStateException alreadyReplicating(boolean status)

Specified by:

alreadyReplicating in interface ActiveMQMessageBundle

bridgeOperationCannotBeExecuted

public ActiveMQIllegalStateException bridgeOperationCannotBeExecuted(String bridgeName,
 String failedOp,
 BridgeImpl.State currentState)

Specified by:

bridgeOperationCannotBeExecuted in interface ActiveMQMessageBundle

positivePowerOfTwo

public IllegalArgumentException positivePowerOfTwo(String name,
 Number val)

Specified by:

positivePowerOfTwo in interface ActiveMQMessageBundle

idGeneratorStopped

public RuntimeException idGeneratorStopped()

Specified by:

idGeneratorStopped in interface ActiveMQMessageBundle