--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/multimediacommsengine/mmcecli/src/mcemessagesink.cpp	Mon Sep 06 17:32:13 2010 +0530
@@ -0,0 +1,171 @@
+/*
+* Copyright (c) 2005 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:    
+*
+*/
+
+
+
+#include "mcemessagesink.h"
+#include "mcecommessagesink.h"
+#include "mcesession.h"
+#include "mceclilogs.h"
+#include "mcemediastream.h"
+#include "mcemanager.h"
+#include "mceclilogs.h"
+#include "mcedatareceiver.h"
+#include "mcedatasinkobserver.h"
+
+#define _FLAT_DATA static_cast<CMceComMessageSink*>( iFlatData )
+#define FLAT_DATA( data ) _FLAT_DATA->data
+
+// ============================ MEMBER FUNCTIONS ===============================
+
+
+// -----------------------------------------------------------------------------
+// CMceMessageSink::NewL
+// -----------------------------------------------------------------------------
+//
+EXPORT_C CMceMessageSink* CMceMessageSink::NewL( CMceManager& aManager )
+    {
+    MCECLI_DEBUG("CMceMessageSink::NewL, Entry");
+    CMceMessageSink* self = CMceMessageSink::NewLC( aManager );
+    CleanupStack::Pop( self );
+    return self;
+    }
+
+// -----------------------------------------------------------------------------
+// CMceMessageSinke::NewLC
+// -----------------------------------------------------------------------------
+//
+EXPORT_C CMceMessageSink* CMceMessageSink::NewLC( CMceManager& aManager )
+    {
+    MCECLI_DEBUG("CMceMessageSink::NewLC, Entry");
+    CMceMessageSink* self = new (ELeave) CMceMessageSink();
+    CleanupStack::PushL( self );
+    self->ConstructL( &aManager );
+    return self;
+    }
+
+    
+// -----------------------------------------------------------------------------
+// CMceMessageSink::~CMceMessageSink
+// -----------------------------------------------------------------------------
+//
+EXPORT_C CMceMessageSink::~CMceMessageSink()
+    {
+    MCECLI_DEBUG("CMceMessageSink::~CMceMessageSink, Entry");
+    delete iReceiver;
+    }
+
+
+// -----------------------------------------------------------------------------
+// 
+// -----------------------------------------------------------------------------
+//
+EXPORT_C void CMceMessageSink::EnableL()
+    {
+    MCECLI_DEBUG("CMceMessageSink::EnableL, Entry");
+    
+    iReceiver = CMceDataReceiver::NewL( *this );    
+    CMceMediaSink::DoEnableL();
+
+    MCECLI_DEBUG("CMceMessageSink::EnableL, Exit");
+    
+    }
+
+
+// -----------------------------------------------------------------------------
+// 
+// -----------------------------------------------------------------------------
+//
+EXPORT_C void CMceMessageSink::DisableL()
+    {
+    MCECLI_DEBUG("CMceMessageSink::DisableL, Entry");
+    
+    delete iReceiver;
+    iReceiver = 0;
+    CMceMediaSink::DoDisableL();
+
+    MCECLI_DEBUG("CMceMessageSink::DisableL, Exit");
+    
+    }
+	    
+	    
+        
+// -----------------------------------------------------------------------------
+// Factory method for inner usage
+// -----------------------------------------------------------------------------
+//
+CMceMessageSink* CMceMessageSink::NewL()
+    {
+    MCECLI_DEBUG("CMceMessageSink::NewL, Entry");
+    CMceMessageSink* self = CMceMessageSink::NewLC();
+    CleanupStack::Pop( self );
+    return self;
+    }
+
+
+// -----------------------------------------------------------------------------
+// Factory method for inner usage
+// -----------------------------------------------------------------------------
+//
+CMceMessageSink* CMceMessageSink::NewLC()
+    {
+    MCECLI_DEBUG("CMceMessageSink::NewLC, Entry");
+    CMceMessageSink* self = new (ELeave) CMceMessageSink();
+    CleanupStack::PushL( self );
+    self->ConstructL( NULL );
+    return self;
+    }
+
+// -----------------------------------------------------------------------------
+// 
+// -----------------------------------------------------------------------------
+//
+void CMceMessageSink::DataReceived( CMceMediaStream& /*aStream*/, CMceMediaSink& /*aSink*/,
+    const TDesC8& aData )
+    {
+    MCECLI_DEBUG("CMceMessageSink::DataReceived, Entry");
+    MMceDataSinkObserver* observer =
+        iStream->Session()->Manager().DataSinkObserver();
+    
+    observer->DataReceived( *iStream, *this, aData );
+    }
+
+// -----------------------------------------------------------------------------
+// CMceMessageSink::CMceMessageSink
+// -----------------------------------------------------------------------------
+//
+CMceMessageSink::CMceMessageSink()
+	: CMceMediaSink()
+    { 
+    }
+	
+	
+// -----------------------------------------------------------------------------
+// CMceMessageSink::ConstructL
+// -----------------------------------------------------------------------------
+//
+void CMceMessageSink::ConstructL( CMceManager* /*aManager*/ )
+    {    
+    MCECLI_DEBUG("CMceMessageSink::ConstructL, Entry");
+	CMceComMessageSink *sink = CMceComMessageSink::NewLC();
+	CMceMediaSink::ConstructL( sink );
+	CleanupStack::Pop(sink);
+    
+	//iReceiver = CMceDataReceiver::NewL( *this, iIsexits );
+    
+    }
+