diff --git a/src/main/java/org/apache/sling/mom/RequeueMessageException.java b/src/main/java/org/apache/sling/mom/RequeueMessageException.java
index be1d0b2..2e84577 100644
--- a/src/main/java/org/apache/sling/mom/RequeueMessageException.java
+++ b/src/main/java/org/apache/sling/mom/RequeueMessageException.java
@@ -25,7 +25,7 @@
 
     /**
      *
-     * @param message
+     * @param message the message
      */
     public RequeueMessageException(String message) {
         super(message);
@@ -33,8 +33,8 @@
 
     /**
      *
-     * @param message
-     * @param cause
+     * @param message the message
+     * @param cause the cause
      */
     public RequeueMessageException(String message, Throwable cause) {
         super(message, cause);
diff --git a/src/main/java/org/apache/sling/mom/Subscriber.java b/src/main/java/org/apache/sling/mom/Subscriber.java
index ed5ce19..9c9fd25 100644
--- a/src/main/java/org/apache/sling/mom/Subscriber.java
+++ b/src/main/java/org/apache/sling/mom/Subscriber.java
@@ -39,8 +39,8 @@
     /**
      * Will be called with each message matching the filters the TopicListener is registered with.
      *
-     * @param topic
-     * @param message
+     * @param topic message topic.
+     * @param message message as a map of maps.
      */
     void onMessage(Types.TopicName topic, Map<String, Object> message);