String routingKey = "test_queue";
String msg = "this is message";
byte[] msgb = JsonUtils.Instance.toByteJson(msg);
ProducerUtil.sendMsg(routingKey, msgb);

public static void main(String[] args) {
    ConsumerRBQueue cq = new ConsumerRBQueue();
    cq.add(new SampleWorker());
    cq.add(new SampleWorker());
    cq.start();
}


public static class SampleWorker extends ConsumerRBProcess {
    private Logger logger = LoggerFactory.getLogger(SampleWorker.class);

    private final static String routingKey = "test_queue";
    private final static String amqpUrl = "amqp://username:password@localhost:5672/";

    public ThumbnailWorker() {
        super(routingKey, amqpUrl);
    }

    @Override
    public String getRoutingKey() {
        return routingKey;
    }

    public static String getAmqpUrl() {
        return amqpUrl;
    }

    @Override
    public void execute(byte[] data) {
        try {
            String message = new String(data, "UTF-8");
            System.out.println(" [xxx] Received '" + routingKey + "':'" + message + "'");
        } catch (Exception e) {
        }
    }
}