package org.jeecqrs.messaging.local;

import org.jeecqrs.messaging.MultiTopicSubscriber;

/**
 * Provides the ability to inform about failing subscribers.
 * 
 * @param <M>  the message type
 */
public interface SubscriberFailingCallback<M> {

    void isFailing(MultiTopicSubscriber<M> subscriber);
    
}

@@ -35,60 +35,8 @@
 l;%0A%0A
-import org.jeecqrs.messaging.MultiTopicSubscriber;%0A%0A
 /**%0A
@@ -100,44 +100,8 @@
 rs.%0A
- * %0A * @param %3CM%3E  the message type%0A
  */%0A
@@ -142,19 +142,16 @@
 Callback
-%3CM%3E
  %7B%0A%0A    
@@ -169,42 +169,8 @@
 ing(
-MultiTopicSubscriber%3CM%3E subscriber
 );%0A 

simplify SubscriberFailingCallback interface