/*
?*?Licensed?to?the?Apache?Software?Foundation?（ASF）?under?one?or?more
?*?contributor?license?agreements.??See?the?NOTICE?file?distributed?with
?*?this?work?for?additional?information?regarding?copyright?ownership.
?*?The?ASF?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.
?*/

//?START?SNIPPET:?demo

#include?
#include?
#include?
#include?
#include?
#include?
#include?
#include?
#include?
#include?
#include?
#include?
#include?
#include?
#include?
#include?
#include?
#include?
#include?
#include?

using?namespace?activemq::core;
using?namespace?decaf::util::concurrent;
using?namespace?decaf::util;
using?namespace?decaf::lang;
using?namespace?cms;
using?namespace?std;

#pragma?comment（lib?“ws2_32.lib“）;

class?HelloWorldProducer?:?public?Runnable?{
private:

????Connection*?connection;
????Session*?session;
????Destination*?destination;
????MessageProducer*?producer;
????int?numMessages;
????bool?useTopic;
????bool?sessionTransacted;
????std::string?brokerURI;

private:

????HelloWorldProducer（const?HelloWorldProducer&）;
????HelloWorldProducer&?operator=（const?HelloWorldProducer&）;

public:

????HelloWorldProducer（const?std::string&?brokerURI?int?numMessages?bool?useTopic?=?false?bool?sessionTransacted?=?false）?:
????????connection（NULL）
????????session（NULL）
????????destination（NULL）
????????producer（NULL）
????????numMessages（numMessages）
????????useTopic（useTopic）
????????sessionTransacted（sessionTransacted）
????????brokerURI（brokerURI）?{
????}

????virtual?~HelloWorldProducer（）{
????????cleanup（）;
????}

????void?close（）?{
????????this->cleanup（）;
????}

????virtual?void?run（）?{

????????try?{

????????????//?Create?a?ConnectionFactory
????????????auto_ptr?connectionFactory（
????????????????ConnectionFactory::createCMSConnectionFactory（brokerURI））;

????????????//?Create?a?Connection
????????????connection?=?connectionFactory->createConnection（）;
????????????connection->start（）;

???????????

?屬性????????????大小?????日期????時間???名稱
-----------?---------??----------?-----??----

?????文件???????1159??2019-11-22?13:57??ActiveMQ\.qmake.stash

?????文件???????3584??2019-11-22?15:46??ActiveMQ\.vs\ActiveMQ\v14\.suo

?????文件???????1503??2019-11-22?15:52??ActiveMQ\ActiveMQ.pro

?????文件???????1183??2015-12-15?15:44??ActiveMQ\include\activemq\cmsutil\CachedConsumer.cpp

?????文件???????3143??2015-12-15?15:44??ActiveMQ\include\activemq\cmsutil\CachedConsumer.h

?????文件???????1180??2015-12-15?15:44??ActiveMQ\include\activemq\cmsutil\CachedProducer.cpp

?????文件???????4623??2015-12-15?15:44??ActiveMQ\include\activemq\cmsutil\CachedProducer.h

?????文件???????2936??2015-12-15?15:44??ActiveMQ\include\activemq\cmsutil\CmsAccessor.cpp

?????文件???????5624??2015-12-15?15:44??ActiveMQ\include\activemq\cmsutil\CmsAccessor.h

?????文件???????2607??2015-12-15?15:44??ActiveMQ\include\activemq\cmsutil\CmsDestinationAccessor.cpp

?????文件???????2893??2015-12-15?15:44??ActiveMQ\include\activemq\cmsutil\CmsDestinationAccessor.h

?????文件??????22110??2015-12-15?15:44??ActiveMQ\include\activemq\cmsutil\CmsTemplate.cpp

?????文件??????26061??2015-12-15?15:44??ActiveMQ\include\activemq\cmsutil\CmsTemplate.h

?????文件???????1024??2015-12-15?15:44??ActiveMQ\include\activemq\cmsutil\DestinationResolver.cpp

?????文件???????2716??2015-12-15?15:44??ActiveMQ\include\activemq\cmsutil\DestinationResolver.h

?????文件???????3973??2015-12-15?15:44??ActiveMQ\include\activemq\cmsutil\DynamicDestinationResolver.cpp

?????文件???????4136??2015-12-15?15:44??ActiveMQ\include\activemq\cmsutil\DynamicDestinationResolver.h

?????文件???????1009??2015-12-15?15:44??ActiveMQ\include\activemq\cmsutil\MessageCreator.cpp

?????文件???????1590??2015-12-15?15:44??ActiveMQ\include\activemq\cmsutil\MessageCreator.h

?????文件???????5956??2015-12-15?15:44??ActiveMQ\include\activemq\cmsutil\PooledSession.cpp

?????文件???????8097??2015-12-15?15:44??ActiveMQ\include\activemq\cmsutil\PooledSession.h

?????文件???????1015??2015-12-15?15:44??ActiveMQ\include\activemq\cmsutil\ProducerCallback.cpp

?????文件???????1678??2015-12-15?15:44??ActiveMQ\include\activemq\cmsutil\ProducerCallback.h

?????文件???????6441??2015-12-15?15:44??ActiveMQ\include\activemq\cmsutil\ResourceLifecycleManager.cpp

?????文件???????4495??2015-12-15?15:44??ActiveMQ\include\activemq\cmsutil\ResourceLifecycleManager.h

?????文件???????1012??2015-12-15?15:44??ActiveMQ\include\activemq\cmsutil\SessionCallback.cpp

?????文件???????1591??2015-12-15?15:44??ActiveMQ\include\activemq\cmsutil\SessionCallback.h

?????文件???????3330??2015-12-15?15:44??ActiveMQ\include\activemq\cmsutil\SessionPool.cpp

?????文件???????3365??2015-12-15?15:44??ActiveMQ\include\activemq\cmsutil\SessionPool.h

?????文件???????3042??2015-12-15?15:44??ActiveMQ\include\activemq\commands\ActiveMQBlobMessage.cpp

............此處省略1537個文件信息