Apache
/
activemq-artemis
mirror of https://github.com/apache/activemq-artemis.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Spelling fixes

This commit is contained in:
Ville Skyttä 2016-08-25 12:53:30 +03:00 committed by Clebert Suconic
parent 8c6e044745
commit e1728f0797
26 changed files with 45 additions and 46 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
artemis-core-client/src/main/java/org/apache/activemq/artemis/spi/core/protocol/RemotingConnection.java
View File

@ -105,7 +105,7 @@ public interface RemotingConnection extends BufferHandler {
/**
* set the failure listeners.
* <p>
* These will be called in the event of the connection being closed. Any previosuly added listeners will be removed.
* These will be called in the event of the connection being closed. Any previously added listeners will be removed.
*
* @param listeners the listeners to add.
*/

32
artemis-core-client/src/test/java/org/apache/activemq/artemis/util/CompressionUtilTest.java
View File

@ -60,10 +60,10 @@ public class CompressionUtilTest extends Assert {
}
byte[] output = new byte[30];
Deflater compresser = new Deflater();
compresser.setInput(input);
compresser.finish();
int compressedDataLength = compresser.deflate(output);
Deflater compressor = new Deflater();
compressor.setInput(input);
compressor.finish();
int compressedDataLength = compressor.deflate(output);
compareByteArray(allCompressed, output, compressedDataLength);
}
@ -97,10 +97,10 @@ public class CompressionUtilTest extends Assert {
}
byte[] output = new byte[30];
Deflater compresser = new Deflater();
compresser.setInput(input);
compresser.finish();
int compressedDataLength = compresser.deflate(output);
Deflater compressor = new Deflater();
compressor.setInput(input);
compressor.finish();
int compressedDataLength = compressor.deflate(output);
compareByteArray(allCompressed, output, compressedDataLength);
}
@ -110,10 +110,10 @@ public class CompressionUtilTest extends Assert {
String inputString = "blahblahblah??blahblahblahblahblah??blablahblah??blablahblah??bla";
byte[] input = inputString.getBytes(StandardCharsets.UTF_8);
byte[] output = new byte[30];
Deflater compresser = new Deflater();
compresser.setInput(input);
compresser.finish();
int compressedDataLength = compresser.deflate(output);
Deflater compressor = new Deflater();
compressor.setInput(input);
compressor.finish();
int compressedDataLength = compressor.deflate(output);
byte[] zipBytes = new byte[compressedDataLength];
@ -146,10 +146,10 @@ public class CompressionUtilTest extends Assert {
String inputString = "blahblahblah??blahblahblahblahblah??blablahblah??blablahblah??bla";
byte[] input = inputString.getBytes(StandardCharsets.UTF_8);
byte[] output = new byte[30];
Deflater compresser = new Deflater();
compresser.setInput(input);
compresser.finish();
int compressedDataLength = compresser.deflate(output);
Deflater compressor = new Deflater();
compressor.setInput(input);
compressor.finish();
int compressedDataLength = compressor.deflate(output);
byte[] zipBytes = new byte[compressedDataLength];

2
artemis-dto/src/main/java/org/apache/activemq/artemis/dto/XmlUtil.java
View File

@ -79,7 +79,7 @@ public class XmlUtil {
return decode(clazz, configuration, null, null);
}
/** We offer parameters for artemisInstance and artemisHoms as they could be coming from the CLI or Maven Plugin */
/** We offer parameters for artemisInstance and artemisHome as they could be coming from the CLI or Maven Plugin */
public static <T> T decode(Class<T> clazz, File configuration, String artemisHome, String artemisInstance) throws Exception {
JAXBContext jaxbContext = JAXBContext.newInstance("org.apache.activemq.artemis.dto");

2
artemis-native/src/main/c/org_apache_activemq_artemis_jlibaio_LibaioContext.c
View File

@ -48,7 +48,7 @@ struct io_control {
pthread_mutex_t pollLock;
// a resuable pool of iocb
// a reusable pool of iocb
struct iocb ** iocb;
int queueSize;
int iocbPut;

2
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/proton/converter/jms/ServerDestination.java
View File

@ -22,7 +22,7 @@ import javax.jms.JMSException;
import javax.jms.Queue;
/**
* This is just here to avoid all the client checks we ned with valid JMS destinations, protocol convertors don't need to
* This is just here to avoid all the client checks we need with valid JMS destinations, protocol convertors don't need to
* adhere to the jms. semantics.
*/
public class ServerDestination extends ActiveMQDestination implements Queue {

2
artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/openwire/OpenWireConnection.java
View File

@ -477,7 +477,7 @@ public class OpenWireConnection extends AbstractRemotingConnection implements Se
if (context.isReconnect() || (context.isNetworkConnection())) {
// once implemented ARTEMIS-194, we need to set the storedSequenceID here somehow
// We have different semantics on Artemis Journal, but we could adapt something for this
// TBD during the implemetnation of ARTEMIS-194
// TBD during the implementation of ARTEMIS-194
result.setLastStoredSequenceId(0);
}
SessionState ss = state.getSessionState(id.getParentId());

4
artemis-rest/src/main/java/org/apache/activemq/artemis/rest/queue/PostMessageNoDups.java
View File

@ -24,7 +24,7 @@ import javax.ws.rs.core.Response;
import javax.ws.rs.core.UriInfo;
/**
* implements reliable "create", "create-next" pattern defined by REST-* Messaging specificaiton
* implements reliable "create", "create-next" pattern defined by REST-* Messaging specification
*/
public class PostMessageNoDups extends PostMessage {
@ -37,4 +37,4 @@ public class PostMessageNoDups extends PostMessage {
res.location(uriInfo.getAbsolutePathBuilder().path(id).build());
return res.build();
}
}
}

3
artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueImpl.java
View File

@ -615,7 +615,7 @@ public class QueueImpl implements Queue {
}
if (logger.isTraceEnabled()) {
logger.trace("Force delivery deliverying async");
logger.trace("Force delivery delivering async");
}
deliverAsync();
@ -3045,4 +3045,3 @@ public class QueueImpl implements Queue {
}
}
}

2
artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/SharedNothingLiveActivation.java
View File

@ -304,7 +304,7 @@ public class SharedNothingLiveActivation extends LiveActivation {
NodeManager nodeManagerInUse = activeMQServer.getNodeManager();
if (nodeManagerInUse != null) {
//todo does this actually make any difference, we only set a different flag in the lock file which replication doesnt use
//todo does this actually make any difference, we only set a different flag in the lock file which replication doesn't use
if (permanently) {
nodeManagerInUse.crashLiveServer();
}

2
artemis-server/src/main/java/org/apache/activemq/artemis/spi/core/protocol/ProtocolManager.java
View File

@ -56,7 +56,7 @@ public interface ProtocolManager<P extends BaseInterceptor> {
MessageConverter getConverter();
/** If this protocols accepts connectoins without an initial handshake.
* If true this protocol will be the failback case no other conenctions are made.
* If true this protocol will be the failback case no other connections are made.
* New designed protocols should always require a handshake. This is only useful for legacy protocols. */
boolean acceptsNoHandshake();

4
docs/hacking-guide/en/ide.md
View File

@ -49,7 +49,7 @@ imported properly. To (re)import the "tests" Maven profile in an existing proje
* Open the Maven Projects Tool Window: View -> Tool Windows -> Maven Projects
* Select the "profiles" drop down
* Unselect then reselect the checkbox next to "tests".
* Click on the "Reimport all maven projects" button in the top left hand corner of the window. (It looks like a ciruclar
* Click on the "Reimport all maven projects" button in the top left hand corner of the window. (It looks like a circular
blue arrow.
* Wait for IDEA to reload and try running a JUnit test again. The option to run should now be present.
@ -94,4 +94,4 @@ Importing all ActiveMQ Artemis subprojects will create _too many_ projects in Ec
and _Project Explorer_ views. One way to address that is to use
[Eclipse's Working Sets](http://help.eclipse.org/juno/index.jsp?topic=%2Forg.eclipse.platform.doc.user%2Fconcepts%2Fcworkset.htm)
feature. A good introduction to it can be found at a
[Dzone article on Eclipse Working Sets](http://eclipse.dzone.com/articles/categorise-projects-package).
[Dzone article on Eclipse Working Sets](http://eclipse.dzone.com/articles/categorise-projects-package).

2
docs/user-manual/en/aerogear-integration.md
View File

@ -35,7 +35,7 @@ Shown are the required params for the connector service and are:
- `master-secret`. The secret of your mobile application in AeroGear.
As well as these required paramaters there are the following optional
As well as these required parameters there are the following optional
parameters
- `ttl`. The time to live for the message once AeroGear receives it.

2
docs/user-manual/en/vertx-integration.md
View File

@ -64,7 +64,7 @@ Shown are the required params for the connector service:
- `queue`. The name of the Apache ActiveMQ Artemis queue to fetch message from.
As well as these required paramaters there are the following optional
As well as these required parameters there are the following optional
parameters
- `host`. The host name on which the vertx target container is

2
examples/features/ha/ha-policy-autobackup/src/main/java/org/apache/activemq/artemis/jms/example/HAPolicyAutoBackupExample.java
View File

@ -103,7 +103,7 @@ public class HAPolicyAutoBackupExample {
System.out.println("Got message: " + message0.getText() + " from node 0");
}
// Step 14.close the consumer so it doesnt get any messages
// Step 14.close the consumer so it doesn't get any messages
consumer1.close();
// Step 15.now kill server1, messages will be scaled down to server0

2
examples/features/perf/perf/src/main/java/org/apache/activemq/artemis/jms/example/PerfBase.java
View File

@ -88,7 +88,7 @@ public abstract class PerfBase {
boolean drainQueue = Boolean.valueOf(props.getProperty("drain-queue"));
String destinationName = props.getProperty("destination-name");
int throttleRate = Integer.valueOf(props.getProperty("throttle-rate"));
boolean dupsOK = Boolean.valueOf(props.getProperty("dups-ok-acknowlege"));
boolean dupsOK = Boolean.valueOf(props.getProperty("dups-ok-acknowledge"));
boolean disableMessageID = Boolean.valueOf(props.getProperty("disable-message-id"));
boolean disableTimestamp = Boolean.valueOf(props.getProperty("disable-message-timestamp"));
String clientLibrary = props.getProperty("client-library", "core");

2
examples/features/perf/soak/src/main/java/org/apache/activemq/artemis/jms/soak/example/SoakBase.java
View File

@ -69,7 +69,7 @@ public class SoakBase {
String destinationLookup = props.getProperty("destination-lookup");
String connectionFactoryLookup = props.getProperty("connection-factory-lookup");
int throttleRate = Integer.valueOf(props.getProperty("throttle-rate"));
boolean dupsOK = Boolean.valueOf(props.getProperty("dups-ok-acknowlege"));
boolean dupsOK = Boolean.valueOf(props.getProperty("dups-ok-acknowledge"));
boolean disableMessageID = Boolean.valueOf(props.getProperty("disable-message-id"));
boolean disableTimestamp = Boolean.valueOf(props.getProperty("disable-message-timestamp"));

2
integration/activemq-aerogear-integration/src/main/java/org/apache/activemq/artemis/integration/aerogear/ActiveMQAeroGearLogger.java
View File

@ -57,7 +57,7 @@ public interface ActiveMQAeroGearLogger extends BasicLogger {
void reply404();
@LogMessage(level = Logger.Level.WARN)
@Message(id = 232005, value = "removing aerogear connector as unexpected respone {0} returned", format = Message.Format.MESSAGE_FORMAT)
@Message(id = 232005, value = "removing aerogear connector as unexpected response {0} returned", format = Message.Format.MESSAGE_FORMAT)
void replyUnknown(int status);
@LogMessage(level = Logger.Level.WARN)

2
pom.xml
View File

@ -198,7 +198,7 @@
<dependencyManagement>
<dependencies>
<!-- ## Test Dependenices ## Note: Junit is required in certain module tests. We should control versions from here. -->
<!-- ## Test Dependencies ## Note: Junit is required in certain module tests. We should control versions from here. -->
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>

2
tests/activemq5-unit-tests/src/test/java/org/apache/activemq/EmbeddedBrokerTestSupport.java
View File

@ -128,7 +128,7 @@ public abstract class EmbeddedBrokerTestSupport extends CombinationTestSupport {
/**
* Factory method to create a new {@link Destination}
*
* @return newly created Destinaiton
* @return newly created Destination
*/
protected ActiveMQDestination createDestination() {
return createDestination(getDestinationString());

2
tests/activemq5-unit-tests/src/test/java/org/apache/activemq/OptimizedAckTest.java
View File

@ -69,7 +69,7 @@ public class OptimizedAckTest extends TestSupport {
Binding binding = broker.getServer().getPostOffice().getBinding(new SimpleString("jms.queue.test"));
final QueueImpl coreQueue = (QueueImpl) binding.getBindable();
assertTrue("deliverying count is 10", Wait.waitFor(new Wait.Condition() {
assertTrue("delivering count is 10", Wait.waitFor(new Wait.Condition() {
@Override
public boolean isSatisified() throws Exception {
return 10 == coreQueue.getDeliveringCount();

2
tests/activemq5-unit-tests/src/test/java/org/apache/activemq/security/SecurityJMXTest.java
View File

@ -85,7 +85,7 @@ public class SecurityJMXTest extends TestCase {
Connection c = new ActiveMQConnectionFactory("vm://localhost").createConnection("system", "manager");
c.start();
// browser consumer will force expriation check on addConsumer
// browser consumer will force expiration check on addConsumer
QueueBrowser browser = c.createSession(false, Session.AUTO_ACKNOWLEDGE).createBrowser(new ActiveMQQueue("TEST.Q"));
assertTrue("no message in the q", !browser.getEnumeration().hasMoreElements());

2
tests/activemq5-unit-tests/src/test/java/org/apache/activemq/transport/failover/FailoverTransactionTest.java
View File

@ -875,7 +875,7 @@ public class FailoverTransactionTest extends OpenwireArtemisBaseTest {
try {
consumerSession.commit();
Assert.fail("expected transaciton rolledback ex");
Assert.fail("expected transaction rolledback ex");
}
catch (TransactionRolledBackException expected) {
}

6
tests/activemq5-unit-tests/src/test/java/org/apache/activemq/usecases/NonBlockingConsumerRedeliveryTest.java
View File

@ -312,7 +312,7 @@ public class NonBlockingConsumerRedeliveryTest {
count = 0;
}
catch (JMSException e) {
LOG.warn("Caught an unexcepted exception: " + e.getMessage());
LOG.warn("Caught an unexpected exception: " + e.getMessage());
}
}
else {
@ -321,7 +321,7 @@ public class NonBlockingConsumerRedeliveryTest {
session.commit();
}
catch (JMSException e) {
LOG.warn("Caught an unexcepted exception: " + e.getMessage());
LOG.warn("Caught an unexpected exception: " + e.getMessage());
}
}
}
@ -388,7 +388,7 @@ public class NonBlockingConsumerRedeliveryTest {
session.rollback();
}
catch (JMSException e) {
LOG.warn("Caught an unexcepted exception: " + e.getMessage());
LOG.warn("Caught an unexpected exception: " + e.getMessage());
}
}
});

2
tests/activemq5-unit-tests/src/test/java/org/apache/activemq/usecases/StartAndStopBrokerTest.java
View File

@ -36,7 +36,7 @@ public class StartAndStopBrokerTest extends TestCase {
// have persistence messages as a default
System.setProperty("activemq.persistenceAdapter", "org.apache.activemq.store.vm.VMPersistenceAdapter");
// configuration of container and all protocolls
// configuration of container and all protocols
BrokerService broker = createBroker();
// start a client

2
tests/jms-tests/src/test/java/org/apache/activemq/artemis/jms/tests/tools/container/Server.java
View File

@ -53,7 +53,7 @@ public interface Server extends Remote {
void kill() throws Exception;
/**
* When kill is called you are actually schedulling the server to be killed in few milliseconds.
* When kill is called you are actually scheduling the server to be killed in few milliseconds.
* There are certain cases where we need to assure the server was really killed.
* For that we have this simple ping we can use to verify if the server still alive or not.
*/

2
tests/joram-tests/src/test/java/org/objectweb/jtests/jms/conform/connection/TopicConnectionTest.java
View File

@ -26,7 +26,7 @@ import org.objectweb.jtests.jms.framework.PubSubTestCase;
/**
* Test topic-specific connection features.
*
* Test setting of client ID which is relevant only for Durable Subscribtion
* Test setting of client ID which is relevant only for Durable Subscription
*/
public class TopicConnectionTest extends PubSubTestCase {