From 2c2539e45720219e577a18e17597709098dd830b Mon Sep 17 00:00:00 2001
From: "selva.andre" <selva.andre@gmail.com>
Date: Sat, 1 Sep 2012 13:18:41 +0200
Subject: [PATCH] Removed refill method from IMessaging interface

---
 .../java/org/dna/mqtt/moquette/messaging/spi/IMessaging.java    | 2 --
 .../dna/mqtt/moquette/messaging/spi/impl/SimpleMessaging.java   | 2 +-
 2 files changed, 1 insertion(+), 3 deletions(-)

diff --git a/parser/src/main/java/org/dna/mqtt/moquette/messaging/spi/IMessaging.java b/parser/src/main/java/org/dna/mqtt/moquette/messaging/spi/IMessaging.java
index 97a1d6e6..001c05ea 100644
--- a/parser/src/main/java/org/dna/mqtt/moquette/messaging/spi/IMessaging.java
+++ b/parser/src/main/java/org/dna/mqtt/moquette/messaging/spi/IMessaging.java
@@ -46,7 +46,5 @@ public interface IMessaging {
 
     void disconnect(IoSession session);
 
-    void refill(MessagingEvent evt) throws InterruptedException;
-
     void republishStored(String clientID);
 }
diff --git a/parser/src/main/java/org/dna/mqtt/moquette/messaging/spi/impl/SimpleMessaging.java b/parser/src/main/java/org/dna/mqtt/moquette/messaging/spi/impl/SimpleMessaging.java
index 716db1f0..22ffc24e 100644
--- a/parser/src/main/java/org/dna/mqtt/moquette/messaging/spi/impl/SimpleMessaging.java
+++ b/parser/src/main/java/org/dna/mqtt/moquette/messaging/spi/impl/SimpleMessaging.java
@@ -170,7 +170,7 @@ public class SimpleMessaging implements IMessaging, Runnable {
     }
 
     //method used by hte Notifier to re-put an event on the inbound queue
-    public void refill(MessagingEvent evt) throws InterruptedException {
+    private void refill(MessagingEvent evt) throws InterruptedException {
         m_inboundQueue.put(evt);
     }