Clean up 'ActiveMQ' refs in literals

This commit is contained in:
jbertram 2015-05-11 11:23:10 -05:00
parent 555ea4799f
commit 2cbeedab89
22 changed files with 36 additions and 36 deletions

View File

@ -46,11 +46,11 @@ public interface ActiveMQBootstrapLogger extends BasicLogger
ActiveMQBootstrapLogger LOGGER = Logger.getMessageLogger(ActiveMQBootstrapLogger.class, ActiveMQBootstrapLogger.class.getPackage().getName()); ActiveMQBootstrapLogger LOGGER = Logger.getMessageLogger(ActiveMQBootstrapLogger.class, ActiveMQBootstrapLogger.class.getPackage().getName());
@LogMessage(level = Logger.Level.INFO) @LogMessage(level = Logger.Level.INFO)
@Message(id = 101000, value = "Starting ActiveMQ Server", format = Message.Format.MESSAGE_FORMAT) @Message(id = 101000, value = "Starting ActiveMQ Artemis Server", format = Message.Format.MESSAGE_FORMAT)
void serverStarting(); void serverStarting();
@LogMessage(level = Logger.Level.INFO) @LogMessage(level = Logger.Level.INFO)
@Message(id = 101001, value = "Stopping ActiveMQ Server", format = Message.Format.MESSAGE_FORMAT) @Message(id = 101001, value = "Stopping ActiveMQ Artemis Server", format = Message.Format.MESSAGE_FORMAT)
void serverStopping(); void serverStopping();
@LogMessage(level = Logger.Level.INFO) @LogMessage(level = Logger.Level.INFO)

View File

