diff options
Diffstat (limited to 'qpid/java/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid')
3 files changed, 11 insertions, 16 deletions
diff --git a/qpid/java/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/AMQNoMethodHandlerException.java b/qpid/java/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/AMQNoMethodHandlerException.java index 8faf1a7c65..42250190b4 100644 --- a/qpid/java/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/AMQNoMethodHandlerException.java +++ b/qpid/java/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/AMQNoMethodHandlerException.java @@ -27,14 +27,10 @@ import org.apache.qpid.protocol.AMQMethodEvent; /**
* AMQNoMethodHandlerException represents the case where no method handler exists to handle an AQMP method.
*
- * <p/><table id="crc"><caption>CRC Card</caption>
- * <tr><th> Responsibilities <th> Collaborations
- * <tr><td> Represents failure to handle an AMQP method.
- * </table>
- *
- * @todo Not an AMQP exception as no status code.
- *
- * @todo Missing method handler. Unlikely to ever happen, and if it does its a coding error. Consider replacing with a
+ * <p>
+ * TODO Not an AMQP exception as no status code.
+ * <p>
+ * TODO Missing method handler. Unlikely to ever happen, and if it does its a coding error. Consider replacing with a
* Runtime.
*/
public class AMQNoMethodHandlerException extends AMQException
diff --git a/qpid/java/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/ConsumerTarget_0_8.java b/qpid/java/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/ConsumerTarget_0_8.java index 3de89a1d70..ae63c16025 100644 --- a/qpid/java/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/ConsumerTarget_0_8.java +++ b/qpid/java/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/ConsumerTarget_0_8.java @@ -43,8 +43,10 @@ import java.util.concurrent.atomic.AtomicBoolean; import java.util.concurrent.atomic.AtomicLong; /** - * Encapsulation of a subscription to a queue. <p/> Ties together the protocol session of a subscriber, the consumer tag - * that was given out by the broker and the channel id. <p/> + * Encapsulation of a subscription to a queue. + * <p> + * Ties together the protocol session of a subscriber, the consumer tag + * that was given out by the broker and the channel id. */ public abstract class ConsumerTarget_0_8 extends AbstractConsumerTarget implements FlowCreditManager.FlowCreditManagerListener { @@ -170,10 +172,8 @@ public abstract class ConsumerTarget_0_8 extends AbstractConsumerTarget implemen * This method can be called by each of the publisher threads. As a result all changes to the channel object must be * thread safe. * - * * @param entry The message to send * @param batch - * @throws org.apache.qpid.AMQException */ @Override public void send(MessageInstance entry, boolean batch) @@ -286,10 +286,8 @@ public abstract class ConsumerTarget_0_8 extends AbstractConsumerTarget implemen * This method can be called by each of the publisher threads. As a result all changes to the channel object must be * thread safe. * - * * @param entry The message to send * @param batch - * @throws org.apache.qpid.AMQException */ @Override public void send(MessageInstance entry, boolean batch) diff --git a/qpid/java/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/state/AMQStateManager.java b/qpid/java/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/state/AMQStateManager.java index 328064b6dc..cb9295ac49 100644 --- a/qpid/java/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/state/AMQStateManager.java +++ b/qpid/java/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/state/AMQStateManager.java @@ -43,8 +43,9 @@ import org.apache.qpid.server.security.SubjectCreator; import org.apache.qpid.server.util.ServerScopedRuntimeException; /** - * The state manager is responsible for managing the state of the protocol session. <p/> For each AMQProtocolHandler - * there is a separate state manager. + * The state manager is responsible for managing the state of the protocol session. + * <p> + * For each AMQProtocolHandler there is a separate state manager. */ public class AMQStateManager implements AMQMethodListener { |