javadoc: Fix doclint reference errors
This commit is contained in:
parent
3b9ed795d1
commit
9a439b4791
|
@ -94,7 +94,6 @@ public class JDBCSequentialFileFactoryDriver extends AbstractJDBCDriver {
|
||||||
* Opens the supplied file. If the file does not exist in the database it will create a new one.
|
* Opens the supplied file. If the file does not exist in the database it will create a new one.
|
||||||
*
|
*
|
||||||
* @param file
|
* @param file
|
||||||
* @return
|
|
||||||
* @throws SQLException
|
* @throws SQLException
|
||||||
*/
|
*/
|
||||||
public void openFile(JDBCSequentialFile file) throws SQLException {
|
public void openFile(JDBCSequentialFile file) throws SQLException {
|
||||||
|
@ -216,7 +215,7 @@ public class JDBCSequentialFileFactoryDriver extends AbstractJDBCDriver {
|
||||||
* @param file
|
* @param file
|
||||||
* @param data
|
* @param data
|
||||||
* @return
|
* @return
|
||||||
* @throws Exception
|
* @throws SQLException
|
||||||
*/
|
*/
|
||||||
public synchronized int writeToFile(JDBCSequentialFile file, byte[] data) throws SQLException {
|
public synchronized int writeToFile(JDBCSequentialFile file, byte[] data) throws SQLException {
|
||||||
try {
|
try {
|
||||||
|
@ -238,7 +237,7 @@ public class JDBCSequentialFileFactoryDriver extends AbstractJDBCDriver {
|
||||||
* @param file
|
* @param file
|
||||||
* @param bytes
|
* @param bytes
|
||||||
* @return
|
* @return
|
||||||
* @throws Exception
|
* @throws SQLException
|
||||||
*/
|
*/
|
||||||
public synchronized int readFromFile(JDBCSequentialFile file, ByteBuffer bytes) throws SQLException {
|
public synchronized int readFromFile(JDBCSequentialFile file, ByteBuffer bytes) throws SQLException {
|
||||||
connection.setAutoCommit(false);
|
connection.setAutoCommit(false);
|
||||||
|
|
|
@ -652,7 +652,6 @@ public class ActiveMQConnectionFactory implements ConnectionFactoryOptions, Exte
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @param interceptorList a comma separated string of incoming interceptor class names to be used. Each interceptor needs a default Constructor to be used with this method.
|
* @param interceptorList a comma separated string of incoming interceptor class names to be used. Each interceptor needs a default Constructor to be used with this method.
|
||||||
* @return this
|
|
||||||
*/
|
*/
|
||||||
public void setIncomingInterceptorList(String interceptorList) {
|
public void setIncomingInterceptorList(String interceptorList) {
|
||||||
checkWrite();
|
checkWrite();
|
||||||
|
@ -665,7 +664,6 @@ public class ActiveMQConnectionFactory implements ConnectionFactoryOptions, Exte
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @param interceptorList a comma separated string of incoming interceptor class names to be used. Each interceptor needs a default Constructor to be used with this method.
|
* @param interceptorList a comma separated string of incoming interceptor class names to be used. Each interceptor needs a default Constructor to be used with this method.
|
||||||
* @return this
|
|
||||||
*/
|
*/
|
||||||
public void setOutgoingInterceptorList(String interceptorList) {
|
public void setOutgoingInterceptorList(String interceptorList) {
|
||||||
serverLocator.setOutgoingInterceptorList(interceptorList);
|
serverLocator.setOutgoingInterceptorList(interceptorList);
|
||||||
|
|
|
@ -43,8 +43,10 @@ public abstract class OutboundTransformer {
|
||||||
*
|
*
|
||||||
* @return the message format key of the encoded message.
|
* @return the message format key of the encoded message.
|
||||||
*
|
*
|
||||||
* @throws Exception
|
* @throws JMSException
|
||||||
* if an error occurs during message transformation
|
* if an error occurs during message transformation
|
||||||
|
* @throws UnsupportedEncodingException
|
||||||
|
* if an error occurs during message encoding
|
||||||
*/
|
*/
|
||||||
public abstract long transform(ServerJMSMessage message, WritableBuffer buffer) throws JMSException, UnsupportedEncodingException;
|
public abstract long transform(ServerJMSMessage message, WritableBuffer buffer) throws JMSException, UnsupportedEncodingException;
|
||||||
|
|
||||||
|
|
|
@ -27,7 +27,7 @@ import org.apache.activemq.artemis.core.settings.HierarchicalRepositoryChangeLis
|
||||||
* <PRE>
|
* <PRE>
|
||||||
*
|
*
|
||||||
* +--------------+ 1 +----------------+ N +--------------+ N +--------+ 1 +-------------------+
|
* +--------------+ 1 +----------------+ N +--------------+ N +--------+ 1 +-------------------+
|
||||||
* | {@link org.apache.activemq.artemis.core.postoffice.PostOffice} |-------> |{@link PagingManager}|-------> |{@link PagingStore} | ------> | {@link org.apache.activemq.artemis.core.paging.impl.Page} | ------> | {@link SequentialFile} |
|
* | {@link org.apache.activemq.artemis.core.postoffice.PostOffice} |-------> |{@link PagingManager}|-------> |{@link PagingStore} | ------> | {@link org.apache.activemq.artemis.core.paging.impl.Page} | ------> | {@link org.apache.activemq.artemis.core.io.SequentialFile} |
|
||||||
* +--------------+ +----------------+ +--------------+ +--------+ +-------------------+
|
* +--------------+ +----------------+ +--------------+ +--------+ +-------------------+
|
||||||
* | 1 ^
|
* | 1 ^
|
||||||
* | |
|
* | |
|
||||||
|
|
|
@ -166,7 +166,7 @@ public interface PagingStore extends ActiveMQComponent {
|
||||||
/**
|
/**
|
||||||
* Sends the pages with given IDs to the {@link ReplicationManager}.
|
* Sends the pages with given IDs to the {@link ReplicationManager}.
|
||||||
* <p>
|
* <p>
|
||||||
* Sending is done here to avoid exposing the internal {@link SequentialFile}s.
|
* Sending is done here to avoid exposing the internal {@link org.apache.activemq.artemis.core.io.SequentialFile}s.
|
||||||
*
|
*
|
||||||
* @param replicator
|
* @param replicator
|
||||||
* @param pageIds
|
* @param pageIds
|
||||||
|
|
|
@ -279,7 +279,7 @@ public interface ActiveMQServer extends ActiveMQComponent {
|
||||||
* @param name
|
* @param name
|
||||||
* @param filterString
|
* @param filterString
|
||||||
* @param durable
|
* @param durable
|
||||||
* @throws ActiveMQInvalidTransientQueueUseException if the shared queue already exists with a different {@code address} or {@code filter}
|
* @throws org.apache.activemq.artemis.api.core.ActiveMQInvalidTransientQueueUseException if the shared queue already exists with a different {@code address} or {@code filterString}
|
||||||
* @throws NullPointerException if {@code address} is {@code null}
|
* @throws NullPointerException if {@code address} is {@code null}
|
||||||
*/
|
*/
|
||||||
void createSharedQueue(final SimpleString address,
|
void createSharedQueue(final SimpleString address,
|
||||||
|
|
|
@ -150,7 +150,7 @@ public class AmqpMessage {
|
||||||
/**
|
/**
|
||||||
* Accepts the message marking it as consumed on the remote peer.
|
* Accepts the message marking it as consumed on the remote peer.
|
||||||
*
|
*
|
||||||
* @param session The session that is used to manage acceptance of the message.
|
* @param txnSession The session that is used to manage acceptance of the message.
|
||||||
* @throws Exception if an error occurs during the accept.
|
* @throws Exception if an error occurs during the accept.
|
||||||
*/
|
*/
|
||||||
public void accept(AmqpSession txnSession) throws Exception {
|
public void accept(AmqpSession txnSession) throws Exception {
|
||||||
|
@ -160,7 +160,7 @@ public class AmqpMessage {
|
||||||
/**
|
/**
|
||||||
* Accepts the message marking it as consumed on the remote peer.
|
* Accepts the message marking it as consumed on the remote peer.
|
||||||
*
|
*
|
||||||
* @param session
|
* @param txnSession
|
||||||
* The session that is used to manage acceptance of the message.
|
* The session that is used to manage acceptance of the message.
|
||||||
*
|
*
|
||||||
* @throws Exception if an error occurs during the accept.
|
* @throws Exception if an error occurs during the accept.
|
||||||
|
@ -354,7 +354,7 @@ public class AmqpMessage {
|
||||||
/**
|
/**
|
||||||
* Sets the GroupId property on an outbound message using the provided String
|
* Sets the GroupId property on an outbound message using the provided String
|
||||||
*
|
*
|
||||||
* @param messageId the String Group ID value to set.
|
* @param groupId the String Group ID value to set.
|
||||||
*/
|
*/
|
||||||
public void setGroupId(String groupId) {
|
public void setGroupId(String groupId) {
|
||||||
checkReadOnly();
|
checkReadOnly();
|
||||||
|
@ -505,7 +505,7 @@ public class AmqpMessage {
|
||||||
* Sets a byte array value into the body of an outgoing Message, throws
|
* Sets a byte array value into the body of an outgoing Message, throws
|
||||||
* an exception if this is an incoming message instance.
|
* an exception if this is an incoming message instance.
|
||||||
*
|
*
|
||||||
* @param value the byte array value to store in the Message body.
|
* @param bytes the byte array value to store in the Message body.
|
||||||
* @throws IllegalStateException if the message is read only.
|
* @throws IllegalStateException if the message is read only.
|
||||||
*/
|
*/
|
||||||
public void setBytes(byte[] bytes) throws IllegalStateException {
|
public void setBytes(byte[] bytes) throws IllegalStateException {
|
||||||
|
@ -515,10 +515,10 @@ public class AmqpMessage {
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Sets a byte array value into the body of an outgoing Message, throws
|
* Sets a described type into the body of an outgoing Message, throws
|
||||||
* an exception if this is an incoming message instance.
|
* an exception if this is an incoming message instance.
|
||||||
*
|
*
|
||||||
* @param value the byte array value to store in the Message body.
|
* @param described the described type value to store in the Message body.
|
||||||
* @throws IllegalStateException if the message is read only.
|
* @throws IllegalStateException if the message is read only.
|
||||||
*/
|
*/
|
||||||
public void setDescribedType(DescribedType described) throws IllegalStateException {
|
public void setDescribedType(DescribedType described) throws IllegalStateException {
|
||||||
|
|
Loading…
Reference in New Issue