class PutJMS extends AbstractProcessor {

    @OnStopped
    public void cleanupResources() {
        WrappedMessageProducer wrappedProducer = producerQueue.poll();
        while (wrappedProducer != null) {
            wrappedProducer.close(getLogger());
            wrappedProducer = producerQueue.poll();
        }
    }

    public  PutJMS();

}