//activity or service implement MQCallback  
        MQFactory mqFactory = new MQFactory(MQConfig.hostName,
                MQConfig.virtualHostname,
                MQConfig.username,
                MQConfig.password,
                MQConfig.exchange,
                MQConfig.rotuingkey,
                MQConfig.port);
        
        // callback injected by factory instances for create consumer and produser instance
        MQConsumer mqConsumer = this.mqFactory.createConsumer(this);
        MQProducer mqProducer = this.mqFactory.createProducer(this);
                

                    mqConsumer.setQueueName("newQueueName");
                    mqConsumer.setRoutingkey("newRoutingKey");
                    mqConsumer.setExchange("newExchange");

        mqConsumer.setMessageListner(new MQConsumer.MQConsumerListener() {
            @Override
            public void onMessageReceived(QueueingConsumer.Delivery delivery) {
             //use delivery message
            }
        });
        
        mqConsumer.subsribe();
        mqConsumer.stop();

        mqProducer.publish(message, null);