From 50fb4e53c19f36df7ca2b9d86be230f03804c336 Mon Sep 17 00:00:00 2001
From: Mark Paluch <mpaluch@pivotal.io>
Date: Wed, 7 Jun 2017 16:57:24 +0200
Subject: [PATCH] =?UTF-8?q?DATACASS-459=20-=20Adopt=20to=20changed=20Annot?=
 =?UTF-8?q?ationUtils.getValue(=E2=80=A6)=20behavior.?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

Related ticket: SPR-15540.
---
 .../repository/query/CassandraQueryMethod.java     | 14 +++++++++++---
 1 file changed, 11 insertions(+), 3 deletions(-)

diff --git a/spring-data-cassandra/src/main/java/org/springframework/data/cassandra/repository/query/CassandraQueryMethod.java b/spring-data-cassandra/src/main/java/org/springframework/data/cassandra/repository/query/CassandraQueryMethod.java
index da5e5bc20..f7aabe8d8 100644
--- a/spring-data-cassandra/src/main/java/org/springframework/data/cassandra/repository/query/CassandraQueryMethod.java
+++ b/spring-data-cassandra/src/main/java/org/springframework/data/cassandra/repository/query/CassandraQueryMethod.java
@@ -143,7 +143,7 @@ public class CassandraQueryMethod extends QueryMethod {
 	 * Returns whether the method has an annotated query.
 	 */
 	public boolean hasAnnotatedQuery() {
-		return (getAnnotatedQuery() != null);
+		return findAnnotatedQuery().isPresent();
 	}
 
 	/**
@@ -153,8 +153,16 @@ public class CassandraQueryMethod extends QueryMethod {
 	 * @return
 	 */
 	public String getAnnotatedQuery() {
-		String query = (String) AnnotationUtils.getValue(getQueryAnnotation());
-		return (StringUtils.hasText(query) ? query : null);
+		return findAnnotatedQuery().orElse(null);
+	}
+
+	private Optional<String> findAnnotatedQuery() {
+
+		Optional<Query> queryAnnotation = Optional.ofNullable(getQueryAnnotation());
+
+		return queryAnnotation.map(AnnotationUtils::getValue) //
+				.map(it -> (String) it) //
+				.filter(StringUtils::hasText);
 	}
 
 	/**