qbit/core/src/main/java/io/advantageous/qbit/queue/JsonQueue.java
@Override
    public void startListener(final ReceiveQueueListener<T> listener) {
        queue.startListener(item -> listener.receive(fromJsonFunction.apply(item)));
    }
@Override
    public void startListener(final ReceiveQueueListener<T> listener) {
        queue.startListener(item -> listener.receive(fromJsonFunction.apply(item)));
    }
@ Override public void startListener ( final ReceiveQueueListener < T > listener ) { queue . startListener ( item -> listener . receive ( fromJsonFunction . apply ( item ) ) ) ; }
Start a listener.

@param listener listener
Start a listener .