qbit/core/src/main/java/io/advantageous/qbit/queue/JsonQueue.java
public static <K, V> JsonQueue<Map<K, V>> createMapQueueWithMapper(
            final Class<K> mapKeyClass,
            final Class<V> valueKeyClass,
            final Queue<String> queue,
            final JsonMapper jsonMapper) {

        return new JsonQueue<>(queue,
                json -> jsonMapper.fromJsonMap(json, mapKeyClass, valueKeyClass),
                jsonMapper::toJson);
    }
public static <K, V> JsonQueue<Map<K, V>> createMapQueueWithMapper(
            final Class<K> mapKeyClass,
            final Class<V> valueKeyClass,
            final Queue<String> queue,
            final JsonMapper jsonMapper) {

        return new JsonQueue<>(queue,
                json -> jsonMapper.fromJsonMap(json, mapKeyClass, valueKeyClass),
                jsonMapper::toJson);
    }
public static < K , V > JsonQueue < Map < K , V > > createMapQueueWithMapper ( final Class < K > mapKeyClass , final Class < V > valueKeyClass , final Queue < String > queue , final JsonMapper jsonMapper ) { return new JsonQueue <> ( queue , json -> jsonMapper . fromJsonMap ( json , mapKeyClass , valueKeyClass ) , jsonMapper :: toJson ) ; }
Create a  JsonQueue that can send a Map of values

@param mapKeyClass   mapKey class
@param valueKeyClass valueKey class
@param queue         queue
@param jsonMapper    jsonMapper
@param <K>           K
@param <V>           V
@return new JsonQueue that works with maps.
Create a JsonQueue that can send a Map of values