package com.bcxin.Infrastructures.queues;

public interface QueueProvider {
    <T extends QueueAbstract> void push(String topic, T data);

    <T extends QueueAbstract> T pool(String queueName);
}