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

Fix some typos

This commit is contained in:
Daniel Trebbien 2017-07-28 19:23:27 -07:00 committed by Colm O hEigeartaigh
parent 3faad9b357
commit 7b528ecee7
8 changed files with 24 additions and 24 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
activemq-broker/src/main/java/org/apache/activemq/broker/BrokerService.java
View File

@ -2163,7 +2163,7 @@ public class BrokerService implements Service {
/** /**
* Schedules a periodic task based on schedulePeriodForDiskLimitCheck to * Schedules a periodic task based on schedulePeriodForDiskLimitCheck to
* update store and temporary store limits if the amount of available space * update store and temporary store limits if the amount of available space
* plus current store size is less than the existin configured limit * plus current store size is less than the existing configured limit
*/ */
protected void scheduleDiskUsageLimitsCheck() throws IOException { protected void scheduleDiskUsageLimitsCheck() throws IOException {
if (schedulePeriodForDiskUsageCheck > 0 && if (schedulePeriodForDiskUsageCheck > 0 &&

2
activemq-broker/src/main/java/org/apache/activemq/broker/region/cursors/StoreDurableSubscriberCursor.java
View File

@ -199,7 +199,7 @@ public class StoreDurableSubscriberCursor extends AbstractPendingMessageCursor {
if (prioritizedMessages && immediatePriorityDispatch && tsp.isPaging()) { if (prioritizedMessages && immediatePriorityDispatch && tsp.isPaging()) {
if (msg.getPriority() > tsp.getLastRecoveredPriority()) { if (msg.getPriority() > tsp.getLastRecoveredPriority()) {
tsp.recoverMessage(node.getMessage(), true); tsp.recoverMessage(node.getMessage(), true);
LOG.trace("cached high priority ({} message: {}, current paged batch priority: {}, cache size: {}", new Object[]{ msg.getPriority(), msg.getMessageId(), tsp.getLastRecoveredPriority(), tsp.batchList.size()}); LOG.trace("cached high priority ({}) message: {}, current paged batch priority: {}, cache size: {}", new Object[]{ msg.getPriority(), msg.getMessageId(), tsp.getLastRecoveredPriority(), tsp.batchList.size()});
} }
} }
} }

2
activemq-broker/src/main/java/org/apache/activemq/broker/region/cursors/TopicStorePrefetch.java
View File

@ -28,7 +28,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
/** /**
* persist pendingCount messages pendingCount message (messages awaiting disptach * persist pendingCount messages pendingCount message (messages awaiting dispatch
* to a consumer) cursor * to a consumer) cursor
* *
* *

34
activemq-broker/src/test/java/org/apache/activemq/JmsTransactionTestSupport.java
View File

@ -162,7 +162,7 @@ public abstract class JmsTransactionTestSupport extends TestSupport implements M
TextMessage message = session.createTextMessage("Batch Message"); TextMessage message = session.createTextMessage("Batch Message");
for (int j = 0; j < batchCount; j++) { for (int j = 0; j < batchCount; j++) {
LOG.info("Producing bacth " + j + " of " + batchSize + " messages"); LOG.info("Producing batch " + j + " of " + batchSize + " messages");
beginTx(); beginTx();
for (int i = 0; i < batchSize; i++) { for (int i = 0; i < batchSize; i++) {
@ -170,7 +170,7 @@ public abstract class JmsTransactionTestSupport extends TestSupport implements M
} }
messageSent(); messageSent();
commitTx(); commitTx();
LOG.info("Consuming bacth " + j + " of " + batchSize + " messages"); LOG.info("Consuming batch " + j + " of " + batchSize + " messages");
beginTx(); beginTx();
for (int i = 0; i < batchSize; i++) { for (int i = 0; i < batchSize; i++) {
@ -187,7 +187,7 @@ public abstract class JmsTransactionTestSupport extends TestSupport implements M
} }
/** /**
* Sends a batch of messages and validates that the rollbacked message was * Sends a batch of messages and validates that the rolled-back message was
* not consumed. * not consumed.
* *
* @throws Exception * @throws Exception
@ -200,7 +200,7 @@ public abstract class JmsTransactionTestSupport extends TestSupport implements M
producer.send(outbound[0]); producer.send(outbound[0]);
commitTx(); commitTx();
// sends a message that gets rollbacked // sends a message that gets rolled-back
beginTx(); beginTx();
producer.send(session.createTextMessage("I'm going to get rolled back.")); producer.send(session.createTextMessage("I'm going to get rolled back."));
rollbackTx(); rollbackTx();
@ -224,7 +224,7 @@ public abstract class JmsTransactionTestSupport extends TestSupport implements M
messages.add(message); messages.add(message);
LOG.info("Received: " + message); LOG.info("Received: " + message);
// validates that the rollbacked was not consumed // validates that the rolled-back was not consumed
commitTx(); commitTx();
Message inbound[] = new Message[messages.size()]; Message inbound[] = new Message[messages.size()];
messages.toArray(inbound); messages.toArray(inbound);
@ -253,7 +253,7 @@ public abstract class JmsTransactionTestSupport extends TestSupport implements M
messages.add(message); messages.add(message);
LOG.info("Received: " + message); LOG.info("Received: " + message);
// validates that the rollbacked was not consumed // validates that the rolled-back was not consumed
commitTx(); commitTx();
Message inbound[] = new Message[messages.size()]; Message inbound[] = new Message[messages.size()];
messages.toArray(inbound); messages.toArray(inbound);
@ -275,7 +275,7 @@ public abstract class JmsTransactionTestSupport extends TestSupport implements M
producer.send(outbound[0]); producer.send(outbound[0]);
commitTx(); commitTx();
// sends a message that gets rollbacked // sends a message that gets rolled-back
beginTx(); beginTx();
producer.send(session.createTextMessage("I'm going to get rolled back.")); producer.send(session.createTextMessage("I'm going to get rolled back."));
consumer.close(); consumer.close();
@ -300,7 +300,7 @@ public abstract class JmsTransactionTestSupport extends TestSupport implements M
messages.add(message); messages.add(message);
LOG.info("Received: " + message); LOG.info("Received: " + message);
// validates that the rollbacked was not consumed // validates that the rolled-back was not consumed
commitTx(); commitTx();
Message inbound[] = new Message[messages.size()]; Message inbound[] = new Message[messages.size()];
messages.toArray(inbound); messages.toArray(inbound);
@ -321,7 +321,7 @@ public abstract class JmsTransactionTestSupport extends TestSupport implements M
producer.send(outbound[0]); producer.send(outbound[0]);
commitTx(); commitTx();
// sends a message that gets rollbacked // sends a message that gets rolled-back
beginTx(); beginTx();
producer.send(session.createTextMessage("I'm going to get rolled back.")); producer.send(session.createTextMessage("I'm going to get rolled back."));
consumer.close(); consumer.close();
@ -348,7 +348,7 @@ public abstract class JmsTransactionTestSupport extends TestSupport implements M
messages.add(message); messages.add(message);
LOG.info("Received: " + message); LOG.info("Received: " + message);
// validates that the rollbacked was not consumed // validates that the rolled-back was not consumed
commitTx(); commitTx();
Message inbound[] = new Message[messages.size()]; Message inbound[] = new Message[messages.size()];
messages.toArray(inbound); messages.toArray(inbound);
@ -356,7 +356,7 @@ public abstract class JmsTransactionTestSupport extends TestSupport implements M
} }
/** /**
* Sends a batch of messages and validates that the rollbacked message was * Sends a batch of messages and validates that the rolled-back message was
* redelivered. * redelivered.
* *
* @throws Exception * @throws Exception
@ -407,7 +407,7 @@ public abstract class JmsTransactionTestSupport extends TestSupport implements M
} }
/** /**
* Sends a batch of messages and validates that the rollbacked message was * Sends a batch of messages and validates that the rolled-back message was
* redelivered. * redelivered.
* *
* @throws Exception * @throws Exception
@ -461,7 +461,7 @@ public abstract class JmsTransactionTestSupport extends TestSupport implements M
} }
/** /**
* Sends a batch of messages and validates that the rollbacked message was * Sends a batch of messages and validates that the rolled-back message was
* not consumed. * not consumed.
* *
* @throws Exception * @throws Exception
@ -487,12 +487,12 @@ public abstract class JmsTransactionTestSupport extends TestSupport implements M
LOG.info("Received: " + message); LOG.info("Received: " + message);
} }
// validates that the rollbacked was not consumed // validates that the rolled-back was not consumed
commitTx(); commitTx();
} }
/** /**
* Perform the test that validates if the rollbacked message was redelivered * Perform the test that validates if the rolled-back message was redelivered
* multiple times. * multiple times.
* *
* @throws Exception * @throws Exception
@ -504,7 +504,7 @@ public abstract class JmsTransactionTestSupport extends TestSupport implements M
} }
/** /**
* Sends a batch of messages and validates that the rollbacked message was * Sends a batch of messages and validates that the rolled-back message was
* not consumed. This test differs by setting the message prefetch to one. * not consumed. This test differs by setting the message prefetch to one.
* *
* @throws Exception * @throws Exception
@ -515,7 +515,7 @@ public abstract class JmsTransactionTestSupport extends TestSupport implements M
} }
/** /**
* Sends a batch of messages and and validates that the rollbacked message * Sends a batch of messages and and validates that the rolled-back message
* was redelivered. This test differs by setting the message prefetch to * was redelivered. This test differs by setting the message prefetch to
* one. * one.
* *

2
activemq-client/src/main/java/org/apache/activemq/ActiveMQMessageConsumer.java
View File

@ -819,7 +819,7 @@ public class ActiveMQMessageConsumer implements MessageAvailableConsumer, StatsC
try { try {
session.sendAck(ackToSend,true); session.sendAck(ackToSend,true);
} catch (JMSException e) { } catch (JMSException e) {
LOG.error(getConsumerId() + " failed to delivered acknowledgements", e); LOG.error(getConsumerId() + " failed to deliver acknowledgements", e);
} finally { } finally {
deliveryingAcknowledgements.set(false); deliveryingAcknowledgements.set(false);
} }

2
activemq-client/src/main/java/org/apache/activemq/jndi/JNDIReferenceFactory.java
View File

@ -40,7 +40,7 @@ public class JNDIReferenceFactory implements ObjectFactory {
/** /**
* This will be called by a JNDIprovider when a Reference is retrieved from * This will be called by a JNDIprovider when a Reference is retrieved from
* a JNDI store - and generates the orignal instance * a JNDI store - and generates the original instance
* *
* @param object the Reference object * @param object the Reference object
* @param name the JNDI name * @param name the JNDI name

2
activemq-client/src/main/java/org/apache/activemq/util/IdGenerator.java
View File

@ -184,7 +184,7 @@ public class IdGenerator {
/** /**
* From a generated id - return the seed (i.e. minus the count) * From a generated id - return the seed (i.e. minus the count)
* *
* @param id the generated identifer * @param id the generated identifier
* @return the seed * @return the seed
*/ */
public static String getSeedFromId(String id) { public static String getSeedFromId(String id) {

2
activemq-jms-pool/src/main/java/org/apache/activemq/jms/pool/PooledConnection.java
View File

@ -256,7 +256,7 @@ public class PooledConnection implements TopicConnection, QueueConnection, Poole
try { try {
session.close(); session.close();
} catch (JMSException ex) { } catch (JMSException ex) {
LOG.info("failed to close laoned Session \"" + session + "\" on closing pooled connection: " + ex.getMessage()); LOG.info("failed to close loaned Session \"" + session + "\" on closing pooled connection: " + ex.getMessage());
} }
} }
loanedSessions.clear(); loanedSessions.clear();