diff -r e8e63152f320 -r 2a9601315dfc javacommons/comms/tsrc/javaapi/src/commsextensionplugin.cpp
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/javacommons/comms/tsrc/javaapi/src/commsextensionplugin.cpp	Mon May 03 12:27:20 2010 +0300
@@ -0,0 +1,212 @@
+/*
+* Copyright (c) 2008 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:  Java Captain extension plugin for Comms Module tests
+*
+*/
+
+#include <string>
+#include <iostream>
+#include <unistd.h>
+
+#include "comms.h"
+#include "logger.h"
+#include "coreinterface.h"
+#include "javacommonutils.h"
+#include "exceptionbase.h"
+
+#include "commsextensionplugin.h"
+
+using namespace std;
+
+const int MODULE_ID_A           = 900;
+const int MODULE_ID_B           = 901;
+const int MODULE_ID_DATA_CHECK  = 902;
+const int MODULE_ID_NO_REPLY    = 903;
+const int MODULE_ID_SLEEP_1S    = 1000;
+const int MODULE_ID_SLEEP_5S    = 5000;
+const int MODULE_ID_SLEEP_10S   = 10000;
+
+#ifdef __SYMBIAN32__
+java::captain::ExtensionPluginInterface* getExtensionPlugin()
+{
+#else
+extern "C" java::captain::ExtensionPluginInterface* getExtensionPlugin()
+{
+#endif
+    return new java::comms::CommsExtensionPlugin();
+}
+
+namespace java
+{
+namespace comms
+{
+// helper method for conversion
+std::string wstringToUtf8(const std::wstring& str)
+{
+    string result;
+    try
+    {
+        char* utf8 = java::util::JavaCommonUtils::wstringToUtf8(str);
+        result.assign(utf8);
+        delete[] utf8;
+    }
+    catch (java::util::ExceptionBase& e)
+    {
+        ELOG1(EJavaComms, "wstringToUtf8 failed: %s", e.toString().c_str());
+    }
+    return result;
+}
+
+CommsExtensionPlugin::CommsExtensionPlugin() : mCore(0), mComms(0)
+{
+    JELOG2(EJavaComms);
+}
+
+CommsExtensionPlugin::~CommsExtensionPlugin()
+{
+    JELOG2(EJavaComms);
+}
+
+void CommsExtensionPlugin::startPlugin(CoreInterface* core)
+{
+    JELOG2(EJavaComms);
+    mCore = core;
+    mComms = core->getComms();
+
+    mComms->registerListener(PLUGIN_ID_JAVACAPTAIN_COMMS_TESTER_C, this);
+
+    mComms->registerListener(MODULE_ID_A, this);
+    mComms->registerListener(MODULE_ID_B, this);
+    mComms->registerListener(MODULE_ID_DATA_CHECK, this);
+    mComms->registerListener(MODULE_ID_NO_REPLY, this);
+    mComms->registerListener(MODULE_ID_SLEEP_1S, this);
+    mComms->registerListener(MODULE_ID_SLEEP_5S, this);
+    mComms->registerListener(MODULE_ID_SLEEP_10S, this);
+}
+
+void CommsExtensionPlugin::stopPlugin()
+{
+    JELOG2(EJavaComms);
+    mComms->unregisterListener(PLUGIN_ID_JAVACAPTAIN_COMMS_TESTER_C, this);
+
+    mComms->unregisterListener(MODULE_ID_A, this);
+    mComms->unregisterListener(MODULE_ID_B, this);
+    mComms->unregisterListener(MODULE_ID_DATA_CHECK, this);
+    mComms->unregisterListener(MODULE_ID_NO_REPLY, this);
+    mComms->unregisterListener(MODULE_ID_SLEEP_1S, this);
+    mComms->unregisterListener(MODULE_ID_SLEEP_5S, this);
+    mComms->unregisterListener(MODULE_ID_SLEEP_10S, this);
+
+    mCore = 0;
+    mComms = 0;
+}
+
+void CommsExtensionPlugin::processMessage(CommsMessage& aMessage)
+{
+    /*
+        LOG1(EJavaComms, EInfo, "processMessage, sender    = %d", aMessage.getSender());
+        LOG1(EJavaComms, EInfo, "processMessage, messageId = %d", aMessage.getMessageId());
+        LOG1(EJavaComms, EInfo, "processMessage, moduleId  = %d", aMessage.getModuleId());
+        LOG1(EJavaComms, EInfo, "processMessage, messageRef= %d", aMessage.getMessageRef());
+    */
+    switch (aMessage.getModuleId())
+    {
+    case MODULE_ID_DATA_CHECK:
+    {
+        // keep this in sync with java side test case
+
+        const string str("abcdefghijklmnopqrstyvwxyz");
+        int num = 0xCAFEBABE;
+        // latin small letter a with diaeresis, latin small letter a with ring above, latin small letter o with diaeresis
+        const string utf8("\xC3\xA4 \xC3\xA5 \xC3\xB6 \xE2\x82\xAC"); // ä å ö €
+        const wstring utf16(L"\u00E4 \u00E5 \u00F6 \u20AC");
+
+        // Japanese Yen symbol, Roman AE with acute accent, Greek Capital Alpha, Greek Capital Omega,
+        // Euro symbol, Rupee symbol, Cyrillic capital letter DZHE, Arabic letter TEH
+        const wstring symbols = L"\u00a5\u01FC\u0391\u03A9\u20ac\u20a8\u040F\u062A";
+        const string symbols_utf8 = wstringToUtf8(symbols);
+
+        // devanagari letter a, tibetan digit zero, katakana letter ya
+        const wstring letters = L"\u0905 \u0F20 \u30E4";
+        const string letters_utf8_manually("\xE0\xA4\x85 \xE0\xBC\xA0 \xE3\x83\xA4");
+        const string letters_utf8 = wstringToUtf8(letters);
+
+        // array of all 8-bit values
+        const int len = 0xff;
+        char bytes[len];
+        for (int i=0; i < len; i++)
+        {
+            bytes[i] = i;
+        }
+
+        string s, u, sym, let, sbytes;
+        wstring w, wsym, wlet;
+        int i, zero, one, max;
+        aMessage >> s >> i >> zero >> one >> max >> u >> w >> wsym >> sym;
+        aMessage >> let >> wlet; // read in 'wrong' order
+        aMessage >> sbytes;
+
+        const char* bytes_out = sbytes.data();
+
+        if (str.compare(s)!=0 || num != i || zero != 0 || one != 1 || max != 0xFFFFFFFF ||
+                utf8.compare(u)!=0 || utf16.compare(w)!=0 || symbols.compare(wsym)!=0 || symbols_utf8.compare(sym)!=0 ||
+                letters_utf8.compare(let)!=0 || letters_utf8_manually.compare(let)!=0 || letters.compare(wlet)!=0 ||
+                memcmp(bytes, bytes_out, len) != 0)
+        {
+            ELOG(EJavaComms, "Data does not match - test will fail !!!!!!!!!");
+            mReply = aMessage;
+            mReply.setReceiver(aMessage.getSender());
+            mComms->send(mReply);
+        }
+        else
+        {
+            CommsMessage reply;
+            reply.setReceiver(aMessage.getSender());
+            reply.setMessageId(aMessage.getMessageId());
+            reply.setMessageRef(aMessage.getMessageRef());
+
+            const string input("ABCDEFGHIJKLMNOPQRSTYWXYZ");
+            int j = 0xDEADBEEF;
+
+            reply << input << j << 0 << 1 << (int)0xFFFFFFFF << letters_utf8_manually;
+            reply << symbols << utf16 << utf8 << sbytes;
+            mComms->send(reply);
+        }
+    }
+    break;
+
+    case MODULE_ID_NO_REPLY:
+        break;
+
+    case MODULE_ID_SLEEP_1S:
+    case MODULE_ID_SLEEP_5S:
+    case MODULE_ID_SLEEP_10S:
+        usleep(1000*aMessage.getModuleId());
+        // fall through
+#ifdef __SYMBIAN32__
+        break;
+#endif
+    default:
+        mReply = aMessage;
+        mReply.setReceiver(aMessage.getSender());
+        mComms->send(mReply);
+        break;
+    }
+}
+
+
+} // namespace comms
+} // namespace java
+
+