ConcurrentHashMap does not register

[ivolo]

How do I serialize ConcurrentHashMap? Gives the following exception when you try to register it:

https://groups.google.com/forum/?fromgroups=#!topic/msgpack/KPx-dP3hnE0

[muga]

Hi,

Thank you for contacting us.

You can serialize ConcurrentHashMap objects with Map template as follows.

import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;

import org.msgpack.MessagePack;
import org.msgpack.packer.Packer;
import org.msgpack.template.Template;
import org.msgpack.template.Templates;
import org.msgpack.unpacker.Unpacker;

public class Main {
    public static void main(String[] args) throws Exception {
        MessagePack msgpack = new MessagePack();

        Template<Map<String, String>> tmpl = Templates.tMap(Templates.TString, Templates.TString);
        ByteArrayOutputStream out = new ByteArrayOutputStream();
        Packer packer = msgpack.createPacker(out);

        ConcurrentHashMap<String, String> src = new ConcurrentHashMap<String, String>();
        src.put("k1", "v1");
        src.put("k2", "v2");

        tmpl.write(packer, src);
        byte[] bytes = out.toByteArray();

        ConcurrentHashMap<String, String> dst = new ConcurrentHashMap<String, String>();
        ByteArrayInputStream in = new ByteArrayInputStream(bytes);
        Unpacker unpacker = msgpack.createUnpacker(in);
        tmpl.read(unpacker, dst);

        System.out.println(dst);
    }
}

Thanks,
Muga

[ivolo]

Thank you!