diff --git a/activemq-core/src/test/java/org/apache/activemq/JmsSendReceiveTestSupport.java b/activemq-core/src/test/java/org/apache/activemq/JmsSendReceiveTestSupport.java index 7f529bc5f4..05203b2890 100755 --- a/activemq-core/src/test/java/org/apache/activemq/JmsSendReceiveTestSupport.java +++ b/activemq-core/src/test/java/org/apache/activemq/JmsSendReceiveTestSupport.java @@ -93,6 +93,7 @@ public class JmsSendReceiveTestSupport extends TestSupport implements MessageLis } producer.send(producerDestination, message); + messageSent(); } assertMessagesAreReceived(); @@ -201,4 +202,13 @@ public class JmsSendReceiveTestSupport extends TestSupport implements MessageLis protected List createConcurrentList() { return Collections.synchronizedList(new ArrayList()); } + + /** + * Just a hook so can insert failure tests + * @throws Exception + * + */ + protected void messageSent() throws Exception{ + + } } \ No newline at end of file