A generic queue implementation extending the concurrent APIs with pluggable queue persistence.