/////////////////////////////////////////////////////////////////////////////
// MsgMgr.cpp - Provides async enqueuing and dequeuing of message traffic. //
//              Built as an ATL component with Both threading model.       //
//                                                                         //
// Jim Fawcett, CSE775 - Distributed Objects, MT1-Q4, Spring 2009          //
/////////////////////////////////////////////////////////////////////////////

#include "stdafx.h"
#include "MsgMgr.h"

STDMETHODIMP CMsgMgr::putMessage(BSTR msg)
{
  pInQ->enQ(msg);
//  pMMFcomp->putString(msg);  // used for test before queues installed
  return S_OK;
}

STDMETHODIMP CMsgMgr::getMessage(BSTR* pMsg)
{
  CComBSTR temp((pOutQ->deQ()).c_str());
  *pMsg = temp.Detach();
//  pMMFcomp->getString(pMsg);  // used for test before queues installed
  return S_OK;
}