{
incrementProcessAttemptCountOrRemoveFromStore(eventStoreKey);
}
});
retryPolicyTemplate.execute(callback, muleContext.getWorkManager());
}
private EventStoreKey storeEvent(final MuleEvent event) throws ObjectStoreException
{
MuleMessage message = event.getMessage();