diff --git a/trunk/src/app/srs_app_rtc_source.cpp b/trunk/src/app/srs_app_rtc_source.cpp
index ff50cc718..1c15790bd 100644
--- a/trunk/src/app/srs_app_rtc_source.cpp
+++ b/trunk/src/app/srs_app_rtc_source.cpp
@@ -115,13 +115,7 @@ void SrsRtcConsumer::update_source_id()
     should_update_source_id = true;
 }
 
-srs_error_t SrsRtcConsumer::enqueue(SrsSharedPtrMessage* shared_msg, bool atc, SrsRtmpJitterAlgorithm ag)
-{
-    srs_error_t err = srs_success;
-    return err;
-}
-
-srs_error_t SrsRtcConsumer::enqueue2(SrsRtpPacket2* pkt)
+srs_error_t SrsRtcConsumer::enqueue(SrsRtpPacket2* pkt)
 {
     srs_error_t err = srs_success;
 
@@ -404,7 +398,7 @@ srs_error_t SrsRtcSource::on_rtp(SrsRtpPacket2* pkt)
 
     for (int i = 0; i < (int)consumers.size(); i++) {
         SrsRtcConsumer* consumer = consumers.at(i);
-        if ((err = consumer->enqueue2(pkt->copy())) != srs_success) {
+        if ((err = consumer->enqueue(pkt->copy())) != srs_success) {
             return srs_error_wrap(err, "consume message");
         }
     }
diff --git a/trunk/src/app/srs_app_rtc_source.hpp b/trunk/src/app/srs_app_rtc_source.hpp
index 14fc689da..6ee2b8282 100644
--- a/trunk/src/app/srs_app_rtc_source.hpp
+++ b/trunk/src/app/srs_app_rtc_source.hpp
@@ -45,7 +45,7 @@ class SrsAudioRecode;
 class SrsRtpPacket2;
 class SrsSample;
 
-class SrsRtcConsumer : public ISrsConsumerQueue
+class SrsRtcConsumer
 {
 private:
     SrsRtcSource* source;
@@ -63,9 +63,10 @@ public:
 public:
     // When source id changed, notice client to print.
     virtual void update_source_id();
-    // Put or get RTP packet in queue.
-    virtual srs_error_t enqueue(SrsSharedPtrMessage* shared_msg, bool atc, SrsRtmpJitterAlgorithm ag);
-    srs_error_t enqueue2(SrsRtpPacket2* pkt);
+    // Put RTP packet into queue.
+    // @note We do not drop packet here, but drop it in sender.
+    srs_error_t enqueue(SrsRtpPacket2* pkt);
+    // Get all RTP packets from queue.
     virtual srs_error_t dump_packets(std::vector<SrsRtpPacket2*>& pkts);
     // Wait for at-least some messages incoming in queue.
     virtual void wait(int nb_msgs);
diff --git a/trunk/src/app/srs_app_source.cpp b/trunk/src/app/srs_app_source.cpp
index 6c3e888f7..d6b25503a 100755
--- a/trunk/src/app/srs_app_source.cpp
+++ b/trunk/src/app/srs_app_source.cpp
@@ -418,14 +418,6 @@ ISrsWakable::~ISrsWakable()
 {
 }
 
-ISrsConsumerQueue::ISrsConsumerQueue()
-{
-}
-
-ISrsConsumerQueue::~ISrsConsumerQueue()
-{
-}
-
 SrsConsumer::SrsConsumer(SrsSource* s, SrsConnection* c)
 {
     source = s;
@@ -1570,7 +1562,7 @@ SrsFormat* SrsMetaCache::ash_format()
     return aformat;
 }
 
-srs_error_t SrsMetaCache::dumps(ISrsConsumerQueue* consumer, bool atc, SrsRtmpJitterAlgorithm ag, bool dm, bool ds)
+srs_error_t SrsMetaCache::dumps(SrsConsumer* consumer, bool atc, SrsRtmpJitterAlgorithm ag, bool dm, bool ds)
 {
     srs_error_t err = srs_success;
     
diff --git a/trunk/src/app/srs_app_source.hpp b/trunk/src/app/srs_app_source.hpp
index be84b1328..7af2ba582 100644
--- a/trunk/src/app/srs_app_source.hpp
+++ b/trunk/src/app/srs_app_source.hpp
@@ -182,18 +182,8 @@ public:
     virtual void wakeup() = 0;
 };
 
-// Enqueue the packet to consumer.
-class ISrsConsumerQueue
-{
-public:
-    ISrsConsumerQueue();
-    virtual ~ISrsConsumerQueue();
-public:
-    virtual srs_error_t enqueue(SrsSharedPtrMessage* shared_msg, bool atc, SrsRtmpJitterAlgorithm ag) = 0;
-};
-
 // The consumer for SrsSource, that is a play client.
-class SrsConsumer : virtual public ISrsWakable, virtual public ISrsConsumerQueue
+class SrsConsumer : virtual public ISrsWakable
 {
 private:
     SrsRtmpJitter* jitter;
@@ -445,7 +435,7 @@ public:
     // Dumps cached metadata to consumer.
     // @param dm Whether dumps the metadata.
     // @param ds Whether dumps the sequence header.
-    virtual srs_error_t dumps(ISrsConsumerQueue* consumer, bool atc, SrsRtmpJitterAlgorithm ag, bool dm, bool ds);
+    virtual srs_error_t dumps(SrsConsumer* consumer, bool atc, SrsRtmpJitterAlgorithm ag, bool dm, bool ds);
 public:
     // Previous exists sequence header.
     virtual SrsSharedPtrMessage* previous_vsh();