diff --git a/activemq-cpp/src/examples/main.cpp b/activemq-cpp/src/examples/main.cpp index 9cc513a82..02a2b29ea 100644 --- a/activemq-cpp/src/examples/main.cpp +++ b/activemq-cpp/src/examples/main.cpp @@ -359,7 +359,7 @@ int main(int argc AMQCPP_UNUSED, char* argv[] AMQCPP_UNUSED) { // System::setProperty( "decaf.net.ssl.keyStorePassword", "password" ); // System::setProperty( "decaf.net.ssl.trustStore", "/rootCA.pem" ); // - // The you just specify the ssl transport in the URI, for example: + // Then you just specify the ssl transport in the URI, for example: // // ssl://localhost:61617 // @@ -386,7 +386,7 @@ int main(int argc AMQCPP_UNUSED, char* argv[] AMQCPP_UNUSED) { long long startTime = System::currentTimeMillis(); HelloWorldProducer producer(brokerURI, numMessages, useTopics); - HelloWorldConsumer consumer(brokerURI, numMessages, useTopics, sessionTransacted); + HelloWorldConsumer consumer(brokerURI, numMessages, useTopics, sessionTransacted); // Start the consumer thread. Thread consumerThread(&consumer); diff --git a/activemq-cpp/src/examples/stress-test/Receiver.cpp b/activemq-cpp/src/examples/stress-test/Receiver.cpp index 6814af87c..6e48a28a3 100644 --- a/activemq-cpp/src/examples/stress-test/Receiver.cpp +++ b/activemq-cpp/src/examples/stress-test/Receiver.cpp @@ -194,7 +194,7 @@ void Receiver::registerMessageListener(ReceiverListener* messageListener, ErrorC return; } - if (messageListener != NULL) { + if (this->messageListener != NULL) { errorCode = CMS_ERROR_A_MESSAGELISTENER_HAS_BEEN_REGISTERED_ALREADY; mutexGeneral.unlock(); return; diff --git a/activemq-cpp/src/main/cms/MessageConsumer.h b/activemq-cpp/src/main/cms/MessageConsumer.h index 6ae878b30..5734dbd92 100644 --- a/activemq-cpp/src/main/cms/MessageConsumer.h +++ b/activemq-cpp/src/main/cms/MessageConsumer.h @@ -105,7 +105,7 @@ namespace cms { virtual void setMessageListener(MessageListener* listener) = 0; /** - * Gets the MessageListener that this class will send mew Message + * Gets the MessageListener that this class will send new Message * notification events to. * * @return The listener of messages received by this consumer @@ -155,7 +155,7 @@ namespace cms { virtual void setMessageAvailableListener(cms::MessageAvailableListener* listener) = 0; /** - * Gets the MessageAvailableListener that this class will send mew Message + * Gets the MessageAvailableListener that this class will send new Message * notification events to. * * @return The listener of message events received by this consumer.