// Copyright (c) 2007-2009 Nokia Corporation and/or its subsidiary(-ies).

// All rights reserved.

// This component and the accompanying materials are made available

// under the terms of "Eclipse Public License v1.0"

// which accompanies this distribution, and is available

// at the URL "http://www.eclipse.org/legal/epl-v10.html".

//

// Initial Contributors:

// Nokia Corporation - initial contribution.

//

// Contributors:

//

// Description:

//

/**

 @file

 @internalTechnology

 @prototype

*/

#ifndef _DUMMYPR_MCPrPUBSUBSUBSCRIBER_H_

#define _DUMMYPR_MCPrPUBSUBSUBSCRIBER_H_

#include <e32property.h>

#include <e32base.h>

#include <elements/nm_messages_base.h>

#include <comms-infras/ss_nodemessages.h>

#include <comms-infras/ss_mmcommsprov.h>

#include <comms-infras/ss_metaconnprov.h>

	{

public:

	virtual ~CMCPrPubSubSubscriber();

    enum

    {

	};

    virtual void ReceivedL(const Messages::TRuntimeCtxId& /*aSender*/, const Messages::TNodeId& /*aRecipient*/, Messages::TSignatureBase& aMessage)

        {

        //This object is only a node because its host needs an TCFClientType::EAvailabilityProvider, which

        //can't be the same as the node.

        //Unfortunatelly the CAvailabilityActivity is really persistent when it comes to sending TCancel to

        //availability providers. This can't be avoided here for now.

        if (!aMessage.IsMessage<Messages::TEBase::TCancel>())

            {

            ASSERT(EFalse);

            }

        }

	CMCPrPubSubSubscriber(const ESock::CMetaConnectionProviderBase& aProvBase, TUint aStopCode);

	TInt RunError(TInt aError);

	void DoCancel();

    const ESock::CMetaConnectionProviderBase& iNode;

	TInt iStopCode;

	RProperty iProperty;

	TBool iBlocking;

	//the availablity activity subscribing for pubsub availablity changes.

	Messages::TNodeCtxId iAvailabilityActivity;

	};

#endif // _DUMMYPR_MCPrPUBSUBSUBSCRIBER_H_