diff -r 80702021b851 -r 92fb71afdc0e json/src/main/java/org/netbeans/html/json/impl/RcvrJSON.java
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/json/src/main/java/org/netbeans/html/json/impl/RcvrJSON.java	Mon Dec 16 16:59:43 2013 +0100
@@ -0,0 +1,149 @@
+/**
+ * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS HEADER.
+ *
+ * Copyright 1997-2010 Oracle and/or its affiliates. All rights reserved.
+ *
+ * Oracle and Java are registered trademarks of Oracle and/or its affiliates.
+ * Other names may be trademarks of their respective owners.
+ *
+ * The contents of this file are subject to the terms of either the GNU
+ * General Public License Version 2 only ("GPL") or the Common
+ * Development and Distribution License("CDDL") (collectively, the
+ * "License"). You may not use this file except in compliance with the
+ * License. You can obtain a copy of the License at
+ * http://www.netbeans.org/cddl-gplv2.html
+ * or nbbuild/licenses/CDDL-GPL-2-CP. See the License for the
+ * specific language governing permissions and limitations under the
+ * License.  When distributing the software, include this License Header
+ * Notice in each file and include the License file at
+ * nbbuild/licenses/CDDL-GPL-2-CP.  Oracle designates this
+ * particular file as subject to the "Classpath" exception as provided
+ * by Oracle in the GPL Version 2 section of the License file that
+ * accompanied this code. If applicable, add the following below the
+ * License Header, with the fields enclosed by brackets [] replaced by
+ * your own identifying information:
+ * "Portions Copyrighted [year] [name of copyright owner]"
+ *
+ * Contributor(s):
+ *
+ * The Original Software is NetBeans. The Initial Developer of the Original
+ * Software is Oracle. Portions Copyright 2013-2013 Oracle. All Rights Reserved.
+ *
+ * If you wish your version of this file to be governed by only the CDDL
+ * or only the GPL Version 2, indicate your decision by adding
+ * "[Contributor] elects to include this software in this distribution
+ * under the [CDDL or GPL Version 2] license." If you do not indicate a
+ * single choice of license, a recipient has the option to distribute
+ * your version of this file under either the CDDL, the GPL Version 2 or
+ * to extend the choice of license to its licensees as provided above.
+ * However, if you add GPL Version 2 code and therefore, elected the GPL
+ * Version 2 license, then the option applies only if the new code is
+ * made subject to such option by the copyright holder.
+ */
+package org.netbeans.html.json.impl;
+
+import net.java.html.BrwsrCtx;
+
+/** Super type for those who wish to receive JSON messages.
+ *
+ * @author Jaroslav Tulach <jtulach@netbeans.org>
+ */
+public abstract class RcvrJSON {
+    protected void onOpen(MsgEvnt msg) {}
+    protected abstract void onMessage(MsgEvnt msg);
+    protected void onClose(MsgEvnt msg) {}
+    protected abstract void onError(MsgEvnt msg);
+    
+    public abstract static class MsgEvnt {
+        MsgEvnt() {
+        }
+        
+        public Throwable getError() {
+            return null;
+        }
+        
+        public final Exception getException() {
+            Throwable t = getError();
+            if (t instanceof Exception) {
+                return (Exception)t;
+            }
+            if (t == null) {
+                return null;
+            }
+            return new Exception(t);
+        }
+        
+        public int dataSize() {
+            return -1;
+        }
+        
+        public <Data> void dataRead(BrwsrCtx ctx, Class<? extends Data> type, Data[] fillTheArray) {
+        }
+
+        public abstract void dispatch(RcvrJSON r);
+        
+        public static MsgEvnt createError(final Throwable t) {
+            return new MsgEvnt() {
+                @Override
+                public Throwable getError() {
+                    return t;
+                }
+
+                @Override
+                public void dispatch(RcvrJSON r) {
+                    r.onError(this);
+                }
+            };
+        }
+        
+        public static MsgEvnt createMessage(final Object value) {
+            return new MsgEvnt() {
+                @Override
+                public int dataSize() {
+                    if (value instanceof Object[]) {
+                        return ((Object[])value).length;
+                    } else {
+                        return 1;
+                    }
+                }
+                
+                @Override
+                public <Data> void dataRead(BrwsrCtx context, Class<? extends Data> type, Data[] arr) {
+                    if (value instanceof Object[]) {
+                        Object[] data = ((Object[]) value);
+                        for (int i = 0; i < data.length && i < arr.length; i++) {
+                            arr[i] = org.netbeans.html.json.impl.JSON.read(context, type, data[i]);
+                        }
+                    } else {
+                        if (arr.length > 0) {
+                            arr[0] = org.netbeans.html.json.impl.JSON.read(context, type, value);
+                        }
+                    }
+                }
+                
+                @Override
+                public void dispatch(RcvrJSON r) {
+                    r.onMessage(this);
+                }
+            };
+        }
+        
+        public static MsgEvnt createOpen() {
+            return new MsgEvnt() {
+                @Override
+                public void dispatch(RcvrJSON r) {
+                    r.onOpen(this);
+                }
+            };
+        }
+
+        public static MsgEvnt createClose() {
+            return new MsgEvnt() {
+                @Override
+                public void dispatch(RcvrJSON r) {
+                    r.onClose(this);
+                }
+            };
+        }
+    } // end MsgEvnt
+}