ChannelCachedMessagePublisher

public class ChannelCachedMessagePublisher {

    private static CachingConnectionFactory CACHING_CONNECTION_FACTORY = new CachingConnectionFactory("localhost");
    private static RabbitTemplate RABBIT_TEMPLATE;

    private void init() {
        if (!INITIALIZED) {
            synchronized (ConnectionCachedMessagePublisher.class) {
                CACHING_CONNECTION_FACTORY.setCacheMode(CachingConnectionFactory.CacheMode.CHANNEL);
                CACHING_CONNECTION_FACTORY.setChannelCacheSize(100);
                CACHING_CONNECTION_FACTORY.setVirtualHost("testVHost");
                CACHING_CONNECTION_FACTORY.setConnectionNameStrategy(CACHING_CONNECTION_FACTORY -> "arpit-cached-connection");
                CACHING_CONNECTION_FACTORY.setPublisherConfirms(false);
                RABBIT_TEMPLATE = new RabbitTemplate(CACHING_CONNECTION_FACTORY);
            }
            INITIALIZED = true;
        }
    }

    public void publishMessage(String exchange, String routingKey, String message) {

        RABBIT_TEMPLATE.convertAndSend(exchange, routingKey, message, new MessagePostProcessor() {
            @Override
            public Message postProcessMessage(Message message) throws AmqpException {
                MessageProperties properties = message.getMessageProperties();
                properties.setDeliveryMode(MessageDeliveryMode.NON_PERSISTENT);
                return new org.springframework.amqp.core.Message(message.getBody(),properties);
            }
        });
    }
}