1 18 package org.apache.activemq.store; 19 20 import org.apache.activemq.command.Message; 21 import org.apache.activemq.command.MessageId; 22 23 26 public interface MessageRecoveryListener { 27 void recoverMessage(Message message) throws Exception ; 28 void recoverMessageReference(MessageId ref) throws Exception ; 29 void finished(); 30 boolean hasSpace(); 31 } 32 | Popular Tags |