gistfile1.txt

    public class ShowHandler_CreateItemCommand : Jasper.Bus.Model.MessageHandler
    {
        private readonly IDocumentStore _documentStore;

        public ShowHandler_CreateItemCommand(IDocumentStore documentStore)
        {
            _documentStore = documentStore;
        }


        public override async Task Handle(Jasper.Bus.Runtime.Invocation.IInvocationContext context)
        {
            var createItemCommand = (ShowHandler.CreateItemCommand)context.Envelope.Message;
            
            // generated by middleware
            using (var documentSession = _documentStore.OpenSession())
            {
                // calling the inner "handler"
                var outgoing1 = ShowHandler.CreateItemHandler.Handle(createItemCommand, documentSession);
                
                // generated by standard policies to glue together outgoing messages
                context.EnqueueCascading(outgoing1);
                
                // this was generated by transactional middleware
                await documentSession.SaveChangesAsync();
            }

        }

    }

The actual handler code is this:

    public class CreateItemHandler
    {
        [MartenTransaction]
        public static ItemCreatedEvent Handle(
            CreateItemCommand command, 
            IDocumentSession session)
        {
            var item = new Item {Name = command.Name};
            session.Store(item);

            return new ItemCreatedEvent{Item = item};
        }
    }