http://git-wip-us.apache.org/repos/asf/activemq-6/blob/034adfbf/activemq-server/src/main/java/org/apache/activemq/core/server/ActiveMQServerLogger.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/server/ActiveMQServerLogger.java b/activemq-server/src/main/java/org/apache/activemq/core/server/ActiveMQServerLogger.java new file mode 100644 index 0000000..150628b --- /dev/null +++ b/activemq-server/src/main/java/org/apache/activemq/core/server/ActiveMQServerLogger.java @@ -0,0 +1,1366 @@ +/* + * Copyright 2005-2014 Red Hat, Inc. + * Red Hat licenses this file to you under the Apache License, version + * 2.0 (the "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * http://www.apache.org/licenses/LICENSE-2.0 + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or + * implied. See the License for the specific language governing + * permissions and limitations under the License. + */ + +package org.apache.activemq.core.server; + +/** + * @author <a href="mailto:andy.tay...@jboss.org";>Andy Taylor</a> + * 3/8/12 + * + * Logger Code 22 + * + * each message id must be 6 digits long starting with 10, the 3rd digit donates the level so + * + * INF0 1 + * WARN 2 + * DEBUG 3 + * ERROR 4 + * TRACE 5 + * FATAL 6 + * + * so an INFO message would be 101000 to 101999 + */ + +import javax.transaction.xa.Xid; +import java.io.File; +import java.net.SocketAddress; +import java.net.URI; +import java.util.List; +import java.util.concurrent.Executor; +import java.util.concurrent.ExecutorService; + +import io.netty.channel.Channel; +import org.apache.activemq.api.core.ActiveMQExceptionType; +import org.apache.activemq.api.core.Pair; +import org.apache.activemq.api.core.SimpleString; +import org.apache.activemq.core.client.impl.ServerLocatorInternal; +import org.apache.activemq.core.config.Configuration; +import org.apache.activemq.core.journal.IOAsyncTask; +import org.apache.activemq.core.journal.SequentialFile; +import org.apache.activemq.core.journal.impl.JournalFile; +import org.apache.activemq.core.paging.cursor.PagePosition; +import org.apache.activemq.core.paging.cursor.PageSubscription; +import org.apache.activemq.core.persistence.OperationContext; +import org.apache.activemq.core.protocol.core.Packet; +import org.apache.activemq.core.protocol.core.impl.wireformat.BackupReplicationStartFailedMessage; +import org.apache.activemq.core.server.cluster.Bridge; +import org.apache.activemq.core.server.cluster.impl.BridgeImpl; +import org.apache.activemq.core.server.cluster.impl.ClusterConnectionImpl; +import org.apache.activemq.core.server.impl.ActiveMQServerImpl; +import org.apache.activemq.core.server.impl.ServerSessionImpl; +import org.apache.activemq.core.server.management.Notification; +import org.apache.activemq.utils.FutureLatch; +import org.jboss.logging.BasicLogger; +import org.jboss.logging.annotations.Cause; +import org.jboss.logging.annotations.LogMessage; +import org.jboss.logging.Logger; +import org.jboss.logging.annotations.Message; +import org.jboss.logging.annotations.MessageLogger; +import org.w3c.dom.Node; + +@MessageLogger(projectCode = "AMQ") +public interface ActiveMQServerLogger extends BasicLogger +{ + /** + * The default logger. + */ + ActiveMQServerLogger LOGGER = Logger.getMessageLogger(ActiveMQServerLogger.class, ActiveMQServerLogger.class.getPackage().getName()); + + @LogMessage(level = Logger.Level.INFO) + @Message(id = 221000, value = "{0} server is starting with configuration {1}", format = Message.Format.MESSAGE_FORMAT) + void serverStarting(String type, Configuration configuration); + + @LogMessage(level = Logger.Level.INFO) + @Message(id = 221001, value = "ActiveMQ Server version {0} [{1}] {2}", format = Message.Format.MESSAGE_FORMAT) + void serverStarted(String fullVersion, SimpleString nodeId, String identity); + + @LogMessage(level = Logger.Level.INFO) + @Message(id = 221002, value = "ActiveMQ Server version {0} [{1}] stopped", format = Message.Format.MESSAGE_FORMAT) + void serverStopped(String version, SimpleString nodeId); + + @LogMessage(level = Logger.Level.INFO) + @Message(id = 221003, value = "trying to deploy queue {0}", format = Message.Format.MESSAGE_FORMAT) + void deployQueue(SimpleString queueName); + + @LogMessage(level = Logger.Level.INFO) + @Message(id = 221004, value = "{0}", format = Message.Format.MESSAGE_FORMAT) + void dumpServerInfo(String serverInfo); + + @LogMessage(level = Logger.Level.INFO) + @Message(id = 221005, value = "Deleting pending large message as it was not completed: {0}", + format = Message.Format.MESSAGE_FORMAT) + void deletingPendingMessage(Pair<Long, Long> msgToDelete); + + @LogMessage(level = Logger.Level.INFO) + @Message(id = 221006, value = "Waiting to obtain live lock", format = Message.Format.MESSAGE_FORMAT) + void awaitingLiveLock(); + + @LogMessage(level = Logger.Level.INFO) + @Message(id = 221007, value = "Server is now live", format = Message.Format.MESSAGE_FORMAT) + void serverIsLive(); + + @LogMessage(level = Logger.Level.INFO) + @Message(id = 221008, value = "live server wants to restart, restarting server in backup", format = Message.Format.MESSAGE_FORMAT) + void awaitFailBack(); + + @LogMessage(level = Logger.Level.INFO) + @Message(id = 221109, value = "ActiveMQ Backup Server version {0} [{1}] started, waiting live to fail before it gets active", + format = Message.Format.MESSAGE_FORMAT) + void backupServerStarted(String version, SimpleString nodeID); + + @LogMessage(level = Logger.Level.INFO) + @Message(id = 221010, value = "Backup Server is now live", format = Message.Format.MESSAGE_FORMAT) + void backupServerIsLive(); + + @LogMessage(level = Logger.Level.INFO) + @Message(id = 221011, value = "Server {0} is now live", format = Message.Format.MESSAGE_FORMAT) + void serverIsLive(String identity); + + @LogMessage(level = Logger.Level.INFO) + @Message(id = 221012, value = "Using AIO Journal", format = Message.Format.MESSAGE_FORMAT) + void journalUseAIO(); + + @LogMessage(level = Logger.Level.INFO) + @Message(id = 221013, value = "Using NIO Journal", format = Message.Format.MESSAGE_FORMAT) + void journalUseNIO(); + + @LogMessage(level = Logger.Level.INFO) + @Message(id = 221014, value = "{0}% loaded", format = Message.Format.MESSAGE_FORMAT) + void percentLoaded(Long percent); + + @LogMessage(level = Logger.Level.INFO) + @Message(id = 221015, value = "Can not find queue {0} while reloading ACKNOWLEDGE_CURSOR, deleting record now", + format = Message.Format.MESSAGE_FORMAT) + void journalCannotFindQueueReloading(Long queueID); + + @LogMessage(level = Logger.Level.INFO) + @Message(id = 221016, + value = "Can not find queue {0} while reloading PAGE_CURSOR_COUNTER_VALUE, deleting record now", + format = Message.Format.MESSAGE_FORMAT) + void journalCannotFindQueueReloadingPage(Long queueID); + + @LogMessage(level = Logger.Level.INFO) + @Message(id = 221017, value = "Can not find queue {0} while reloading PAGE_CURSOR_COUNTER_INC, deleting record now", + format = Message.Format.MESSAGE_FORMAT) + void journalCannotFindQueueReloadingPageCursor(Long queueID); + + @LogMessage(level = Logger.Level.INFO) + @Message(id = 221018, value = "Large message: {0} did not have any associated reference, file will be deleted", + format = Message.Format.MESSAGE_FORMAT) + void largeMessageWithNoRef(Long messageID); + + @LogMessage(level = Logger.Level.INFO) + @Message(id = 221019, value = "Deleting unreferenced message id={0} from the journal", format = Message.Format.MESSAGE_FORMAT) + void journalUnreferencedMessage(Long messageID); + + @LogMessage(level = Logger.Level.INFO) + @Message(id = 221020, value = "Started Netty Acceptor version {0} {1}:{2,number,#}", format = Message.Format.MESSAGE_FORMAT) + void startedNettyAcceptor(String id, String host, Integer port); + + @LogMessage(level = Logger.Level.INFO) + @Message(id = 221021, value = "failed to remove connection", format = Message.Format.MESSAGE_FORMAT) + void errorRemovingConnection(); + + @LogMessage(level = Logger.Level.INFO) + @Message(id = 221022, value = "unable to start connector service: {0}", format = Message.Format.MESSAGE_FORMAT) + void errorStartingConnectorService(@Cause Throwable e, String name); + + @LogMessage(level = Logger.Level.INFO) + @Message(id = 221023, value = "unable to stop connector service: {0}", format = Message.Format.MESSAGE_FORMAT) + void errorStoppingConnectorService(@Cause Throwable e, String name); + + @LogMessage(level = Logger.Level.INFO) + @Message(id = 221024, value = "Backup server {0} is synchronized with live-server.", format = Message.Format.MESSAGE_FORMAT) + void backupServerSynched(ActiveMQServerImpl server); + + @LogMessage(level = Logger.Level.INFO) + @Message(id = 221025, value = "Replication: sending {0} (size={1}) to backup. {2}", format = Message.Format.MESSAGE_FORMAT) + void journalSynch(JournalFile jf, Long size, SequentialFile file); + + @LogMessage(level = Logger.Level.INFO) + @Message( + id = 221026, + value = "Bridge {0} connected to fowardingAddress={1}. {2} does not have any bindings what means messages will be ignored until a binding is created.", + format = Message.Format.MESSAGE_FORMAT) + void bridgeNoBindings(SimpleString name, SimpleString forwardingAddress, SimpleString address); + + @LogMessage(level = Logger.Level.INFO) + @Message(id = 221027, value = "Bridge {0} is connected", format = Message.Format.MESSAGE_FORMAT) + void bridgeConnected(BridgeImpl name); + + @LogMessage(level = Logger.Level.INFO) + @Message(id = 221028, value = "Bridge is stopping, will not retry", format = Message.Format.MESSAGE_FORMAT) + void bridgeStopping(); + + @LogMessage(level = Logger.Level.INFO) + @Message(id = 221029, value = "stopped bridge {0}", format = Message.Format.MESSAGE_FORMAT) + void bridgeStopped(SimpleString name); + + @LogMessage(level = Logger.Level.INFO) + @Message(id = 221030, value = "paused bridge {0}", format = Message.Format.MESSAGE_FORMAT) + void bridgePaused(SimpleString name); + + @LogMessage(level = Logger.Level.INFO) + @Message(id = 221031, value = "backup announced", format = Message.Format.MESSAGE_FORMAT) + void backupAnnounced(); + + @LogMessage(level = Logger.Level.INFO) + @Message(id = 221032, value = "Waiting to become backup node", format = Message.Format.MESSAGE_FORMAT) + void waitingToBecomeBackup(); + + @LogMessage(level = Logger.Level.INFO) + @Message(id = 221033, value = "** got backup lock", format = Message.Format.MESSAGE_FORMAT) + void gotBackupLock(); + + @LogMessage(level = Logger.Level.INFO) + @Message(id = 221034, value = "Waiting {0} to obtain live lock", format = Message.Format.MESSAGE_FORMAT) + void waitingToObtainLiveLock(String timeoutMessage); + + @LogMessage(level = Logger.Level.INFO) + @Message(id = 221035, value = "Live Server Obtained live lock", format = Message.Format.MESSAGE_FORMAT) + void obtainedLiveLock(); + + @LogMessage(level = Logger.Level.INFO) + @Message(id = 221036, value = "Message with duplicate ID {0} was already set at {1}. Move from {2} being ignored and message removed from {3}", + format = Message.Format.MESSAGE_FORMAT) + void messageWithDuplicateID(Object duplicateProperty, SimpleString toAddress, SimpleString address, SimpleString simpleString); + + @LogMessage(level = Logger.Level.INFO) + @Message(id = 221037, value = "{0} to become ''live''", format = Message.Format.MESSAGE_FORMAT) + void becomingLive(ActiveMQServer server); + + @LogMessage(level = Logger.Level.INFO) + @Message(id = 221038, value = "Configuration option ''{0}'' is deprecated. Consult the manual for details.", + format = Message.Format.MESSAGE_FORMAT) + void deprecatedConfigurationOption(String deprecatedOption); + + @LogMessage(level = Logger.Level.INFO) + @Message(id = 221039, value = "Restarting as Replicating backup server after live restart", + format = Message.Format.MESSAGE_FORMAT) + void restartingReplicatedBackupAfterFailback(); + + @LogMessage(level = Logger.Level.INFO) + @Message(id = 221040, value = "Remote group coordinators did not start yet", format = Message.Format.MESSAGE_FORMAT) + void remoteGroupCoordinatorsNotStarted(); + + @LogMessage(level = Logger.Level.INFO) + @Message(id = 221041, value = "Cannot find queue {0} while reloading PAGE_CURSOR_COMPLETE, deleting record now", + format = Message.Format.MESSAGE_FORMAT) + void cantFindQueueOnPageComplete(long queueID); + + @LogMessage(level = Logger.Level.INFO) + @Message(id = 221042, + value = "Bridge {0} timed out waiting for the completion of {1} messages, we will just shutdown the bridge after 10 seconds wait", + format = Message.Format.MESSAGE_FORMAT) + void timedOutWaitingCompletions(String bridgeName, long numberOfMessages); + + @LogMessage(level = Logger.Level.INFO) + @Message(id = 221043, value = "Adding protocol support {0}", format = Message.Format.MESSAGE_FORMAT) + void addingProtocolSupport(String protocolKey); + + @LogMessage(level = Logger.Level.INFO) + @Message(id = 221045, value = "libaio is not available, switching the configuration into NIO", format = Message.Format.MESSAGE_FORMAT) + void switchingNIO(); + + @LogMessage(level = Logger.Level.INFO) + @Message(id = 221046, value = "Unblocking message production on address ''{0}''; size is currently: {1} bytes; max-size-bytes: {2}", format = Message.Format.MESSAGE_FORMAT) + void unblockingMessageProduction(SimpleString addressName, long currentSize, long maxSize); + + @LogMessage(level = Logger.Level.INFO) + @Message(id = 221047, value = "Backup Server has scaled down to live server", format = Message.Format.MESSAGE_FORMAT) + void backupServerScaledDown(); + + @LogMessage(level = Logger.Level.INFO) + @Message(id = 221048, value = "Consumer {0}:{1} attached to queue ''{2}'' from {3} identified as ''slow.'' Expected consumption rate: {4} msgs/second; actual consumption rate: {5} msgs/second.", format = Message.Format.MESSAGE_FORMAT) + void slowConsumerDetected(String sessionID, long consumerID, String queueName, String remoteAddress, float slowConsumerThreshold, float consumerRate); + + @LogMessage(level = Logger.Level.INFO) + @Message(id = 221049, value = "Activating Replica for node: {0}", format = Message.Format.MESSAGE_FORMAT) + void activatingReplica(SimpleString nodeID); + + @LogMessage(level = Logger.Level.INFO) + @Message(id = 221050, value = "Activating Shared Store Slave", format = Message.Format.MESSAGE_FORMAT) + void activatingSharedStoreSlave(); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222000, value = "ActiveMQServer is being finalized and has not been stopped. Please remember to stop the server before letting it go out of scope", + format = Message.Format.MESSAGE_FORMAT) + void serverFinalisedWIthoutBeingSTopped(); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222001, value = "Error closing sessions while stopping server", format = Message.Format.MESSAGE_FORMAT) + void errorClosingSessionsWhileStoppingServer(@Cause Exception e); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222002, value = "Timed out waiting for pool to terminate {0}. Interrupting all its threads!", format = Message.Format.MESSAGE_FORMAT) + void timedOutStoppingThreadpool(ExecutorService service); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222003, value = "Must specify a name for each divert. This one will not be deployed.", format = Message.Format.MESSAGE_FORMAT) + void divertWithNoName(); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222004, value = "Must specify an address for each divert. This one will not be deployed.", format = Message.Format.MESSAGE_FORMAT) + void divertWithNoAddress(); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222005, value = "Must specify a forwarding address for each divert. This one will not be deployed.", format = Message.Format.MESSAGE_FORMAT) + void divertWithNoForwardingAddress(); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222006, value = "Binding already exists with name {0}, divert will not be deployed", format = Message.Format.MESSAGE_FORMAT) + void divertBindingNotExists(SimpleString bindingName); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222007, value = "Security risk! ActiveMQ is running with the default cluster admin user and default password. Please see the cluster chapter in the ActiveMQ User Guide for instructions on how to change this.", format = Message.Format.MESSAGE_FORMAT) + void clusterSecurityRisk(); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222008, value = "unable to restart server, please kill and restart manually", format = Message.Format.MESSAGE_FORMAT) + void serverRestartWarning(); + + @LogMessage(level = Logger.Level.WARN) + void serverRestartWarning(@Cause Exception e); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222009, value = "Unable to announce backup for replication. Trying to stop the server.", format = Message.Format.MESSAGE_FORMAT) + void replicationStartProblem(@Cause Exception e); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222010, value = "Critical IO Error, shutting down the server. file={1}, message={0}", format = Message.Format.MESSAGE_FORMAT) + void ioCriticalIOError(String message, String file, @Cause Throwable code); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222011, value = "Error stopping server", format = Message.Format.MESSAGE_FORMAT) + void errorStoppingServer(@Cause Exception e); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222012, value = "Timed out waiting for backup activation to exit", format = Message.Format.MESSAGE_FORMAT) + void backupActivationProblem(); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222013, value = "Error when trying to start replication", format = Message.Format.MESSAGE_FORMAT) + void errorStartingReplication(@Cause Exception e); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222014, value = "Error when trying to stop replication", format = Message.Format.MESSAGE_FORMAT) + void errorStoppingReplication(@Cause Exception e); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222015, value = "{0}", format = Message.Format.MESSAGE_FORMAT) + void warn(String message); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222016, value = "Cannot deploy a connector with no name specified.", format = Message.Format.MESSAGE_FORMAT) + void connectorWithNoName(); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222017, value = "There is already a connector with name {0} deployed. This one will not be deployed.", format = Message.Format.MESSAGE_FORMAT) + void connectorAlreadyDeployed(String name); + + @LogMessage(level = Logger.Level.WARN) + @Message( + id = 222018, + value = "AIO was not located on this platform, it will fall back to using pure Java NIO. If your platform is Linux, install LibAIO to enable the AIO journal", + format = Message.Format.MESSAGE_FORMAT) + void AIONotFound(); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222019, value = "There is already a discovery group with name {0} deployed. This one will not be deployed.", format = Message.Format.MESSAGE_FORMAT) + void discoveryGroupAlreadyDeployed(String name); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222020, value = "error scanning for URL''s", format = Message.Format.MESSAGE_FORMAT) + void errorScanningURLs(@Cause Exception e); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222021, value = "problem undeploying {0}", format = Message.Format.MESSAGE_FORMAT) + void problemUndeployingNode(@Cause Exception e, Node node); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222022, value = "Timed out waiting for paging cursor to stop {0} {1}", format = Message.Format.MESSAGE_FORMAT) + void timedOutStoppingPagingCursor(FutureLatch future, Executor executor); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222023, value = "problem cleaning page address {0}", format = Message.Format.MESSAGE_FORMAT) + void problemCleaningPageAddress(@Cause Exception e, SimpleString address); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222024, value = "Could not complete operations on IO context {0}", + format = Message.Format.MESSAGE_FORMAT) + void problemCompletingOperations(OperationContext e); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222025, value = "Problem cleaning page subscription counter", format = Message.Format.MESSAGE_FORMAT) + void problemCleaningPagesubscriptionCounter(@Cause Exception e); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222026, value = "Error on cleaning up cursor pages", format = Message.Format.MESSAGE_FORMAT) + void problemCleaningCursorPages(@Cause Exception e); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222027, value = "Timed out flushing executors for paging cursor to stop {0}", format = Message.Format.MESSAGE_FORMAT) + void timedOutFlushingExecutorsPagingCursor(PageSubscription pageSubscription); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222028, value = "Could not find page cache for page {0} removing it from the journal", + format = Message.Format.MESSAGE_FORMAT) + void pageNotFound(PagePosition pos); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222029, + value = "Could not locate page transaction {0}, ignoring message on position {1} on address={2} queue={3}", + format = Message.Format.MESSAGE_FORMAT) + void pageSubscriptionCouldntLoad(long transactionID, PagePosition position, SimpleString address, SimpleString name); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222030, value = "File {0} being renamed to {1}.invalidPage as it was loaded partially. Please verify your data.", format = Message.Format.MESSAGE_FORMAT) + void pageInvalid(String fileName, String name); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222031, value = "Error while deleting page file", format = Message.Format.MESSAGE_FORMAT) + void pageDeleteError(@Cause Exception e); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222032, value = "page finalise error", format = Message.Format.MESSAGE_FORMAT) + void pageFinaliseError(@Cause Exception e); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222033, value = "Page file {0} had incomplete records at position {1} at record number {2}", format = Message.Format.MESSAGE_FORMAT) + void pageSuspectFile(String fileName, int position, int msgNumber); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222034, value = "Can not delete page transaction id={0}", format = Message.Format.MESSAGE_FORMAT) + void pageTxDeleteError(@Cause Exception e, long recordID); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222035, value = "Directory {0} did not have an identification file {1}", + format = Message.Format.MESSAGE_FORMAT) + void pageStoreFactoryNoIdFile(String s, String addressFile); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222036, value = "Timed out on waiting PagingStore {0} to shutdown", format = Message.Format.MESSAGE_FORMAT) + void pageStoreTimeout(SimpleString address); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222037, value = "IO Error, impossible to start paging", format = Message.Format.MESSAGE_FORMAT) + void pageStoreStartIOError(@Cause Exception e); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222038, value = "Starting paging on address ''{0}''; size is currently: {1} bytes; max-size-bytes: {2}", format = Message.Format.MESSAGE_FORMAT) + void pageStoreStart(SimpleString storeName, long addressSize, long maxSize); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222039, value = "Messages sent to address ''{0}'' are being dropped; size is currently: {1} bytes; max-size-bytes: {2}", format = Message.Format.MESSAGE_FORMAT) + void pageStoreDropMessages(SimpleString storeName, long addressSize, long maxSize); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222040, value = "Server is stopped", format = Message.Format.MESSAGE_FORMAT) + void serverIsStopped(); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222041, value = "Cannot find queue {0} to update delivery count", format = Message.Format.MESSAGE_FORMAT) + void journalCannotFindQueueDelCount(Long queueID); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222042, value = "Cannot find message {0} to update delivery count", format = Message.Format.MESSAGE_FORMAT) + void journalCannotFindMessageDelCount(Long msg); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222043, value = "Message for queue {0} which does not exist. This message will be ignored.", format = Message.Format.MESSAGE_FORMAT) + void journalCannotFindQueueForMessage(Long queueID); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222044, value = "It was not possible to delete message {0}", format = Message.Format.MESSAGE_FORMAT) + void journalErrorDeletingMessage(@Cause Exception e, Long messageID); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222045, value = "Message in prepared tx for queue {0} which does not exist. This message will be ignored.", format = Message.Format.MESSAGE_FORMAT) + void journalMessageInPreparedTX(Long queueID); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222046, value = "Failed to remove reference for {0}", format = Message.Format.MESSAGE_FORMAT) + void journalErrorRemovingRef(Long messageID); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222047, value = "Can not find queue {0} while reloading ACKNOWLEDGE_CURSOR", + format = Message.Format.MESSAGE_FORMAT) + void journalCannotFindQueueReloadingACK(Long queueID); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222048, value = "PAGE_CURSOR_COUNTER_VALUE record used on a prepared statement, invalid state", format = Message.Format.MESSAGE_FORMAT) + void journalPAGEOnPrepared(); + + @LogMessage(level = Logger.Level.WARN) + @Message( + id = 222049, + value = "InternalError: Record type {0} not recognized. Maybe you are using journal files created on a different version", + format = Message.Format.MESSAGE_FORMAT) + void journalInvalidRecordType(Byte recordType); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222050, value = "Can not locate recordType={0} on loadPreparedTransaction//deleteRecords", + format = Message.Format.MESSAGE_FORMAT) + void journalInvalidRecordTypeOnPreparedTX(Byte recordType); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222051, value = "Journal Error", format = Message.Format.MESSAGE_FORMAT) + void journalError(@Cause Exception e); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222052, value = "error incrementing delay detection", format = Message.Format.MESSAGE_FORMAT) + void errorIncrementDelayDeletionCount(@Cause Exception e); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222053, value = "Error on copying large message {0} for DLA or Expiry", format = Message.Format.MESSAGE_FORMAT) + void lareMessageErrorCopying(@Cause Exception e, LargeServerMessage largeServerMessage); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222054, value = "Error on executing IOAsyncTask", format = Message.Format.MESSAGE_FORMAT) + void errorExecutingIOAsyncTask(@Cause Throwable t); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222055, value = "Error on deleting duplicate cache", format = Message.Format.MESSAGE_FORMAT) + void errorDeletingDuplicateCache(@Cause Exception e); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222056, value = "Did not route to any bindings for address {0} and sendToDLAOnNoRoute is true but there is no DLA configured for the address, the message will be ignored.", + format = Message.Format.MESSAGE_FORMAT) + void noDLA(SimpleString address); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222057, value = "It was not possible to add references due to an IO error code {0} message = {1}", + format = Message.Format.MESSAGE_FORMAT) + void ioErrorAddingReferences(Integer errorCode, String errorMessage); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222058, value = "Duplicate message detected through the bridge - message will not be routed. Message information:\n{0}", format = Message.Format.MESSAGE_FORMAT) + void duplicateMessageDetectedThruBridge(ServerMessage message); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222059, value = "Duplicate message detected - message will not be routed. Message information:\n{0}", format = Message.Format.MESSAGE_FORMAT) + void duplicateMessageDetected(ServerMessage message); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222060, value = "Error while confirming large message completion on rollback for recordID={0}", format = Message.Format.MESSAGE_FORMAT) + void journalErrorConfirmingLargeMessage(@Cause Throwable e, Long messageID); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222061, value = "Client connection failed, clearing up resources for session {0}", format = Message.Format.MESSAGE_FORMAT) + void clientConnectionFailed(String name); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222062, value = "Cleared up resources for session {0}", format = Message.Format.MESSAGE_FORMAT) + void clearingUpSession(String name); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222063, value = "Error processing IOCallback code = {0} message = {1}", format = Message.Format.MESSAGE_FORMAT) + void errorProcessingIOCallback(Integer errorCode, String errorMessage); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222065, value = "Client is not being consistent on the request versioning. It just sent a version id={0} while it informed {1} previously", format = Message.Format.MESSAGE_FORMAT) + void incompatibleVersionAfterConnect(int version, int clientVersion); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222066, value = "Reattach request from {0} failed as there is no confirmationWindowSize configured, which may be ok for your system", format = Message.Format.MESSAGE_FORMAT) + void reattachRequestFailed(String remoteAddress); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222067, value = "Connection failure has been detected: {0} [code={1}]", format = Message.Format.MESSAGE_FORMAT) + void connectionFailureDetected(String message, ActiveMQExceptionType type); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222069, value = "error cleaning up stomp connection", format = Message.Format.MESSAGE_FORMAT) + void errorCleaningStompConn(@Cause Exception e); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222070, value = "Stomp Transactional acknowledgement is not supported", format = Message.Format.MESSAGE_FORMAT) + void stompTXAckNorSupported(); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222071, value = "Interrupted while waiting for stomp heart beate to die", format = Message.Format.MESSAGE_FORMAT) + void errorOnStompHeartBeat(@Cause InterruptedException e); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222072, value = "Timed out flushing channel on InVMConnection", format = Message.Format.MESSAGE_FORMAT) + void timedOutFlushingInvmChannel(); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 212074, value = "channel group did not completely close", format = Message.Format.MESSAGE_FORMAT) + void nettyChannelGroupError(); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222075, value = "{0} is still connected to {1}", format = Message.Format.MESSAGE_FORMAT) + void nettyChannelStillOpen(Channel channel, SocketAddress remoteAddress); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222076, value = "channel group did not completely unbind", format = Message.Format.MESSAGE_FORMAT) + void nettyChannelGroupBindError(); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222077, value = "{0} is still bound to {1}", format = Message.Format.MESSAGE_FORMAT) + void nettyChannelStillBound(Channel channel, SocketAddress remoteAddress); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222078, value = "Error instantiating remoting interceptor {0}", format = Message.Format.MESSAGE_FORMAT) + void errorCreatingRemotingInterceptor(@Cause Exception e, String interceptorClass); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222079, value = "The following keys are invalid for configuring the acceptor: {0} the acceptor will not be started.", + format = Message.Format.MESSAGE_FORMAT) + void invalidAcceptorKeys(String s); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222080, value = "Error instantiating remoting acceptor {0}", format = Message.Format.MESSAGE_FORMAT) + void errorCreatingAcceptor(@Cause Exception e, String factoryClassName); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222081, value = "Timed out waiting for remoting thread pool to terminate", format = Message.Format.MESSAGE_FORMAT) + void timeoutRemotingThreadPool(); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222082, value = "error on connection failure check", format = Message.Format.MESSAGE_FORMAT) + void errorOnFailureCheck(@Cause Throwable e); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222083, value = "The following keys are invalid for configuring the connector service: {0} the connector will not be started.", + format = Message.Format.MESSAGE_FORMAT) + void connectorKeysInvalid(String s); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222084, value = "The following keys are required for configuring the connector service: {0} the connector will not be started.", + format = Message.Format.MESSAGE_FORMAT) + void connectorKeysMissing(String s); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222085, value = "Packet {0} can not be processed by the ReplicationEndpoint", + format = Message.Format.MESSAGE_FORMAT) + void invalidPacketForReplication(Packet packet); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222086, value = "error handling packet {0} for replication", format = Message.Format.MESSAGE_FORMAT) + void errorHandlingReplicationPacket(@Cause Exception e, Packet packet); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222087, value = "Replication Error while closing the page on backup", format = Message.Format.MESSAGE_FORMAT) + void errorClosingPageOnReplication(@Cause Exception e); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222088, value = "Journal comparison mismatch:\n{0}", format = Message.Format.MESSAGE_FORMAT) + void journalcomparisonMismatch(String s); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222089, value = "Replication Error deleting large message ID = {0}", format = Message.Format.MESSAGE_FORMAT) + void errorDeletingLargeMessage(@Cause Exception e, long messageId); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222090, value = "Replication Large MessageID {0} is not available on backup server. Ignoring replication message", format = Message.Format.MESSAGE_FORMAT) + void largeMessageNotAvailable(long messageId); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222091, value = "The backup node has been shut-down, replication will now stop", format = Message.Format.MESSAGE_FORMAT) + void replicationStopOnBackupShutdown(); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222092, value = "Connection to the backup node failed, removing replication now", format = Message.Format.MESSAGE_FORMAT) + void replicationStopOnBackupFail(@Cause Exception e); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222093, value = "Timed out waiting to stop Bridge", format = Message.Format.MESSAGE_FORMAT) + void timedOutWaitingToStopBridge(); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222094, value = "Bridge unable to send message {0}, will try again once bridge reconnects", format = Message.Format.MESSAGE_FORMAT) + void bridgeUnableToSendMessage(@Cause Exception e, MessageReference ref); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222095, value = "Connection failed with failedOver={0}", format = Message.Format.MESSAGE_FORMAT) + void bridgeConnectionFailed(@Cause Exception e, Boolean failedOver); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222096, value = "Error on querying binding on bridge {0}. Retrying in 100 milliseconds", format = Message.Format.MESSAGE_FORMAT) + void errorQueryingBridge(@Cause Throwable t, SimpleString name); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222097, value = "Address {0} does not have any bindings yet, retry #({1})", + format = Message.Format.MESSAGE_FORMAT) + void errorQueryingBridge(SimpleString address, Integer retryCount); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222098, value = "Server is starting, retry to create the session for bridge {0}", format = Message.Format.MESSAGE_FORMAT) + void errorStartingBridge(SimpleString name); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222099, value = "Bridge {0} is unable to connect to destination. It will be disabled.", format = Message.Format.MESSAGE_FORMAT) + void errorConnectingBridge(@Cause Exception e, Bridge bridge); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222100, value = "ServerLocator was shutdown, can not retry on opening connection for bridge", + format = Message.Format.MESSAGE_FORMAT) + void bridgeLocatorShutdown(); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222101, value = "Bridge {0} achieved {1} maxattempts={2} it will stop retrying to reconnect", format = Message.Format.MESSAGE_FORMAT) + void bridgeAbortStart(SimpleString name, Integer retryCount, Integer reconnectAttempts); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222102, value = "Unexpected exception while trying to reconnect", format = Message.Format.MESSAGE_FORMAT) + void errorReConnecting(@Cause Exception e); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222103, value = "transaction with xid {0} timed out", format = Message.Format.MESSAGE_FORMAT) + void unexpectedXid(Xid xid); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222104, value = "IO Error completing the transaction, code = {0}, message = {1}", format = Message.Format.MESSAGE_FORMAT) + void ioErrorOnTX(Integer errorCode, String errorMessage); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222105, value = "Could not finish context execution in 10 seconds", + format = Message.Format.MESSAGE_FORMAT) + void errorCompletingContext(@Cause Exception e); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222106, value = "Replacing incomplete LargeMessage with ID={0}", format = Message.Format.MESSAGE_FORMAT) + void replacingIncompleteLargeMessage(Long messageID); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222107, value = "Cleared up resources for session {0}", format = Message.Format.MESSAGE_FORMAT) + void clientConnectionFailedClearingSession(String name); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222108, value = "unable to send notification when broadcast group is stopped", + format = Message.Format.MESSAGE_FORMAT) + void broadcastGroupClosed(@Cause Exception e); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222109, value = "NodeID={0} is not available on the topology. Retrying the connection to that node now", format = Message.Format.MESSAGE_FORMAT) + void nodeNotAvailable(String targetNodeID); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222110, value = "no queue IDs defined!, originalMessage = {0}, copiedMessage = {1}, props={2}", + format = Message.Format.MESSAGE_FORMAT) + void noQueueIdDefined(ServerMessage message, ServerMessage messageCopy, SimpleString idsHeaderName); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222111, value = "exception while invoking {0} on {1}", + format = Message.Format.MESSAGE_FORMAT) + void managementOperationError(@Cause Exception e, String op, String resourceName); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222112, value = "exception while retrieving attribute {0} on {1}", + format = Message.Format.MESSAGE_FORMAT) + void managementAttributeError(@Cause Exception e, String att, String resourceName); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222113, value = "On ManagementService stop, there are {0} unexpected registered MBeans: {1}", + format = Message.Format.MESSAGE_FORMAT) + void managementStopError(Integer size, List<String> unexpectedResourceNames); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222114, value = "Unable to delete group binding info {0}", + format = Message.Format.MESSAGE_FORMAT) + void unableToDeleteGroupBindings(@Cause Exception e, SimpleString groupId); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222115, value = "Error closing serverLocator={0}", + format = Message.Format.MESSAGE_FORMAT) + void errorClosingServerLocator(@Cause Exception e, ServerLocatorInternal clusterLocator); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222116, value = "unable to start broadcast group {0}", format = Message.Format.MESSAGE_FORMAT) + void unableToStartBroadcastGroup(@Cause Exception e, String name); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222117, value = "unable to start cluster connection {0}", format = Message.Format.MESSAGE_FORMAT) + void unableToStartClusterConnection(@Cause Exception e, SimpleString name); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222118, value = "unable to start Bridge {0}", format = Message.Format.MESSAGE_FORMAT) + void unableToStartBridge(@Cause Exception e, SimpleString name); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222119, value = "No connector with name {0}. backup cannot be announced.", + format = Message.Format.MESSAGE_FORMAT) + void announceBackupNoConnector(String connectorName); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222120, value = "no cluster connections defined, unable to announce backup", format = Message.Format.MESSAGE_FORMAT) + void announceBackupNoClusterConnections(); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222121, value = "Must specify a unique name for each bridge. This one will not be deployed.", format = Message.Format.MESSAGE_FORMAT) + void bridgeNotUnique(); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222122, value = "Must specify a queue name for each bridge. This one {0} will not be deployed.", format = Message.Format.MESSAGE_FORMAT) + void bridgeNoQueue(String name); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222123, value = "Forward address is not specified on bridge {0}. Will use original message address instead", format = Message.Format.MESSAGE_FORMAT) + void bridgeNoForwardAddress(String bridgeName); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222124, value = "There is already a bridge with name {0} deployed. This one will not be deployed.", format = Message.Format.MESSAGE_FORMAT) + void bridgeAlreadyDeployed(String name); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222125, value = "No queue found with name {0} bridge {1} will not be deployed.", format = Message.Format.MESSAGE_FORMAT) + void bridgeQueueNotFound(String queueName, String bridgeName); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222126, value = "No discovery group found with name {0} bridge will not be deployed.", format = Message.Format.MESSAGE_FORMAT) + void bridgeNoDiscoveryGroup(String name); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222127, value = "Must specify a unique name for each cluster connection. This one will not be deployed.", format = Message.Format.MESSAGE_FORMAT) + void clusterConnectionNotUnique(); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222128, value = "Must specify an address for each cluster connection. This one will not be deployed.", format = Message.Format.MESSAGE_FORMAT) + void clusterConnectionNoForwardAddress(); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222129, value = "No connector with name {0}. The cluster connection will not be deployed.", + format = Message.Format.MESSAGE_FORMAT) + void clusterConnectionNoConnector(String connectorName); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222130, + value = "Cluster Configuration {0} already exists. The cluster connection will not be deployed.", + format = Message.Format.MESSAGE_FORMAT) + void clusterConnectionAlreadyExists(String connectorName); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222131, value = "No discovery group with name {0}. The cluster connection will not be deployed.", + format = Message.Format.MESSAGE_FORMAT) + void clusterConnectionNoDiscoveryGroup(String discoveryGroupName); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222132, value = "There is already a broadcast-group with name {0} deployed. This one will not be deployed.", format = Message.Format.MESSAGE_FORMAT) + void broadcastGroupAlreadyExists(String name); + + @LogMessage(level = Logger.Level.WARN) + @Message( + id = 222133, + value = "There is no connector deployed with name {0}. The broadcast group with name {1} will not be deployed.", + format = Message.Format.MESSAGE_FORMAT) + void broadcastGroupNoConnector(String connectorName, String bgName); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222134, value = "No connector defined with name {0}. The bridge will not be deployed.", + format = Message.Format.MESSAGE_FORMAT) + void bridgeNoConnector(String name); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222135, value = "Stopping Redistributor, Timed out waiting for tasks to complete", format = Message.Format.MESSAGE_FORMAT) + void errorStoppingRedistributor(); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222136, value = "IO Error during redistribution, errorCode = {0} message = {1}", format = Message.Format.MESSAGE_FORMAT) + void ioErrorRedistributing(Integer errorCode, String errorMessage); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222137, value = "Unable to announce backup, retrying", format = Message.Format.MESSAGE_FORMAT) + void errorAnnouncingBackup(); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222138, value = "Local Member is not set at on ClusterConnection {0}", format = Message.Format.MESSAGE_FORMAT) + void noLocalMemborOnClusterConnection(ClusterConnectionImpl clusterConnection); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222139, value = "{0}::Remote queue binding {1} has already been bound in the post office. Most likely cause for this is you have a loop in your cluster due to cluster max-hops being too large or you have multiple cluster connections to the same nodes using overlapping addresses", + format = Message.Format.MESSAGE_FORMAT) + void remoteQueueAlreadyBoundOnClusterConnection(Object messageFlowRecord, SimpleString clusterName); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222141, value = "Node Manager can not open file {0}", format = Message.Format.MESSAGE_FORMAT) + void nodeManagerCantOpenFile(@Cause Exception e, File file); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222142, value = "Error on resetting large message deliver - {0}", format = Message.Format.MESSAGE_FORMAT) + void errorResttingLargeMessage(@Cause Throwable e, Object deliverer); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222143, value = "Timed out waiting for executor to complete", format = Message.Format.MESSAGE_FORMAT) + void errorTransferringConsumer(); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222144, value = "Queue could not finish waiting executors. Try increasing the thread pool size", + format = Message.Format.MESSAGE_FORMAT) + void errorFlushingExecutorsOnQueue(); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222145, value = "Error expiring reference {0} 0n queue", format = Message.Format.MESSAGE_FORMAT) + void errorExpiringReferencesOnQueue(@Cause Exception e, MessageReference ref); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222146, value = "Message has expired. No bindings for Expiry Address {0} so dropping it", format = Message.Format.MESSAGE_FORMAT) + void errorExpiringReferencesNoBindings(SimpleString expiryAddress); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222147, value = "Message has expired. No expiry queue configured for queue {0} so dropping it", format = Message.Format.MESSAGE_FORMAT) + void errorExpiringReferencesNoQueue(SimpleString name); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222148, value = "Message {0} has exceeded max delivery attempts. No bindings for Dead Letter Address {1} so dropping it", + format = Message.Format.MESSAGE_FORMAT) + void messageExceededMaxDelivery(MessageReference ref, SimpleString name); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222149, value = "Message {0} has reached maximum delivery attempts, sending it to Dead Letter Address {1} from {2}", + format = Message.Format.MESSAGE_FORMAT) + void messageExceededMaxDeliverySendtoDLA(MessageReference ref, SimpleString name, SimpleString simpleString); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222150, value = "Message has exceeded max delivery attempts. No Dead Letter Address configured for queue {0} so dropping it", + format = Message.Format.MESSAGE_FORMAT) + void messageExceededMaxDeliveryNoDLA(SimpleString name); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222151, value = "removing consumer which did not handle a message, consumer={0}, message={1}", + format = Message.Format.MESSAGE_FORMAT) + void removingBadConsumer(@Cause Throwable e, Consumer consumer, MessageReference reference); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222152, value = "Unable to decrement reference counting on queue", + format = Message.Format.MESSAGE_FORMAT) + void errorDecrementingRefCount(@Cause Throwable e); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222153, value = "Unable to remove message id = {0} please remove manually", + format = Message.Format.MESSAGE_FORMAT) + void errorRemovingMessage(@Cause Throwable e, Long messageID); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222154, value = "Error checking DLQ", + format = Message.Format.MESSAGE_FORMAT) + void errorCheckingDLQ(@Cause Throwable e); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222155, value = "Failed to register as backup. Stopping the server.", + format = Message.Format.MESSAGE_FORMAT) + void errorRegisteringBackup(); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222156, value = "Less than {0}%\n{1}\nYou are in danger of running out of RAM. Have you set paging parameters on your addresses? (See user manual \"Paging\" chapter)", + format = Message.Format.MESSAGE_FORMAT) + void memoryError(Integer memoryWarningThreshold, String info); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222157, value = "Error completing callback on replication manager", + format = Message.Format.MESSAGE_FORMAT) + void errorCompletingCallbackOnReplicationManager(@Cause Throwable e); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222158, value = "{0} backup activation thread did not finish.", format = Message.Format.MESSAGE_FORMAT) + void backupActivationDidntFinish(ActiveMQServer server); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222159, value = "unable to send notification when broadcast group is stopped", format = Message.Format.MESSAGE_FORMAT) + void broadcastBridgeStoppedError(@Cause Exception e); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222160, value = "unable to send notification when broadcast group is stopped", format = Message.Format.MESSAGE_FORMAT) + void notificationBridgeStoppedError(@Cause Exception e); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222161, value = "Group Handler timed-out waiting for sendCondition", format = Message.Format.MESSAGE_FORMAT) + void groupHandlerSendTimeout(); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222162, value = "Moving data directory {0} to {1}", format = Message.Format.MESSAGE_FORMAT) + void backupMovingDataAway(String oldPath, String newPath); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222163, value = "Server is being completely stopped, since this was a replicated backup there may be journal files that need cleaning up. The ActiveMQ server will have to be manually restarted.", + format = Message.Format.MESSAGE_FORMAT) + void stopReplicatedBackupAfterFailback(); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222164, value = "Error when trying to start replication {0}", format = Message.Format.MESSAGE_FORMAT) + void errorStartingReplication(BackupReplicationStartFailedMessage.BackupRegistrationProblem problem); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222165, value = "Error starting naming server", format = Message.Format.MESSAGE_FORMAT) + void unableToStartNamingServer(@Cause Exception e); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222166, value = "Error stopping naming server", format = Message.Format.MESSAGE_FORMAT) + void unableToStopNamingServer(@Cause Exception e); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222167, value = "Group Binding not available so deleting {0} groups from {1}, groups will be bound to another node", + format = Message.Format.MESSAGE_FORMAT) + void groupingQueueRemoved(int size, SimpleString clusterName); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222168, value = "The ''protocol'' property is deprecated, if you want this Acceptor to support multiple protocols use the ''protocols'' property, i.e. ''CORE,AMQP,STOMP''", + format = Message.Format.MESSAGE_FORMAT) + void warnDeprecatedProtocol(); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222169, value = "You have old legacy clients connected to the queue {0} and we can''t disconnect them, these clients may just hang", + format = Message.Format.MESSAGE_FORMAT) + void warnDisconnectOldClient(String queueName); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222170, value = "Bridge {0} forwarding address {1} has confirmation-window-size ({2}) greater than address'' max-size-bytes'' ({3})", + format = Message.Format.MESSAGE_FORMAT) + void bridgeConfirmationWindowTooSmall(String bridgeName, String address, int windowConfirmation, long maxSizeBytes); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222171, value = "Bridge {0} forwarding address {1} could not be resolved on address-settings configuration", + format = Message.Format.MESSAGE_FORMAT) + void bridgeCantFindAddressConfig(String bridgeName, String forwardingAddress); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222172, value = "Queue {0} was busy for more than {1} milliseconds. There are possibly consumers hanging on a network operation", + format = Message.Format.MESSAGE_FORMAT) + void queueBusy(String name, long timeout); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222173, value = "Queue {0} is duplicated during reload. This queue will be renamed as {1}", format = Message.Format.MESSAGE_FORMAT) + void queueDuplicatedRenaming(String name, String newName); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222174, value = "Queue {0}, on address={1}, is taking too long to flush deliveries. Watch out for frozen clients.", format = Message.Format.MESSAGE_FORMAT) + void timeoutFlushInTransit(String queueName, String addressName); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222175, value = "Bridge {0} could not find configured connectors", format = Message.Format.MESSAGE_FORMAT) + void bridgeCantFindConnectors(String bridgeName); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222176, + value = "A session that was already doing XA work on {0} is replacing the xid by {1} " + + ". This was most likely caused from a previous communication timeout", + format = Message.Format.MESSAGE_FORMAT) + void xidReplacedOnXStart(String xidOriginalToString, String xidReplacedToString); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222177, value = "Wrong configuration for role, {0} is not a valid permission", + format = Message.Format.MESSAGE_FORMAT) + void rolePermissionConfigurationError(String permission); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222178, value = "Error during recovery of page counters", + format = Message.Format.MESSAGE_FORMAT) + void errorRecoveringPageCounter(@Cause Throwable error); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222181, value = "Unable to scaleDown messages", format = Message.Format.MESSAGE_FORMAT) + void failedToScaleDown(@Cause Throwable e); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222182, value = "Missing cluster-configuration for scale-down-clustername {0}", format = Message.Format.MESSAGE_FORMAT) + void missingClusterConfigForScaleDown(String scaleDownCluster); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222183, value = "Blocking message production on address ''{0}''; size is currently: {1} bytes; max-size-bytes: {2}", format = Message.Format.MESSAGE_FORMAT) + void blockingMessageProduction(SimpleString addressName, long currentSize, long maxSize); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222184, + value = "Unable to recover group bindings in SCALE_DOWN mode, only FULL backup server can do this", + format = Message.Format.MESSAGE_FORMAT) + void groupBindingsOnRecovery(); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222185, + value = "no cluster connection for specified replication cluster", + format = Message.Format.MESSAGE_FORMAT) + void noClusterConnectionForReplicationCluster(); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222186, + value = "unable to authorise cluster control", + format = Message.Format.MESSAGE_FORMAT) + void clusterControlAuthfailure(); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222187, + value = "Failed to activate replicata", + format = Message.Format.MESSAGE_FORMAT) + void activateReplicatedBackupFailed(@Cause Throwable e); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222188, + value = "Unable to find target queue for node {0}", + format = Message.Format.MESSAGE_FORMAT) + void unableToFindTargetQueue(String targetNodeID); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222189, + value = "Failed to activate shared store slave", + format = Message.Format.MESSAGE_FORMAT) + void activateSharedStoreSlaveFailed(@Cause Throwable e); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 222190, + value = "Disallowing use of vulnerable protocol: {0}. See http://www.oracle.com/technetwork/topics/security/poodlecve-2014-3566-2339408.html for more details.", + format = Message.Format.MESSAGE_FORMAT) + void disallowedProtocol(String protocol); + + @LogMessage(level = Logger.Level.ERROR) + @Message(id = 224000, value = "Failure in initialisation", format = Message.Format.MESSAGE_FORMAT) + void initializationError(@Cause Throwable e); + + @LogMessage(level = Logger.Level.ERROR) + @Message(id = 224001, value = "Error deploying URI {0}", format = Message.Format.MESSAGE_FORMAT) + void errorDeployingURI(@Cause Throwable e, URI uri); + + @LogMessage(level = Logger.Level.ERROR) + @Message(id = 224002, value = "Error deploying URI", format = Message.Format.MESSAGE_FORMAT) + void errorDeployingURI(@Cause Throwable e); + + @LogMessage(level = Logger.Level.ERROR) + @Message(id = 224003, value = "Error undeploying URI {0}", format = Message.Format.MESSAGE_FORMAT) + void errorUnDeployingURI(@Cause Throwable e, URI a); + + @LogMessage(level = Logger.Level.ERROR) + @Message(id = 224005, value = "Unable to deploy node {0}", format = Message.Format.MESSAGE_FORMAT) + void unableToDeployNode(@Cause Exception e, Node node); + + @LogMessage(level = Logger.Level.ERROR) + @Message(id = 224006, value = "Invalid filter: {0}", format = Message.Format.MESSAGE_FORMAT) + void invalidFilter(@Cause Throwable t, SimpleString filter); + + @LogMessage(level = Logger.Level.ERROR) + @Message(id = 224007, value = "page subscription = {0} error={1}", format = Message.Format.MESSAGE_FORMAT) + void pageSubscriptionError(IOAsyncTask ioAsyncTask, String error); + + @LogMessage(level = Logger.Level.ERROR) + @Message(id = 224008, value = "Failed to store id", format = Message.Format.MESSAGE_FORMAT) + void batchingIdError(@Cause Exception e); + + @LogMessage(level = Logger.Level.ERROR) + @Message(id = 224009, value = "Cannot find message {0}", format = Message.Format.MESSAGE_FORMAT) + void cannotFindMessage(Long id); + + @LogMessage(level = Logger.Level.ERROR) + @Message(id = 224010, value = "Cannot find queue messages for queueID={0} on ack for messageID={1}", format = Message.Format.MESSAGE_FORMAT) + void journalCannotFindQueue(Long queue, Long id); + + @LogMessage(level = Logger.Level.ERROR) + @Message(id = 224011, value = "Cannot find queue messages {0} for message {1} while processing scheduled messages", format = Message.Format.MESSAGE_FORMAT) + void journalCannotFindQueueScheduled(Long queue, Long id); + + @LogMessage(level = Logger.Level.ERROR) + @Message(id = 224012, value = "error releasing resources", format = Message.Format.MESSAGE_FORMAT) + void largeMessageErrorReleasingResources(@Cause Exception e); + + @LogMessage(level = Logger.Level.ERROR) + @Message(id = 224013, value = "failed to expire messages for queue", format = Message.Format.MESSAGE_FORMAT) + void errorExpiringMessages(@Cause Exception e); + + @LogMessage(level = Logger.Level.ERROR) + @Message(id = 224014, value = "Failed to close session", format = Message.Format.MESSAGE_FORMAT) + void errorClosingSession(@Cause Exception e); + + @LogMessage(level = Logger.Level.ERROR) + @Message(id = 224015, value = "Caught XA exception", format = Message.Format.MESSAGE_FORMAT) + void caughtXaException(@Cause Exception e); + + @LogMessage(level = Logger.Level.ERROR) + @Message(id = 224016, value = "Caught exception", format = Message.Format.MESSAGE_FORMAT) + void caughtException(@Cause Throwable e); + + @LogMessage(level = Logger.Level.ERROR) + @Message(id = 224017, value = "Invalid packet {0}", format = Message.Format.MESSAGE_FORMAT) + void invalidPacket(Packet packet); + + @LogMessage(level = Logger.Level.ERROR) + @Message(id = 224018, value = "Failed to create session", format = Message.Format.MESSAGE_FORMAT) + void failedToCreateSession(@Cause Exception e); + + @LogMessage(level = Logger.Level.ERROR) + @Message(id = 224019, value = "Failed to reattach session", format = Message.Format.MESSAGE_FORMAT) + void failedToReattachSession(@Cause Exception e); + + @LogMessage(level = Logger.Level.ERROR) + @Message(id = 224020, value = "Failed to handle create queue", format = Message.Format.MESSAGE_FORMAT) + void failedToHandleCreateQueue(@Cause Exception e); + + @LogMessage(level = Logger.Level.ERROR) + @Message(id = 224021, value = "Failed to decode packet", format = Message.Format.MESSAGE_FORMAT) + void errorDecodingPacket(@Cause Exception e); + + @LogMessage(level = Logger.Level.ERROR) + @Message(id = 224022, value = "Failed to execute failure listener", format = Message.Format.MESSAGE_FORMAT) + void errorCallingFailureListener(@Cause Throwable e); + + @LogMessage(level = Logger.Level.ERROR) + @Message(id = 224024, value = "Stomp Error, tx already exist! {0}", format = Message.Format.MESSAGE_FORMAT) + void stompErrorTXExists(String txID); + + @LogMessage(level = Logger.Level.ERROR) + @Message(id = 224027, value = "Failed to write to handler on invm connector {0}", format = Message.Format.MESSAGE_FORMAT) + void errorWritingToInvmConnector(@Cause Exception e, Runnable runnable); + + @LogMessage(level = Logger.Level.ERROR) + @Message(id = 224028, value = "Failed to stop acceptor", format = Message.Format.MESSAGE_FORMAT) + void errorStoppingAcceptor(); + + @LogMessage(level = Logger.Level.ERROR) + @Message(id = 224029, value = "large message sync: largeMessage instance is incompatible with it, ignoring data", format = Message.Format.MESSAGE_FORMAT) + void largeMessageIncompatible(); + + @LogMessage(level = Logger.Level.ERROR) + @Message(id = 224030, value = "Could not cancel reference {0}", format = Message.Format.MESSAGE_FORMAT) + void errorCancellingRefOnBridge(@Cause Exception e, MessageReference ref2); + + @LogMessage(level = Logger.Level.ERROR) + @Message(id = 224031, value = "-------------------------------Stomp begin tx: {0}", format = Message.Format.MESSAGE_FORMAT) + void stompBeginTX(String txID); + + @LogMessage(level = Logger.Level.ERROR) + @Message(id = 224032, value = "Failed to pause bridge", format = Message.Format.MESSAGE_FORMAT) + void errorPausingBridge(@Cause Exception e); + + @LogMessage(level = Logger.Level.ERROR) + @Message(id = 224033, value = "Failed to broadcast connector configs", format = Message.Format.MESSAGE_FORMAT) + void errorBroadcastingConnectorConfigs(@Cause Exception e); + + @LogMessage(level = Logger.Level.ERROR) + @Message(id = 224034, value = "Failed to close consumer", format = Message.Format.MESSAGE_FORMAT) + void errorClosingConsumer(@Cause Exception e); + + @LogMessage(level = Logger.Level.ERROR) + @Message(id = 224035, value = "Failed to close cluster connection flow record", format = Message.Format.MESSAGE_FORMAT) + void errorClosingFlowRecord(@Cause Exception e); + + @LogMessage(level = Logger.Level.ERROR) + @Message(id = 224036, value = "Failed to update cluster connection topology", format = Message.Format.MESSAGE_FORMAT) + void errorUpdatingTopology(@Cause Exception e); + + @LogMessage(level = Logger.Level.ERROR) + @Message(id = 224037, value = "cluster connection Failed to handle message", format = Message.Format.MESSAGE_FORMAT) + void errorHandlingMessage(@Cause Exception e); + + @LogMessage(level = Logger.Level.ERROR) + @Message(id = 224038, value = "Failed to ack old reference", format = Message.Format.MESSAGE_FORMAT) + void errorAckingOldReference(@Cause Exception e); + + @LogMessage(level = Logger.Level.ERROR) + @Message(id = 224039, value = "Failed to expire message reference", format = Message.Format.MESSAGE_FORMAT) + void errorExpiringRef(@Cause Exception e); + + @LogMessage(level = Logger.Level.ERROR) + @Message(id = 224040, value = "Failed to remove consumer", format = Message.Format.MESSAGE_FORMAT) + void errorRemovingConsumer(@Cause Exception e); + + @LogMessage(level = Logger.Level.ERROR) + @Message(id = 224041, value = "Failed to deliver", format = Message.Format.MESSAGE_FORMAT) + void errorDelivering(@Cause Exception e); + + @LogMessage(level = Logger.Level.ERROR) + @Message(id = 224042, value = "Error while restarting the backup server: {0}", format = Message.Format.MESSAGE_FORMAT) + void errorRestartingBackupServer(@Cause Exception e, ActiveMQServer backup); + + @LogMessage(level = Logger.Level.ERROR) + @Message(id = 224043, value = "Failed to send forced delivery message", format = Message.Format.MESSAGE_FORMAT) + void errorSendingForcedDelivery(@Cause Exception e); + + @LogMessage(level = Logger.Level.ERROR) + @Message(id = 224044, value = "error acknowledging message", format = Message.Format.MESSAGE_FORMAT) + void errorAckingMessage(@Cause Exception e); + + @LogMessage(level = Logger.Level.ERROR) + @Message(id = 224045, value = "Failed to run large message deliverer", format = Message.Format.MESSAGE_FORMAT) + void errorRunningLargeMessageDeliverer(@Cause Exception e); + + @LogMessage(level = Logger.Level.ERROR) + @Message(id = 224046, value = "Exception while browser handled from {0}", format = Message.Format.MESSAGE_FORMAT) + void errorBrowserHandlingMessage(@Cause Exception e, MessageReference current); + + @LogMessage(level = Logger.Level.ERROR) + @Message(id = 224047, value = "Failed to delete large message file", format = Message.Format.MESSAGE_FORMAT) + void errorDeletingLargeMessageFile(@Cause Throwable e); + + @LogMessage(level = Logger.Level.ERROR) + @Message(id = 224048, value = "Failed to remove temporary queue {0}", format = Message.Format.MESSAGE_FORMAT) + void errorRemovingTempQueue(@Cause Exception e, SimpleString bindingName); + + @LogMessage(level = Logger.Level.ERROR) + @Message(id = 224049, value = "Cannot find consumer with id {0}", format = Message.Format.MESSAGE_FORMAT) + void cannotFindConsumer(long consumerID); + + @LogMessage(level = Logger.Level.ERROR) + @Message(id = 224050, value = "Failed to close connection {0}", format = Message.Format.MESSAGE_FORMAT) + void errorClosingConnection(ServerSessionImpl serverSession); + + @LogMessage(level = Logger.Level.ERROR) + @Message(id = 224051, value = "Failed to call notification listener", format = Message.Format.MESSAGE_FORMAT) + void errorCallingNotifListener(@Cause Exception e); + + @LogMessage(level = Logger.Level.ERROR) + @Message(id = 224052, value = "Unable to call Hierarchical Repository Change Listener", format = Message.Format.MESSAGE_FORMAT) + void errorCallingRepoListener(@Cause Throwable e); + + @LogMessage(level = Logger.Level.ERROR) + @Message(id = 224053, value = "failed to timeout transaction, xid:{0}", format = Message.Format.MESSAGE_FORMAT) + void errorTimingOutTX(@Cause Exception e, Xid xid); + + @LogMessage(level = Logger.Level.ERROR) + @Message(id = 224054, value = "exception while stopping the replication manager", format = Message.Format.MESSAGE_FORMAT) + void errorStoppingReplicationManager(@Cause Throwable t); + + @LogMessage(level = Logger.Level.ERROR) + @Message(id = 224055, value = "Bridge Failed to ack", format = Message.Format.MESSAGE_FORMAT) + void bridgeFailedToAck(@Cause Throwable t); + + @LogMessage(level = Logger.Level.ERROR) + @Message(id = 224056, value = "Live server will not fail-back automatically", format = Message.Format.MESSAGE_FORMAT) + void autoFailBackDenied(); + + @LogMessage(level = Logger.Level.ERROR) + @Message(id = 224057, value = "Backup server that requested fail-back was not announced. Server will not stop for fail-back.", + format = Message.Format.MESSAGE_FORMAT) + void failbackMissedBackupAnnouncement(); + + @LogMessage(level = Logger.Level.ERROR) + @Message(id = 224058, value = "Stopping ClusterManager. As it failed to authenticate with the cluster: {0}", + format = Message.Format.MESSAGE_FORMAT) + void clusterManagerAuthenticationError(String msg); + + @LogMessage(level = Logger.Level.ERROR) + @Message(id = 224059, value = "Invalid cipher suite specified. Supported cipher suites are: {0}", format = Message.Format.MESSAGE_FORMAT) + void invalidCipherSuite(String validSuites); + + @LogMessage(level = Logger.Level.ERROR) + @Message(id = 224060, value = "Invalid protocol specified. Supported protocols are: {0}", format = Message.Format.MESSAGE_FORMAT) + void invalidProtocol(String validProtocols); + + @LogMessage(level = Logger.Level.WARN) + @Message(id = 224069, value = "Could not contact group handler coordinator after 10 retries, message being routed without grouping information", + format = Message.Format.MESSAGE_FORMAT) + void impossibleToRouteGrouped(); + + @LogMessage(level = Logger.Level.ERROR) + @Message(id = 224061, value = "Setting both <{0}> and <ha-policy> is invalid. Please use <ha-policy> exclusively as <{0}> is deprecated. Ignoring <{0}> value.", format = Message.Format.MESSAGE_FORMAT) + void incompatibleWithHAPolicy(String parameter); + + @LogMessage(level = Logger.Level.ERROR) + @Message(id = 224062, value = "Failed to send SLOW_CONSUMER notification: {0}", format = Message.Format.MESSAGE_FORMAT) + void failedToSendSlowConsumerNotification(Notification notification, @Cause Exception e); + + @LogMessage(level = Logger.Level.ERROR) + @Message(id = 224063, value = "Failed to close consumer connections for address {0}", format = Message.Format.MESSAGE_FORMAT) + void failedToCloseConsumerConnectionsForAddress(String address, @Cause Exception e); + + @LogMessage(level = Logger.Level.ERROR) + @Message(id = 224064, value = "Setting <{0}> is invalid with this HA Policy Configuration. Please use <ha-policy> exclusively or remove. Ignoring <{0}> value.", format = Message.Format.MESSAGE_FORMAT) + void incompatibleWithHAPolicyChosen(String parameter); + +}
http://git-wip-us.apache.org/repos/asf/activemq-6/blob/034adfbf/activemq-server/src/main/java/org/apache/activemq/core/server/ActiveMQServers.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/server/ActiveMQServers.java b/activemq-server/src/main/java/org/apache/activemq/core/server/ActiveMQServers.java new file mode 100644 index 0000000..411f68c --- /dev/null +++ b/activemq-server/src/main/java/org/apache/activemq/core/server/ActiveMQServers.java @@ -0,0 +1,123 @@ +/* + * Copyright 2005-2014 Red Hat, Inc. + * Red Hat licenses this file to you under the Apache License, version + * 2.0 (the "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * http://www.apache.org/licenses/LICENSE-2.0 + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or + * implied. See the License for the specific language governing + * permissions and limitations under the License. + */ +package org.apache.activemq.core.server; + +import java.lang.management.ManagementFactory; + +import javax.management.MBeanServer; + +import org.apache.activemq.core.config.Configuration; +import org.apache.activemq.core.server.impl.ActiveMQServerImpl; +import org.apache.activemq.spi.core.security.ActiveMQSecurityManager; +import org.apache.activemq.spi.core.security.ActiveMQSecurityManagerImpl; + +/** + * ActiveMQServers is a factory class for instantiating ActiveMQServer instances. + * <p> + * This class should be used when you want to instantiate a ActiveMQServer instance for embedding in + * your own application, as opposed to directly instantiating an implementing instance. + * @author <a href="mailto:tim....@jboss.com";>Tim Fox</a> + */ +public final class ActiveMQServers +{ + + private ActiveMQServers() + { + // Utility class + } + + public static ActiveMQServer newActiveMQServer(final Configuration config, final boolean enablePersistence) + { + ActiveMQSecurityManager securityManager = new ActiveMQSecurityManagerImpl(); + + ActiveMQServer server = ActiveMQServers.newActiveMQServer(config, + ManagementFactory.getPlatformMBeanServer(), + securityManager, + enablePersistence); + + return server; + } + + public static ActiveMQServer newActiveMQServer(final Configuration config) + { + return ActiveMQServers.newActiveMQServer(config, config.isPersistenceEnabled()); + } + + public static ActiveMQServer newActiveMQServer(final Configuration config, + final MBeanServer mbeanServer, + final boolean enablePersistence) + { + ActiveMQSecurityManager securityManager = new ActiveMQSecurityManagerImpl(); + + ActiveMQServer server = ActiveMQServers.newActiveMQServer(config, mbeanServer, securityManager, enablePersistence); + + return server; + } + + public static ActiveMQServer newActiveMQServer(final Configuration config, final MBeanServer mbeanServer) + { + return ActiveMQServers.newActiveMQServer(config, mbeanServer, true); + } + + public static ActiveMQServer newActiveMQServer(final Configuration config, + final MBeanServer mbeanServer, + final ActiveMQSecurityManager securityManager) + { + ActiveMQServer server = ActiveMQServers.newActiveMQServer(config, mbeanServer, securityManager, true); + + return server; + } + + public static ActiveMQServer newActiveMQServer(final Configuration config, + final MBeanServer mbeanServer, + final ActiveMQSecurityManager securityManager, + final boolean enablePersistence) + { + config.setPersistenceEnabled(enablePersistence); + + ActiveMQServer server = new ActiveMQServerImpl(config, mbeanServer, securityManager); + + return server; + } + + public static ActiveMQServer newActiveMQServer(Configuration config, + String defUser, String defPass) + { + ActiveMQSecurityManager securityManager = new ActiveMQSecurityManagerImpl(); + + securityManager.addUser(defUser, defPass); + + ActiveMQServer server = ActiveMQServers.newActiveMQServer(config, + ManagementFactory.getPlatformMBeanServer(), + securityManager, + config.isPersistenceEnabled()); + + return server; + } + + public static ActiveMQServer newActiveMQServer(final Configuration config, + final MBeanServer mbeanServer, + final boolean enablePersistence, + String user, + String password) + { + ActiveMQSecurityManager securityManager = new ActiveMQSecurityManagerImpl(); + + securityManager.addUser(user, password); + + ActiveMQServer server = ActiveMQServers.newActiveMQServer(config, mbeanServer, securityManager, enablePersistence); + + return server; + } + +} http://git-wip-us.apache.org/repos/asf/activemq-6/blob/034adfbf/activemq-server/src/main/java/org/apache/activemq/core/server/ConnectorService.java ---------------------------------------------------------------------- diff --git a/activemq-server/src/main/java/org/apache/activemq/core/server/ConnectorService.java b/activemq-server/src/main/java/org/apache/activemq/core/server/ConnectorService.java index 9e76264..96a91b4 100644 --- a/activemq-server/src/main/java/org/apache/activemq/core/server/ConnectorService.java +++ b/activemq-server/src/main/java/org/apache/activemq/core/server/ConnectorService.java @@ -16,7 +16,7 @@ package org.apache.activemq.core.server; * @author <a href="mailto:andy.tay...@jboss.org";>Andy Taylor</a> * Created Jun 29, 2010 */ -public interface ConnectorService extends HornetQComponent +public interface ConnectorService extends ActiveMQComponent { String getName(); }
