@ DoesServiceRequest public Iterable < CloudQueueMessage > retrieveMessages ( final int numberOfMessages , final int visibilityTimeoutInSeconds , QueueRequestOptions options , OperationContext opContext ) throws StorageException { Utility . assertInBounds ( "numberOfMessages" , numberOfMessages , 1 , QueueConstants . MAX_NUMBER_OF_MESSAGES_TO_PEEK ) ; Utility . assertInBounds ( "visibilityTimeoutInSeconds" , visibilityTimeoutInSeconds , 0 , QueueConstants . MAX_TIME_TO_LIVE_IN_SECONDS ) ; if ( opContext == null ) { opContext = new OperationContext ( ) ; } opContext . initialize ( ) ; options = QueueRequestOptions . populateAndApplyDefaults ( options , this . queueServiceClient ) ; return ExecutionEngine . executeWithRetry ( this . queueServiceClient , this , this . retrieveMessagesImpl ( numberOfMessages , visibilityTimeoutInSeconds , options ) , options . getRetryPolicyFactory ( ) , opContext ) ; }
Retrieves the specified number of messages from the front of the queue using the specified request options and operation context . This operation marks the retrieved messages as invisible in the queue for the default visibility timeout period .