public class OspreyManagerTest {

    public static void main(String[] args) {
//        BasicConfigurator.configure();
        OspreyManager ospreyManager = new OspreyManager("osprey-test");
        ospreyManager.registerProcessor(new TestProcessor());
        ospreyManager.init();
        Message message = new TestMessage();
        Result result = ospreyManager.addMessage(message, false);
        System.out.println(result.isSuccess());
        result = ospreyManager.commitMessage(message, result);
        System.out.println(result.isSuccess());
    }

    public static class TestMessage extends Message {

        private static final long serialVersionUID = -9006052790210673532L;

    }

    public static class TestProcessor implements OspreyProcessor<TestMessage> {

        /**
         * @return
         */
        public Class<TestMessage> interest() {
            return TestMessage.class;
        }

        /**
         * @param event
         * @return
         */
        public Result process(TestMessage event) {
            System.out.println("Handled event" + event);
            Result result = new Result();
            result.setSuccess(false);
            return result;
        }

    }

}