Nonfunctional changes only

2 files changed, 7 insertions, 6 deletions

diff --git a/documentapi/src/main/java/com/yahoo/documentapi/Session.java b/documentapi/src/main/java/com/yahoo/documentapi/Session.java
index 8ab098397de..3f296723079 100644
--- a/documentapi/src/main/java/com/yahoo/documentapi/Session.java
+++ b/documentapi/src/main/java/com/yahoo/documentapi/Session.java
@@ -18,7 +18,7 @@ public interface Session {
      *
      * @return the next response, or null if no response is ready at this time
      */
-    public Response getNext();
+    Response getNext();
 
     /**
      * Returns the next response of this session. This will block until a response is ready
@@ -28,12 +28,12 @@ public interface Session {
      * @return the next response, or null if no response becomes ready before the timeout expires
      * @throws InterruptedException if this thread is interrupted while waiting
      */
-    public Response getNext(int timeoutMilliseconds) throws InterruptedException;
+    Response getNext(int timeoutMilliseconds) throws InterruptedException;
 
     /**
      * Destroys this session and frees up any resources it has held. Making further calls on a destroyed
      * session causes a runtime exception.
      */
-    public void destroy();
+    void destroy();
 
 }
diff --git a/documentapi/src/main/java/com/yahoo/documentapi/messagebus/MessageBusAsyncSession.java b/documentapi/src/main/java/com/yahoo/documentapi/messagebus/MessageBusAsyncSession.java
index eb71b3cfe47..8a6fa85c68b 100644
--- a/documentapi/src/main/java/com/yahoo/documentapi/messagebus/MessageBusAsyncSession.java
+++ b/documentapi/src/main/java/com/yahoo/documentapi/messagebus/MessageBusAsyncSession.java
@@ -32,7 +32,7 @@ public class MessageBusAsyncSession implements MessageBusSession, AsyncSession {
 
     private static final Logger log = Logger.getLogger(MessageBusAsyncSession.class.getName());
     private final AtomicLong requestId = new AtomicLong(0);
-    private final BlockingQueue<Response> responses = new LinkedBlockingQueue<Response>();
+    private final BlockingQueue<Response> responses = new LinkedBlockingQueue<>();
     private final ThrottlePolicy throttlePolicy;
     private final SourceSession session;
     private String route;
@@ -120,8 +120,8 @@ public class MessageBusAsyncSession implements MessageBusSession, AsyncSession {
      * A convenience method for assigning the internal trace level and route string to a message before sending it
      * through the internal mbus session object.
      *
-     * @param msg The message to send.
-     * @return The document api result object.
+     * @param msg the message to send.
+     * @return the document api result object.
      */
     public Result send(Message msg) {
         try {
@@ -292,4 +292,5 @@ public class MessageBusAsyncSession implements MessageBusSession, AsyncSession {
             }
         }
     }
+
 }