|
|
@@ -19,18 +19,18 @@ CAliyunMNS::CAliyunMNS(std::string queueName)
|
|
|
{
|
|
|
queue = m_mnsClient->getQueueRef(queueName.c_str());
|
|
|
|
|
|
- //LOG_ERROR("queueName:" << queueName.c_str());
|
|
|
- //LOG_ERROR("endpoint:" << endpoint.c_str());
|
|
|
- //LOG_ERROR("accessId:" << accessId.c_str());
|
|
|
- //LOG_ERROR("accessKey:" << accessKey.c_str());
|
|
|
- //LOG_ERROR("stsToken:" << stsToken.c_str());
|
|
|
+ LOG_ERROR("queueName:" << queueName.c_str());
|
|
|
+ LOG_ERROR("endpoint:" << endpoint.c_str());
|
|
|
+ LOG_ERROR("accessId:" << accessId.c_str());
|
|
|
+ LOG_ERROR("accessKey:" << accessKey.c_str());
|
|
|
+ LOG_ERROR("stsToken:" << stsToken.c_str());
|
|
|
|
|
|
is_init = true;
|
|
|
}
|
|
|
catch(MNSServerException& me)
|
|
|
{
|
|
|
//cout << "Request Failed: " << me.GetErrorCode().c_str() << endl;
|
|
|
- //LOG_INFO("Request Failed: " << me.GetErrorCode().c_str());
|
|
|
+ LOG_INFO("Request Failed: " << me.GetErrorCode().c_str());
|
|
|
is_init = false;
|
|
|
|
|
|
return;
|
|
|
@@ -38,7 +38,7 @@ CAliyunMNS::CAliyunMNS(std::string queueName)
|
|
|
catch(MNSExceptionBase& mb)
|
|
|
{
|
|
|
//cout << "Request Failed: " << mb.ToString().c_str() << endl;
|
|
|
- //LOG_INFO("Request Failed: " << mb.ToString().c_str());
|
|
|
+ LOG_INFO("Request Failed: " << mb.ToString().c_str());
|
|
|
is_init = false;
|
|
|
|
|
|
return;
|
|
|
@@ -57,6 +57,7 @@ std::string CAliyunMNS::getMessage()
|
|
|
{
|
|
|
if(is_init == false)
|
|
|
{
|
|
|
+ LOG_INFO("is_init is false");
|
|
|
return "error!";
|
|
|
}
|
|
|
|