public void put ( DelayableImmutableMessage delayableImmutableMessage ) { if ( messagePersister . persist ( messageQueueId , delayableImmutableMessage ) ) { logger . trace ( "Message {} was persisted for messageQueueId {}" , delayableImmutableMessage . getMessage ( ) , messageQueueId ) ; } else { logger . trace ( "Message {} was not persisted for messageQueueId {}" , delayableImmutableMessage . getMessage ( ) , messageQueueId ) ; } delayableImmutableMessages . put ( delayableImmutableMessage ) ; }
Add the passed in message to the queue of messages to be processed . Also offer the message for persisting .