@ -484,8 +484,8 @@ public interface ActiveMQServerControl
/** /**
* Closes all the connections of clients connected to this server which matches the specified IP address. * Closes all the connections of clients connected to this server which matches the specified IP address.
*/ */
@Operation(desc = "Closes all the consumer connections for the given ActiveMQ address", impact = MBeanOperationInfo.INFO) @Operation(desc = "Closes all the consumer connections for the given messaging address", impact = MBeanOperationInfo.INFO)
boolean closeConsumerConnectionsForAddress(@Parameter(desc = "a ActiveMQ address", name = "address") String address) throws Exception; boolean closeConsumerConnectionsForAddress(@Parameter(desc = "a messaging address", name = "address") String address) throws Exception;
/** /**
* Closes all the connections of sessions with a matching user name. * Closes all the connections of sessions with a matching user name.

View File

@ -31,7 +31,7 @@ public class JMSManagementHelper
{ {
if (jmsMessage instanceof ActiveMQMessage == false) if (jmsMessage instanceof ActiveMQMessage == false)
{ {
throw new IllegalArgumentException("Cannot send a non ActiveMQ message as a management message " + jmsMessage.getClass() throw new IllegalArgumentException("Cannot send a foreign message as a management message " + jmsMessage.getClass()
.getName()); .getName());
} }

View File

@ -271,8 +271,8 @@ public interface JMSServerControl
/** /**
* Closes all the connections on this server for consumers which are consuming from a queue associated with a particular address. * Closes all the connections on this server for consumers which are consuming from a queue associated with a particular address.
*/ */
@Operation(desc = "Closes all the consumer connections for the given ActiveMQ address", impact = MBeanOperationInfo.INFO) @Operation(desc = "Closes all the consumer connections for the given messaging address", impact = MBeanOperationInfo.INFO)
boolean closeConsumerConnectionsForAddress(@Parameter(desc = "a ActiveMQ address", name = "address") String address) throws Exception; boolean closeConsumerConnectionsForAddress(@Parameter(desc = "a messaging address", name = "address") String address) throws Exception;
/** /**
* Closes all the connections on this server for sessions using a particular user name. * Closes all the connections on this server for sessions using a particular user name.

View File

@ -398,7 +398,7 @@ public class ActiveMQMessage implements javax.jms.Message
{ {
if (dest instanceof ActiveMQDestination == false) if (dest instanceof ActiveMQDestination == false)
{ {
throw new InvalidDestinationException("Not a ActiveMQ destination " + dest); throw new InvalidDestinationException("Foreign destination " + dest);
} }
ActiveMQDestination jbd = (ActiveMQDestination)dest; ActiveMQDestination jbd = (ActiveMQDestination)dest;

View File

@ -330,7 +330,7 @@ public class ActiveMQMessageProducer implements MessageProducer, QueueSender, To
{ {
if (destination != null && !(destination instanceof ActiveMQDestination)) if (destination != null && !(destination instanceof ActiveMQDestination))
{ {
throw new InvalidDestinationException("Not a ActiveMQ Destination:" + destination); throw new InvalidDestinationException("Foreign destination:" + destination);
} }
if (destination != null && defaultDestination != null) if (destination != null && defaultDestination != null)
{ {

View File

@ -905,7 +905,7 @@ public class JMSServerControlImpl extends AbstractControl implements JMSServerCo
{ {
if (!server.isStarted()) if (!server.isStarted())
{ {
throw new IllegalStateException("ActiveMQ JMS Server is not started. it can not be managed yet"); throw new IllegalStateException("ActiveMQ Artemis JMS Server is not started. It can not be managed yet");
} }
} }

View File

@ -66,7 +66,7 @@ public interface ActiveMQJMSServerLogger extends BasicLogger
void noQueueOnTopic(String queueName, String name); void noQueueOnTopic(String queueName, String name);
@LogMessage(level = Logger.Level.WARN) @LogMessage(level = Logger.Level.WARN)
@Message(id = 122008, value = "XA Recovery can not connect to any ActiveMQ server on recovery {0}" , format = Message.Format.MESSAGE_FORMAT) @Message(id = 122008, value = "XA Recovery can not connect to any broker on recovery {0}" , format = Message.Format.MESSAGE_FORMAT)
void recoveryConnectFailed(String s); void recoveryConnectFailed(String s);
@LogMessage(level = Logger.Level.WARN) @LogMessage(level = Logger.Level.WARN)

View File

@ -155,7 +155,7 @@ public class ActiveMQBootstrap
{ {
restartFile.delete(); restartFile.delete();
} }
final Timer timer = new Timer("ActiveMQ Server Shutdown Timer", false); final Timer timer = new Timer("ActiveMQ Artemis Server Shutdown Timer", false);
timer.scheduleAtFixedRate(new ServerStopTimerTask(stopFile, killFile, restartFile, timer), 500, 500); timer.scheduleAtFixedRate(new ServerStopTimerTask(stopFile, killFile, restartFile, timer), 500, 500);
} }
} }

View File

@ -155,7 +155,7 @@ public class ProtonServerSenderContext extends AbstractProtonContextSender imple
} }
catch (Exception e) catch (Exception e)
{ {
throw ActiveMQAMQPProtocolMessageBundle.BUNDLE.errorCreatingActiveMQConsumer(e.getMessage()); throw ActiveMQAMQPProtocolMessageBundle.BUNDLE.errorCreatingConsumer(e.getMessage());
} }
} }
} }

View File

@ -50,10 +50,10 @@ public interface ActiveMQAMQPProtocolMessageBundle
@Message(id = 219003, value = "error finding temporary queue, {0}", format = Message.Format.MESSAGE_FORMAT) @Message(id = 219003, value = "error finding temporary queue, {0}", format = Message.Format.MESSAGE_FORMAT)
ActiveMQAMQPInternalErrorException errorFindingTemporaryQueue(String message); ActiveMQAMQPInternalErrorException errorFindingTemporaryQueue(String message);
@Message(id = 219005, value = "error creating ActiveMQ Consumer, {0}", format = Message.Format.MESSAGE_FORMAT) @Message(id = 219005, value = "error creating consumer, {0}", format = Message.Format.MESSAGE_FORMAT)
ActiveMQAMQPInternalErrorException errorCreatingActiveMQConsumer(String message); ActiveMQAMQPInternalErrorException errorCreatingConsumer(String message);
@Message(id = 219006, value = "error starting ActiveMQ Consumer, {0}", format = Message.Format.MESSAGE_FORMAT) @Message(id = 219006, value = "error starting consumer, {0}", format = Message.Format.MESSAGE_FORMAT)
ActiveMQAMQPIllegalStateException errorStartingConsumer(String message); ActiveMQAMQPIllegalStateException errorStartingConsumer(String message);
@Message(id = 219007, value = "error acknowledging message {0}, {1}", format = Message.Format.MESSAGE_FORMAT) @Message(id = 219007, value = "error acknowledging message {0}, {1}", format = Message.Format.MESSAGE_FORMAT)

View File

@ -49,8 +49,8 @@ import static org.apache.activemq.artemis.core.protocol.stomp.ActiveMQStompProto
public final class StompConnection implements RemotingConnection public final class StompConnection implements RemotingConnection
{ {
protected static final String CONNECTION_ID_PROP = "__AMQ_CID"; protected static final String CONNECTION_ID_PROP = "__AMQ_CID";
private static final String SERVER_NAME = "ActiveMQ/" + VersionLoader.getVersion().getFullVersion() + private static final String SERVER_NAME = "ActiveMQ-Artemis/" + VersionLoader.getVersion().getFullVersion() +
" ActiveMQ Messaging Engine"; " ActiveMQ Artemis Messaging Engine";
private final StompProtocolManager manager; private final StompProtocolManager manager;

View File

@ -94,7 +94,7 @@ public class ActiveMQRAConnectionMetaData implements ConnectionMetaData
ActiveMQRALogger.LOGGER.trace("getJMSProviderName()"); ActiveMQRALogger.LOGGER.trace("getJMSProviderName()");
} }
return "ActiveMQ"; return "ActiveMQ Artemis";
} }
/** /**

View File

@ -58,11 +58,11 @@ public interface ActiveMQRALogger extends BasicLogger
void attemptingReconnect(ActiveMQActivationSpec spec); void attemptingReconnect(ActiveMQActivationSpec spec);
@LogMessage(level = Logger.Level.INFO) @LogMessage(level = Logger.Level.INFO)
@Message(id = 151002, value = "Reconnected with ActiveMQ", format = Message.Format.MESSAGE_FORMAT) @Message(id = 151002, value = "Reconnected with broker", format = Message.Format.MESSAGE_FORMAT)
void reconnected(); void reconnected();
@LogMessage(level = Logger.Level.INFO) @LogMessage(level = Logger.Level.INFO)
@Message(id = 151003, value = "ActiveMQ resource adaptor stopped", format = Message.Format.MESSAGE_FORMAT) @Message(id = 151003, value = "resource adaptor stopped", format = Message.Format.MESSAGE_FORMAT)
void raStopped(); void raStopped();
@LogMessage(level = Logger.Level.INFO) @LogMessage(level = Logger.Level.INFO)
@ -70,11 +70,11 @@ public interface ActiveMQRALogger extends BasicLogger
void instantiatingDestination(String destinationType, String destination); void instantiatingDestination(String destinationType, String destination);
@LogMessage(level = Logger.Level.INFO) @LogMessage(level = Logger.Level.INFO)
@Message(id = 151005, value = "awaiting ActiveMQ Server availability", format = Message.Format.MESSAGE_FORMAT) @Message(id = 151005, value = "awaiting server availability", format = Message.Format.MESSAGE_FORMAT)
void awaitingJMSServerCreation(); void awaitingJMSServerCreation();
@LogMessage(level = Logger.Level.WARN) @LogMessage(level = Logger.Level.WARN)
@Message(id = 152001, value = "problem resetting ActiveMQ xa session after failure", format = Message.Format.MESSAGE_FORMAT) @Message(id = 152001, value = "problem resetting xa session after failure", format = Message.Format.MESSAGE_FORMAT)
void problemResettingXASession(); void problemResettingXASession();
@LogMessage(level = Logger.Level.WARN) @LogMessage(level = Logger.Level.WARN)
@ -90,7 +90,7 @@ public interface ActiveMQRALogger extends BasicLogger
void handlingJMSFailure(@Cause Exception e); void handlingJMSFailure(@Cause Exception e);
@LogMessage(level = Logger.Level.WARN) @LogMessage(level = Logger.Level.WARN)
@Message(id = 152005, value = "Failure in ActiveMQ activation {0}", format = Message.Format.MESSAGE_FORMAT) @Message(id = 152005, value = "Failure in broker activation {0}", format = Message.Format.MESSAGE_FORMAT)
void failureInActivation(@Cause Throwable t, ActiveMQActivationSpec spec); void failureInActivation(@Cause Throwable t, ActiveMQActivationSpec spec);
@LogMessage(level = Logger.Level.WARN) @LogMessage(level = Logger.Level.WARN)
@ -102,7 +102,7 @@ public interface ActiveMQRALogger extends BasicLogger
void errorCreatingReference(@Cause Exception e); void errorCreatingReference(@Cause Exception e);
@LogMessage(level = Logger.Level.ERROR) @LogMessage(level = Logger.Level.ERROR)
@Message(id = 154001, value = "Unable to stop ActiveMQ resource adapter.", format = Message.Format.MESSAGE_FORMAT) @Message(id = 154001, value = "Unable to stop resource adapter.", format = Message.Format.MESSAGE_FORMAT)
void errorStoppingRA(@Cause Exception e); void errorStoppingRA(@Cause Exception e);
@LogMessage(level = Logger.Level.ERROR) @LogMessage(level = Logger.Level.ERROR)

View File

@ -57,7 +57,7 @@ public class ActiveMQRAMetaData implements ManagedConnectionMetaData
ActiveMQRALogger.LOGGER.trace("getEISProductName()"); ActiveMQRALogger.LOGGER.trace("getEISProductName()");
} }
return "ActiveMQ"; return "ActiveMQ Artemis";
} }
/** /**

View File

@ -68,7 +68,7 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable
/** /**
* The Name of the product that this resource adapter represents. * The Name of the product that this resource adapter represents.
*/ */
public static final String PRODUCT_NAME = "ActiveMQ"; public static final String PRODUCT_NAME = "ActiveMQ Artemis";
/** /**
* Trace enabled * Trace enabled
@ -262,7 +262,7 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable
} }
} }
ActiveMQRALogger.LOGGER.info("ActiveMQ resource adaptor started"); ActiveMQRALogger.LOGGER.info("Resource adaptor started");
} }
/** /**
@ -1982,7 +1982,7 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable
} }
else else
{ {
throw new IllegalArgumentException("must provide either TransportType or DiscoveryGroupAddress and DiscoveryGroupPort for ActiveMQ ResourceAdapter Connection Factory"); throw new IllegalArgumentException("must provide either TransportType or DiscoveryGroupAddress and DiscoveryGroupPort for ResourceAdapter Connection Factory");
} }
setParams(cf, overrideProperties); setParams(cf, overrideProperties);
@ -2041,7 +2041,7 @@ public class ActiveMQResourceAdapter implements ResourceAdapter, Serializable
} }
if (endpointFactory == null) if (endpointFactory == null)
{ {
throw new IllegalArgumentException("must provide either TransportType or DiscoveryGroupAddress and DiscoveryGroupPort for ActiveMQ ResourceAdapter Connection Factory"); throw new IllegalArgumentException("must provide either TransportType or DiscoveryGroupAddress and DiscoveryGroupPort for ResourceAdapter Connection Factory");
} }
} }

View File

@ -48,7 +48,7 @@ public class ActiveMQPushStrategy extends UriTemplateStrategy
ClientResponse<?> res = request.head(); ClientResponse<?> res = request.head();
if (res.getStatus() != 200) if (res.getStatus() != 200)
{ {
throw new RuntimeException("Failed to query ActiveMQ REST destination for init information. Status: " + res.getStatus()); throw new RuntimeException("Failed to query REST destination for init information. Status: " + res.getStatus());
} }
String url = (String)res.getHeaders().getFirst("msg-create-with-id"); String url = (String)res.getHeaders().getFirst("msg-create-with-id");
if (url == null) if (url == null)

View File

@ -1089,7 +1089,7 @@ public class ConfigurationImpl implements Configuration, Serializable
@Override @Override
public String toString() public String toString()
{ {
StringBuilder sb = new StringBuilder("ActiveMQ Configuration ("); StringBuilder sb = new StringBuilder("Broker Configuration (");
sb.append("clustered=").append(isClustered()).append(","); sb.append("clustered=").append(isClustered()).append(",");
sb.append("journalDirectory=").append(journalDirectory).append(","); sb.append("journalDirectory=").append(journalDirectory).append(",");
sb.append("bindingsDirectory=").append(bindingsDirectory).append(","); sb.append("bindingsDirectory=").append(bindingsDirectory).append(",");

View File

@ -2148,7 +2148,7 @@ public class ActiveMQServerControlImpl extends AbstractControl implements Active
{ {
if (!server.isStarted()) if (!server.isStarted())
{ {
throw new IllegalStateException("ActiveMQ Server is not started. It can not be managed yet"); throw new IllegalStateException("Broker is not started. It can not be managed yet");
} }
} }

View File

@ -1031,7 +1031,7 @@ public class QueueControlImpl extends AbstractControl implements QueueControl
{ {
if (!postOffice.isStarted()) if (!postOffice.isStarted())
{ {
throw new IllegalStateException("ActiveMQ Server is not started. Queue can not be managed yet"); throw new IllegalStateException("Broker is not started. Queue can not be managed yet");
} }
} }

View File

@ -66,7 +66,7 @@ public interface ActiveMQXARecoveryLogger extends BasicLogger
void noQueueOnTopic(String queueName, String name); void noQueueOnTopic(String queueName, String name);
@LogMessage(level = Logger.Level.WARN) @LogMessage(level = Logger.Level.WARN)
@Message(id = 122008, value = "XA Recovery can not connect to any ActiveMQ server on recovery {0}" , format = Message.Format.MESSAGE_FORMAT) @Message(id = 122008, value = "XA Recovery can not connect to any broker on recovery {0}" , format = Message.Format.MESSAGE_FORMAT)
void recoveryConnectFailed(String s); void recoveryConnectFailed(String s);
@LogMessage(level = Logger.Level.WARN) @LogMessage(level = Logger.Level.WARN)

View File

@ -1111,7 +1111,7 @@ public abstract class ClusterTestBase extends ServiceTestBase
{ {
String br = "-------------------------\n"; String br = "-------------------------\n";
String out = br; String out = br;
out += "ActiveMQ server " + server + "\n"; out += "ActiveMQ Artemis server " + server + "\n";
ClusterManager clusterManager = server.getClusterManager(); ClusterManager clusterManager = server.getClusterManager();
if (clusterManager == null) if (clusterManager == null)
{ {