Browse files

Replace all "/* (non-Javadoc)\n* @see ETC */" with @Override:

- Delete all unused methods not overriding anything;
- Reduce visibility when possible

FYI, regular expression used was:
/\* \(non-Javadoc\)\R    \* @see [\p{Alpha}\p{Digit}\p{Punct}\p{Blank}]*\R    \*/\R[\s\t]*public
REPLACED WITH
@Override\R   public
  • Loading branch information...
1 parent bd97be4 commit a4ca83bdabc0193e433ce4285ea6b080402266b3 Francisco Borges committed Jan 4, 2013
Showing with 254 additions and 1,013 deletions.
  1. +4 −12 hornetq-core-client/src/main/java/org/hornetq/core/client/impl/ClientMessageImpl.java
  2. +28 −115 ...-core-client/src/main/java/org/hornetq/core/client/impl/CompressedLargeMessageControllerImpl.java
  3. +37 −163 hornetq-core-client/src/main/java/org/hornetq/core/client/impl/LargeMessageControllerImpl.java
  4. +1 −3 hornetq-jms-server/src/main/java/org/hornetq/jms/management/impl/JMSQueueControlImpl.java
  5. +3 −9 hornetq-jms-server/src/main/java/org/hornetq/jms/management/impl/JMSServerControlImpl.java
  6. +2 −14 hornetq-jms-server/src/main/java/org/hornetq/jms/management/impl/JMSTopicControlImpl.java
  7. +3 −9 hornetq-jms-server/src/main/java/org/hornetq/jms/persistence/config/PersistedConnectionFactory.java
  8. +3 −9 hornetq-jms-server/src/main/java/org/hornetq/jms/persistence/config/PersistedJNDI.java
  9. +4 −12 ...s-server/src/main/java/org/hornetq/jms/persistence/impl/journal/JMSJournalStorageManagerImpl.java
  10. +14 −77 ...q-jms-server/src/main/java/org/hornetq/jms/persistence/impl/nullpm/NullJMSStorageManagerImpl.java
  11. +3 −9 ...s-server/src/main/java/org/hornetq/jms/server/config/impl/ConnectionFactoryConfigurationImpl.java
  12. +5 −19 hornetq-jms-server/src/main/java/org/hornetq/jms/server/impl/JMSServerManagerImpl.java
  13. +2 −6 hornetq-jms-server/src/main/java/org/hornetq/jms/server/recovery/RecoveryDiscovery.java
  14. +2 −6 hornetq-journal/src/main/java/org/hornetq/core/journal/impl/AIOSequentialFile.java
  15. +2 −6 hornetq-journal/src/main/java/org/hornetq/core/journal/impl/AbstractSequentialFileFactory.java
  16. +1 −3 hornetq-journal/src/main/java/org/hornetq/core/journal/impl/DummyCallback.java
  17. +2 −6 hornetq-journal/src/main/java/org/hornetq/core/journal/impl/JournalCompactor.java
  18. +3 −9 hornetq-journal/src/main/java/org/hornetq/core/journal/impl/JournalFileImpl.java
  19. +1 −3 hornetq-journal/src/main/java/org/hornetq/core/journal/impl/JournalImpl.java
  20. +1 −3 hornetq-journal/src/main/java/org/hornetq/core/journal/impl/SimpleWaitIOCallback.java
  21. +1 −3 hornetq-journal/src/main/java/org/hornetq/core/journal/impl/dataformat/JournalAddRecord.java
  22. +1 −3 hornetq-journal/src/main/java/org/hornetq/core/journal/impl/dataformat/JournalDeleteRecordTX.java
  23. +1 −3 hornetq-journal/src/main/java/org/hornetq/core/journal/impl/dataformat/JournalRollbackRecordTX.java
  24. +8 −24 hornetq-server/src/main/java/org/hornetq/core/config/impl/ConfigurationImpl.java
  25. +1 −3 hornetq-server/src/main/java/org/hornetq/core/management/impl/QueueControlImpl.java
  26. +12 −36 hornetq-server/src/main/java/org/hornetq/core/paging/cursor/PagedReferenceImpl.java
  27. +1 −3 hornetq-server/src/main/java/org/hornetq/core/paging/cursor/impl/PagePositionImpl.java
  28. +5 −15 hornetq-server/src/main/java/org/hornetq/core/paging/cursor/impl/PageSubscriptionImpl.java
  29. +1 −3 hornetq-server/src/main/java/org/hornetq/core/paging/impl/PageTransactionInfoImpl.java
  30. +3 −9 hornetq-server/src/main/java/org/hornetq/core/persistence/config/PersistedAddressSetting.java
  31. +3 −9 hornetq-server/src/main/java/org/hornetq/core/persistence/config/PersistedRoles.java
  32. +2 −6 hornetq-server/src/main/java/org/hornetq/core/persistence/impl/journal/JournalStorageManager.java
  33. +6 −44 ...-server/src/main/java/org/hornetq/core/persistence/impl/nullpm/NullStorageLargeServerMessage.java
  34. +2 −4 hornetq-server/src/main/java/org/hornetq/core/remoting/impl/netty/NettyAcceptor.java
  35. +1 −3 hornetq-server/src/main/java/org/hornetq/core/server/impl/ServerMessageImpl.java
  36. +1 −3 hornetq-server/src/main/java/org/hornetq/core/server/impl/ServerSessionImpl.java
  37. +3 −9 hornetq-server/src/main/java/org/hornetq/core/settings/impl/AddressSettings.java
  38. +2 −6 ...ornetq-spring-integration/src/main/java/org/hornetq/integration/spring/SpringBindingRegistry.java
  39. +11 −55 ...tests/src/test/java/org/hornetq/tests/unit/core/journal/impl/fakes/FakeSequentialFileFactory.java
  40. +50 −209 tests/unit-tests/src/test/java/org/hornetq/tests/unit/core/postoffice/impl/FakeQueue.java
  41. +16 −64 tests/unit-tests/src/test/java/org/hornetq/tests/unit/core/server/impl/fakes/FakePostOffice.java
  42. +2 −6 tests/unit-tests/src/test/java/org/hornetq/tests/unit/ra/MessageEndpointFactory.java
View
16 hornetq-core-client/src/main/java/org/hornetq/core/client/impl/ClientMessageImpl.java
@@ -143,9 +143,7 @@ public String toString()
return "ClientMessage[messageID=" + messageID + ", durable=" + durable + ", address=" + getAddress() + ",properties=" + properties.toString() + "]";
}
- /* (non-Javadoc)
- * @see org.hornetq.api.core.client.ClientMessage#saveToOutputStream(java.io.OutputStream)
- */
+ @Override
public void saveToOutputStream(final OutputStream out) throws HornetQException
{
try
@@ -161,25 +159,19 @@ public void saveToOutputStream(final OutputStream out) throws HornetQException
}
}
- /* (non-Javadoc)
- * @see org.hornetq.api.core.client.ClientMessage#setOutputStream(java.io.OutputStream)
- */
+ @Override
public void setOutputStream(final OutputStream out) throws HornetQException
{
saveToOutputStream(out);
}
- /* (non-Javadoc)
- * @see org.hornetq.api.core.client.ClientMessage#waitOutputStreamCompletion()
- */
+ @Override
public boolean waitOutputStreamCompletion(final long timeMilliseconds) throws HornetQException
{
return true;
}
- /* (non-Javadoc)
- * @see org.hornetq.api.core.client.impl.ClientMessageInternal#discardLargeBody()
- */
+ @Override
public void discardBody()
{
}
View
143 ...ient/src/main/java/org/hornetq/core/client/impl/CompressedLargeMessageControllerImpl.java
@@ -25,8 +25,8 @@
import org.hornetq.api.core.HornetQBuffers;
import org.hornetq.api.core.HornetQException;
import org.hornetq.api.core.SimpleString;
-import org.hornetq.core.protocol.core.impl.wireformat.SessionReceiveContinuationMessage;
import org.hornetq.core.client.HornetQClientLogger;
+import org.hornetq.core.protocol.core.impl.wireformat.SessionReceiveContinuationMessage;
import org.hornetq.utils.DataConstants;
import org.hornetq.utils.HornetQBufferInputStream;
import org.hornetq.utils.InflaterReader;
@@ -202,10 +202,7 @@ public short getShort(final long index)
return (short)(getByte(index) << 8 | getByte(index + 1) & 0xFF);
}
- /* (non-Javadoc)
- * @see org.hornetq.api.core.buffers.ChannelBuffer#getUnsignedMedium(int)
- */
- public int getUnsignedMedium(final int index)
+ private int getUnsignedMedium(final int index)
{
positioningNotSupported();
return 0;
@@ -217,102 +214,54 @@ public int getUnsignedMedium(final long index)
return 0;
}
- /* (non-Javadoc)
- * @see org.hornetq.api.core.buffers.ChannelBuffer#setByte(int, byte)
- */
+ @Override
public void setByte(final int index, final byte value)
{
throw new IllegalAccessError(OPERATION_NOT_SUPPORTED);
}
- /* (non-Javadoc)
- * @see org.hornetq.api.core.buffers.ChannelBuffer#setBytes(int, org.hornetq.api.core.buffers.ChannelBuffer, int, int)
- */
+ @Override
public void setBytes(final int index, final HornetQBuffer src, final int srcIndex, final int length)
{
throw new IllegalAccessError(OPERATION_NOT_SUPPORTED);
}
- /* (non-Javadoc)
- * @see org.hornetq.api.core.buffers.ChannelBuffer#setBytes(int, byte[], int, int)
- */
+ @Override
public void setBytes(final int index, final byte[] src, final int srcIndex, final int length)
{
throw new IllegalAccessError(OPERATION_NOT_SUPPORTED);
}
- /* (non-Javadoc)
- * @see org.hornetq.api.core.buffers.ChannelBuffer#setBytes(int, java.nio.ByteBuffer)
- */
+ @Override
public void setBytes(final int index, final ByteBuffer src)
{
throw new IllegalAccessError(OPERATION_NOT_SUPPORTED);
}
- /* (non-Javadoc)
- * @see org.hornetq.api.core.buffers.ChannelBuffer#setBytes(int, java.io.InputStream, int)
- */
- public int setBytes(final int index, final InputStream in, final int length) throws IOException
- {
- throw new IllegalAccessError(OPERATION_NOT_SUPPORTED);
- }
-
- /* (non-Javadoc)
- * @see org.hornetq.api.core.buffers.ChannelBuffer#setBytes(int, java.nio.channels.ScatteringByteChannel, int)
- */
- public int setBytes(final int index, final ScatteringByteChannel in, final int length) throws IOException
- {
- throw new IllegalAccessError(OPERATION_NOT_SUPPORTED);
- }
-
- /* (non-Javadoc)
- * @see org.hornetq.api.core.buffers.ChannelBuffer#setInt(int, int)
- */
+ @Override
public void setInt(final int index, final int value)
{
throw new IllegalAccessError(OPERATION_NOT_SUPPORTED);
}
- /* (non-Javadoc)
- * @see org.hornetq.api.core.buffers.ChannelBuffer#setLong(int, long)
- */
+ @Override
public void setLong(final int index, final long value)
{
throw new IllegalAccessError(OPERATION_NOT_SUPPORTED);
}
- /* (non-Javadoc)
- * @see org.hornetq.api.core.buffers.ChannelBuffer#setMedium(int, int)
- */
- public void setMedium(final int index, final int value)
- {
- throw new IllegalAccessError(OPERATION_NOT_SUPPORTED);
- }
-
- /* (non-Javadoc)
- * @see org.hornetq.api.core.buffers.ChannelBuffer#setShort(int, short)
- */
+ @Override
public void setShort(final int index, final short value)
{
throw new IllegalAccessError(OPERATION_NOT_SUPPORTED);
}
- /* (non-Javadoc)
- * @see org.hornetq.api.core.buffers.ChannelBuffer#toByteBuffer(int, int)
- */
+ @Override
public ByteBuffer toByteBuffer(final int index, final int length)
{
throw new IllegalAccessError(OPERATION_NOT_SUPPORTED);
}
- /* (non-Javadoc)
- * @see org.hornetq.api.core.buffers.ChannelBuffer#toString(int, int, java.lang.String)
- */
- public String toString(final int index, final int length, final String charsetName)
- {
- throw new IllegalAccessError(OPERATION_NOT_SUPPORTED);
- }
-
public int readerIndex()
{
return 0;
@@ -724,17 +673,13 @@ public Object getUnderlyingBuffer()
return this;
}
- /* (non-Javadoc)
- * @see org.hornetq.spi.core.remoting.HornetQBuffer#readBoolean()
- */
+ @Override
public boolean readBoolean()
{
return readByte() != 0;
}
- /* (non-Javadoc)
- * @see org.hornetq.spi.core.remoting.HornetQBuffer#readChar()
- */
+ @Override
public char readChar()
{
return (char)readShort();
@@ -762,25 +707,19 @@ public HornetQBuffer readBytes(final int length)
return HornetQBuffers.wrappedBuffer(bytesToGet);
}
- /* (non-Javadoc)
- * @see org.hornetq.spi.core.remoting.HornetQBuffer#readDouble()
- */
+ @Override
public double readDouble()
{
return Double.longBitsToDouble(readLong());
}
- /* (non-Javadoc)
- * @see org.hornetq.spi.core.remoting.HornetQBuffer#readFloat()
- */
+ @Override
public float readFloat()
{
return Float.intBitsToFloat(readInt());
}
- /* (non-Javadoc)
- * @see org.hornetq.spi.core.remoting.HornetQBuffer#readNullableSimpleString()
- */
+ @Override
public SimpleString readNullableSimpleString()
{
int b = readByte();
@@ -794,9 +733,7 @@ public SimpleString readNullableSimpleString()
}
}
- /* (non-Javadoc)
- * @see org.hornetq.spi.core.remoting.HornetQBuffer#readNullableString()
- */
+ @Override
public String readNullableString()
{
int b = readByte();
@@ -810,9 +747,7 @@ public String readNullableString()
}
}
- /* (non-Javadoc)
- * @see org.hornetq.spi.core.remoting.HornetQBuffer#readSimpleString()
- */
+ @Override
public SimpleString readSimpleString()
{
int len = readInt();
@@ -821,9 +756,7 @@ public SimpleString readSimpleString()
return new SimpleString(data);
}
- /* (non-Javadoc)
- * @see org.hornetq.spi.core.remoting.HornetQBuffer#readString()
- */
+ @Override
public String readString()
{
int len = readInt();
@@ -847,83 +780,63 @@ else if (len < 0xfff)
}
}
- /* (non-Javadoc)
- * @see org.hornetq.spi.core.remoting.HornetQBuffer#readUTF()
- */
+ @Override
public String readUTF()
{
return UTF8Util.readUTF(this);
}
- /* (non-Javadoc)
- * @see org.hornetq.spi.core.remoting.HornetQBuffer#writeBoolean(boolean)
- */
+ @Override
public void writeBoolean(final boolean val)
{
throw new IllegalAccessError(OPERATION_NOT_SUPPORTED);
}
- /* (non-Javadoc)
- * @see org.hornetq.spi.core.remoting.HornetQBuffer#writeChar(char)
- */
+ @Override
public void writeChar(final char val)
{
throw new IllegalAccessError(OPERATION_NOT_SUPPORTED);
}
- /* (non-Javadoc)
- * @see org.hornetq.spi.core.remoting.HornetQBuffer#writeDouble(double)
- */
+ @Override
public void writeDouble(final double val)
{
throw new IllegalAccessError(OPERATION_NOT_SUPPORTED);
}
- /* (non-Javadoc)
- * @see org.hornetq.spi.core.remoting.HornetQBuffer#writeFloat(float)
- */
+ @Override
public void writeFloat(final float val)
{
throw new IllegalAccessError(OPERATION_NOT_SUPPORTED);
}
- /* (non-Javadoc)
- * @see org.hornetq.spi.core.remoting.HornetQBuffer#writeNullableSimpleString(org.hornetq.util.SimpleString)
- */
+ @Override
public void writeNullableSimpleString(final SimpleString val)
{
throw new IllegalAccessError(OPERATION_NOT_SUPPORTED);
}
- /* (non-Javadoc)
- * @see org.hornetq.spi.core.remoting.HornetQBuffer#writeNullableString(java.lang.String)
- */
+ @Override
public void writeNullableString(final String val)
{
throw new IllegalAccessError(OPERATION_NOT_SUPPORTED);
}
- /* (non-Javadoc)
- * @see org.hornetq.spi.core.remoting.HornetQBuffer#writeSimpleString(org.hornetq.util.SimpleString)
- */
+ @Override
public void writeSimpleString(final SimpleString val)
{
throw new IllegalAccessError(OPERATION_NOT_SUPPORTED);
}
- /* (non-Javadoc)
- * @see org.hornetq.spi.core.remoting.HornetQBuffer#writeString(java.lang.String)
- */
+ @Override
public void writeString(final String val)
{
throw new IllegalAccessError(OPERATION_NOT_SUPPORTED);
}
- /* (non-Javadoc)
- * @see org.hornetq.spi.core.remoting.HornetQBuffer#writeUTF(java.lang.String)
- */
+ @Override
public void writeUTF(final String utf)
{
throw new IllegalAccessError(OPERATION_NOT_SUPPORTED);
View
200 ...tq-core-client/src/main/java/org/hornetq/core/client/impl/LargeMessageControllerImpl.java
@@ -32,10 +32,10 @@
import org.hornetq.api.core.HornetQExceptionType;
import org.hornetq.api.core.HornetQInterruptedException;
import org.hornetq.api.core.SimpleString;
-import org.hornetq.core.protocol.core.Packet;
-import org.hornetq.core.protocol.core.impl.wireformat.SessionReceiveContinuationMessage;
import org.hornetq.core.client.HornetQClientLogger;
import org.hornetq.core.client.HornetQClientMessageBundle;
+import org.hornetq.core.protocol.core.Packet;
+import org.hornetq.core.protocol.core.impl.wireformat.SessionReceiveContinuationMessage;
import org.hornetq.utils.DataConstants;
import org.hornetq.utils.UTF8Util;
import org.jboss.netty.buffer.ChannelBuffer;
@@ -397,17 +397,7 @@ private void checkException() throws HornetQException
// Channel Buffer Implementation ---------------------------------
- /* (non-Javadoc)
- * @see org.hornetq.api.core.buffers.ChannelBuffer#array()
- */
- public byte[] array()
- {
- throw new IllegalAccessError("array not supported on LargeMessageBufferImpl");
- }
-
- /* (non-Javadoc)
- * @see org.hornetq.api.core.buffers.ChannelBuffer#capacity()
- */
+ @Override
public int capacity()
{
return -1;
@@ -418,9 +408,7 @@ public byte readByte()
return getByte(readerIndex++);
}
- /* (non-Javadoc)
- * @see org.hornetq.api.core.buffers.ChannelBuffer#getByte(int)
- */
+ @Override
public byte getByte(final int index)
{
return getByte((long)index);
@@ -440,29 +428,22 @@ private byte getByte(final long index)
}
}
- /* (non-Javadoc)
- * @see org.hornetq.api.core.buffers.ChannelBuffer#getBytes(int, org.hornetq.api.core.buffers.ChannelBuffer, int, int)
- */
+ @Override
public void getBytes(final int index, final HornetQBuffer dst, final int dstIndex, final int length)
{
byte[] destBytes = new byte[length];
getBytes(index, destBytes);
dst.setBytes(dstIndex, destBytes);
}
- /* (non-Javadoc)
- * @see org.hornetq.api.core.buffers.ChannelBuffer#getBytes(int, org.hornetq.api.core.buffers.ChannelBuffer, int, int)
- */
- public void getBytes(final long index, final HornetQBuffer dst, final int dstIndex, final int length)
+ private void getBytes(final long index, final HornetQBuffer dst, final int dstIndex, final int length)
{
byte[] destBytes = new byte[length];
getBytes(index, destBytes);
dst.setBytes(dstIndex, destBytes);
}
- /* (non-Javadoc)
- * @see org.hornetq.api.core.buffers.ChannelBuffer#getBytes(int, byte[], int, int)
- */
+ @Override
public void getBytes(final int index, final byte[] dst, final int dstIndex, final int length)
{
byte bytesToGet[] = new byte[length];
@@ -481,9 +462,7 @@ public void getBytes(final long index, final byte[] dst, final int dstIndex, fin
System.arraycopy(bytesToGet, 0, dst, dstIndex, length);
}
- /* (non-Javadoc)
- * @see org.hornetq.api.core.buffers.ChannelBuffer#getBytes(int, java.nio.ByteBuffer)
- */
+ @Override
public void getBytes(final int index, final ByteBuffer dst)
{
byte bytesToGet[] = new byte[dst.remaining()];
@@ -533,9 +512,7 @@ public int getInt(final long index)
(getByte(index + 3) & 0xff) << 0;
}
- /* (non-Javadoc)
- * @see org.hornetq.api.core.buffers.ChannelBuffer#getLong(int)
- */
+ @Override
public long getLong(final int index)
{
return ((long)getByte(index) & 0xff) << 56 | ((long)getByte(index + 1) & 0xff) << 48 |
@@ -558,9 +535,7 @@ public long getLong(final long index)
((long)getByte(index + 7) & 0xff) << 0;
}
- /* (non-Javadoc)
- * @see org.hornetq.api.core.buffers.ChannelBuffer#getShort(int)
- */
+ @Override
public short getShort(final int index)
{
return (short)(getByte(index) << 8 | getByte(index + 1) & 0xFF);
@@ -571,10 +546,7 @@ public short getShort(final long index)
return (short)(getByte(index) << 8 | getByte(index + 1) & 0xFF);
}
- /* (non-Javadoc)
- * @see org.hornetq.api.core.buffers.ChannelBuffer#getUnsignedMedium(int)
- */
- public int getUnsignedMedium(final int index)
+ private int getUnsignedMedium(final int index)
{
return (getByte(index) & 0xff) << 16 | (getByte(index + 1) & 0xff) << 8 | (getByte(index + 2) & 0xff) << 0;
}
@@ -584,102 +556,54 @@ public int getUnsignedMedium(final long index)
return (getByte(index) & 0xff) << 16 | (getByte(index + 1) & 0xff) << 8 | (getByte(index + 2) & 0xff) << 0;
}
- /* (non-Javadoc)
- * @see org.hornetq.api.core.buffers.ChannelBuffer#setByte(int, byte)
- */
+ @Override
public void setByte(final int index, final byte value)
{
throw new IllegalAccessError(LargeMessageControllerImpl.READ_ONLY_ERROR_MESSAGE);
}
- /* (non-Javadoc)
- * @see org.hornetq.api.core.buffers.ChannelBuffer#setBytes(int, org.hornetq.api.core.buffers.ChannelBuffer, int, int)
- */
+ @Override
public void setBytes(final int index, final HornetQBuffer src, final int srcIndex, final int length)
{
throw new IllegalAccessError(LargeMessageControllerImpl.READ_ONLY_ERROR_MESSAGE);
}
- /* (non-Javadoc)
- * @see org.hornetq.api.core.buffers.ChannelBuffer#setBytes(int, byte[], int, int)
- */
+ @Override
public void setBytes(final int index, final byte[] src, final int srcIndex, final int length)
{
throw new IllegalAccessError(LargeMessageControllerImpl.READ_ONLY_ERROR_MESSAGE);
}
- /* (non-Javadoc)
- * @see org.hornetq.api.core.buffers.ChannelBuffer#setBytes(int, java.nio.ByteBuffer)
- */
+ @Override
public void setBytes(final int index, final ByteBuffer src)
{
throw new IllegalAccessError(LargeMessageControllerImpl.READ_ONLY_ERROR_MESSAGE);
}
- /* (non-Javadoc)
- * @see org.hornetq.api.core.buffers.ChannelBuffer#setBytes(int, java.io.InputStream, int)
- */
- public int setBytes(final int index, final InputStream in, final int length) throws IOException
- {
- throw new IllegalAccessError(LargeMessageControllerImpl.READ_ONLY_ERROR_MESSAGE);
- }
-
- /* (non-Javadoc)
- * @see org.hornetq.api.core.buffers.ChannelBuffer#setBytes(int, java.nio.channels.ScatteringByteChannel, int)
- */
- public int setBytes(final int index, final ScatteringByteChannel in, final int length) throws IOException
- {
- throw new IllegalAccessError(LargeMessageControllerImpl.READ_ONLY_ERROR_MESSAGE);
- }
-
- /* (non-Javadoc)
- * @see org.hornetq.api.core.buffers.ChannelBuffer#setInt(int, int)
- */
+ @Override
public void setInt(final int index, final int value)
{
throw new IllegalAccessError(LargeMessageControllerImpl.READ_ONLY_ERROR_MESSAGE);
}
- /* (non-Javadoc)
- * @see org.hornetq.api.core.buffers.ChannelBuffer#setLong(int, long)
- */
+ @Override
public void setLong(final int index, final long value)
{
throw new IllegalAccessError(LargeMessageControllerImpl.READ_ONLY_ERROR_MESSAGE);
}
- /* (non-Javadoc)
- * @see org.hornetq.api.core.buffers.ChannelBuffer#setMedium(int, int)
- */
- public void setMedium(final int index, final int value)
- {
- throw new IllegalAccessError(LargeMessageControllerImpl.READ_ONLY_ERROR_MESSAGE);
- }
-
- /* (non-Javadoc)
- * @see org.hornetq.api.core.buffers.ChannelBuffer#setShort(int, short)
- */
+ @Override
public void setShort(final int index, final short value)
{
throw new IllegalAccessError(LargeMessageControllerImpl.READ_ONLY_ERROR_MESSAGE);
}
- /* (non-Javadoc)
- * @see org.hornetq.api.core.buffers.ChannelBuffer#toByteBuffer(int, int)
- */
+ @Override
public ByteBuffer toByteBuffer(final int index, final int length)
{
throw new IllegalAccessError(LargeMessageControllerImpl.READ_ONLY_ERROR_MESSAGE);
}
- /* (non-Javadoc)
- * @see org.hornetq.api.core.buffers.ChannelBuffer#toString(int, int, java.lang.String)
- */
- public String toString(final int index, final int length, final String charsetName)
- {
- throw new IllegalAccessError(LargeMessageControllerImpl.READ_ONLY_ERROR_MESSAGE);
- }
-
public int readerIndex()
{
return (int)readerIndex;
@@ -1081,17 +1005,13 @@ public Object getUnderlyingBuffer()
return this;
}
- /* (non-Javadoc)
- * @see org.hornetq.spi.core.remoting.HornetQBuffer#readBoolean()
- */
+ @Override
public boolean readBoolean()
{
return readByte() != 0;
}
- /* (non-Javadoc)
- * @see org.hornetq.spi.core.remoting.HornetQBuffer#readChar()
- */
+ @Override
public char readChar()
{
return (char)readShort();
@@ -1120,25 +1040,19 @@ public HornetQBuffer readBytes(final int length)
return HornetQBuffers.wrappedBuffer(bytesToGet);
}
- /* (non-Javadoc)
- * @see org.hornetq.spi.core.remoting.HornetQBuffer#readDouble()
- */
+ @Override
public double readDouble()
{
return Double.longBitsToDouble(readLong());
}
- /* (non-Javadoc)
- * @see org.hornetq.spi.core.remoting.HornetQBuffer#readFloat()
- */
+ @Override
public float readFloat()
{
return Float.intBitsToFloat(readInt());
}
- /* (non-Javadoc)
- * @see org.hornetq.spi.core.remoting.HornetQBuffer#readNullableSimpleString()
- */
+ @Override
public SimpleString readNullableSimpleString()
{
int b = readByte();
@@ -1152,9 +1066,7 @@ public SimpleString readNullableSimpleString()
}
}
- /* (non-Javadoc)
- * @see org.hornetq.spi.core.remoting.HornetQBuffer#readNullableString()
- */
+ @Override
public String readNullableString()
{
int b = readByte();
@@ -1168,9 +1080,7 @@ public String readNullableString()
}
}
- /* (non-Javadoc)
- * @see org.hornetq.spi.core.remoting.HornetQBuffer#readSimpleString()
- */
+ @Override
public SimpleString readSimpleString()
{
int len = readInt();
@@ -1179,9 +1089,7 @@ public SimpleString readSimpleString()
return new SimpleString(data);
}
- /* (non-Javadoc)
- * @see org.hornetq.spi.core.remoting.HornetQBuffer#readString()
- */
+ @Override
public String readString()
{
int len = readInt();
@@ -1205,96 +1113,68 @@ else if (len < 0xfff)
}
}
- /* (non-Javadoc)
- * @see org.hornetq.spi.core.remoting.HornetQBuffer#readUTF()
- */
+ @Override
public String readUTF()
{
return UTF8Util.readUTF(this);
}
- /* (non-Javadoc)
- * @see org.hornetq.spi.core.remoting.HornetQBuffer#writeBoolean(boolean)
- */
+ @Override
public void writeBoolean(final boolean val)
{
throw new IllegalAccessError(LargeMessageControllerImpl.READ_ONLY_ERROR_MESSAGE);
}
- /* (non-Javadoc)
- * @see org.hornetq.spi.core.remoting.HornetQBuffer#writeChar(char)
- */
+ @Override
public void writeChar(final char val)
{
throw new IllegalAccessError(LargeMessageControllerImpl.READ_ONLY_ERROR_MESSAGE);
}
- /* (non-Javadoc)
- * @see org.hornetq.spi.core.remoting.HornetQBuffer#writeDouble(double)
- */
+ @Override
public void writeDouble(final double val)
{
throw new IllegalAccessError(LargeMessageControllerImpl.READ_ONLY_ERROR_MESSAGE);
}
- /* (non-Javadoc)
- * @see org.hornetq.spi.core.remoting.HornetQBuffer#writeFloat(float)
- */
+ @Override
public void writeFloat(final float val)
{
throw new IllegalAccessError(LargeMessageControllerImpl.READ_ONLY_ERROR_MESSAGE);
}
- /* (non-Javadoc)
- * @see org.hornetq.spi.core.remoting.HornetQBuffer#writeNullableSimpleString(org.hornetq.util.SimpleString)
- */
+ @Override
public void writeNullableSimpleString(final SimpleString val)
{
throw new IllegalAccessError(LargeMessageControllerImpl.READ_ONLY_ERROR_MESSAGE);
}
- /* (non-Javadoc)
- * @see org.hornetq.spi.core.remoting.HornetQBuffer#writeNullableString(java.lang.String)
- */
+ @Override
public void writeNullableString(final String val)
{
throw new IllegalAccessError(LargeMessageControllerImpl.READ_ONLY_ERROR_MESSAGE);
}
- /* (non-Javadoc)
- * @see org.hornetq.spi.core.remoting.HornetQBuffer#writeSimpleString(org.hornetq.util.SimpleString)
- */
+ @Override
public void writeSimpleString(final SimpleString val)
{
throw new IllegalAccessError(LargeMessageControllerImpl.READ_ONLY_ERROR_MESSAGE);
}
- /* (non-Javadoc)
- * @see org.hornetq.spi.core.remoting.HornetQBuffer#writeString(java.lang.String)
- */
+ @Override
public void writeString(final String val)
{
throw new IllegalAccessError(LargeMessageControllerImpl.READ_ONLY_ERROR_MESSAGE);
}
- /* (non-Javadoc)
- * @see org.hornetq.spi.core.remoting.HornetQBuffer#writeUTF(java.lang.String)
- */
+ @Override
public void writeUTF(final String utf)
{
throw new IllegalAccessError(LargeMessageControllerImpl.READ_ONLY_ERROR_MESSAGE);
}
- /* (non-Javadoc)
- * @see org.hornetq.api.core.buffers.ChannelBuffer#compareTo(org.hornetq.api.core.buffers.ChannelBuffer)
- */
- public int compareTo(final HornetQBuffer buffer)
- {
- return -1;
- }
-
public HornetQBuffer copy()
{
throw new UnsupportedOperationException();
@@ -1305,12 +1185,6 @@ public HornetQBuffer slice(final int index, final int length)
throw new UnsupportedOperationException();
}
- // Package protected ---------------------------------------------
-
- // Protected -----------------------------------------------------
-
- // Private -------------------------------------------------------
-
/**
* @param output
* @param packet
View
4 hornetq-jms-server/src/main/java/org/hornetq/jms/management/impl/JMSQueueControlImpl.java
@@ -158,9 +158,7 @@ public void setExpiryAddress(final String expiryAddres) throws Exception
coreQueueControl.setExpiryAddress(expiryAddres);
}
- /* (non-Javadoc)
- * @see org.hornetq.api.jms.management.JMSQueueControl#addJNDI(java.lang.String)
- */
+ @Override
public void addJNDI(String jndi) throws Exception
{
jmsServerManager.addQueueToJndi(managedQueue.getName(), jndi);
View
12 hornetq-jms-server/src/main/java/org/hornetq/jms/management/impl/JMSServerControlImpl.java
@@ -208,9 +208,7 @@ public void createConnectionFactory(String name,
}
}
- /* (non-Javadoc)
- * @see org.hornetq.api.jms.management.JMSServerControl#createConnectionFactory(java.lang.String, boolean, boolean, int, java.lang.String, java.lang.String, java.lang.String, long, long, long, int, boolean, int, int, int, int, int, boolean, boolean, boolean, boolean, boolean, java.lang.String, int, int, boolean, int, int, long, double, long, int, boolean, java.lang.String)
- */
+ @Override
public void createConnectionFactory(String name,
boolean ha,
boolean useDiscovery,
@@ -284,9 +282,7 @@ public void createConnectionFactory(String name,
groupId);
}
- /* (non-Javadoc)
- * @see org.hornetq.api.jms.management.JMSServerControl#createConnectionFactory(java.lang.String, boolean, boolean, int, java.lang.String[], java.lang.String[], java.lang.String, long, long, long, int, boolean, int, int, int, int, int, boolean, boolean, boolean, boolean, boolean, java.lang.String, int, int, boolean, int, int, long, double, long, int, boolean, java.lang.String)
- */
+ @Override
public void createConnectionFactory(String name,
boolean ha,
boolean useDiscovery,
@@ -418,9 +414,7 @@ public boolean createQueue(final String name, final String jndiBindings) throws
return createQueue(name, jndiBindings, null, true);
}
- /* (non-Javadoc)
- * @see org.hornetq.api.jms.management.JMSServerControl#createQueue(java.lang.String, java.lang.String, java.lang.String)
- */
+ @Override
public boolean createQueue(String name, String jndiBindings, String selector) throws Exception
{
return createQueue(name, jndiBindings, selector, true);
View
16 hornetq-jms-server/src/main/java/org/hornetq/jms/management/impl/JMSTopicControlImpl.java
@@ -22,6 +22,7 @@
import javax.management.StandardMBean;
import org.hornetq.api.core.HornetQException;
+import org.hornetq.api.core.Pair;
import org.hornetq.api.core.management.AddressControl;
import org.hornetq.api.core.management.HornetQServerControl;
import org.hornetq.api.core.management.QueueControl;
@@ -33,7 +34,6 @@
import org.hornetq.jms.client.HornetQMessage;
import org.hornetq.jms.client.SelectorTranslator;
import org.hornetq.jms.server.JMSServerManager;
-import org.hornetq.api.core.Pair;
import org.hornetq.utils.json.JSONArray;
import org.hornetq.utils.json.JSONObject;
@@ -76,24 +76,12 @@ public JMSTopicControlImpl(final HornetQDestination topic,
// TopicControlMBean implementation ------------------------------
- /* (non-Javadoc)
- * @see org.hornetq.api.jms.management.JMSQueueControl#addJNDI(java.lang.String)
- */
+ @Override
public void addJNDI(String jndi) throws Exception
{
jmsServerManager.addTopicToJndi(managedTopic.getName(), jndi);
}
-
- /* (non-Javadoc)
- * @see org.hornetq.api.jms.management.TopicControl#removeJNDI(java.lang.String)
- */
- public void removeJNDI(String jndi) throws Exception
- {
- jmsServerManager.removeTopicFromJNDI(managedTopic.getName(), jndi);
- }
-
-
public String[] getJNDIBindings()
{
return jmsServerManager.getJNDIOnTopic(managedTopic.getName());
View
12 ...s-server/src/main/java/org/hornetq/jms/persistence/config/PersistedConnectionFactory.java
@@ -82,26 +82,20 @@ public ConnectionFactoryConfiguration getConfig()
return config;
}
- /* (non-Javadoc)
- * @see org.hornetq.core.journal.EncodingSupport#decode(org.hornetq.api.core.HornetQBuffer)
- */
+ @Override
public void decode(final HornetQBuffer buffer)
{
config = new ConnectionFactoryConfigurationImpl();
config.decode(buffer);
}
- /* (non-Javadoc)
- * @see org.hornetq.core.journal.EncodingSupport#encode(org.hornetq.api.core.HornetQBuffer)
- */
+ @Override
public void encode(final HornetQBuffer buffer)
{
config.encode(buffer);
}
- /* (non-Javadoc)
- * @see org.hornetq.core.journal.EncodingSupport#getEncodeSize()
- */
+ @Override
public int getEncodeSize()
{
return config.getEncodeSize();
View
12 hornetq-jms-server/src/main/java/org/hornetq/jms/persistence/config/PersistedJNDI.java
@@ -63,9 +63,7 @@ public PersistedJNDI(PersistedType type, String name)
}
// Public --------------------------------------------------------
- /* (non-Javadoc)
- * @see org.hornetq.core.journal.EncodingSupport#decode(org.hornetq.api.core.HornetQBuffer)
- */
+ @Override
public void decode(HornetQBuffer buffer)
{
type = PersistedType.getType(buffer.readByte());
@@ -79,9 +77,7 @@ public void decode(HornetQBuffer buffer)
}
}
- /* (non-Javadoc)
- * @see org.hornetq.core.journal.EncodingSupport#encode(org.hornetq.api.core.HornetQBuffer)
- */
+ @Override
public void encode(HornetQBuffer buffer)
{
buffer.writeByte(type.getType());
@@ -93,9 +89,7 @@ public void encode(HornetQBuffer buffer)
}
}
- /* (non-Javadoc)
- * @see org.hornetq.core.journal.EncodingSupport#getEncodeSize()
- */
+ @Override
public int getEncodeSize()
{
return DataConstants.SIZE_BYTE +
View
16 .../src/main/java/org/hornetq/jms/persistence/impl/journal/JMSJournalStorageManagerImpl.java
@@ -122,19 +122,15 @@ public JMSJournalStorageManagerImpl(final IDGenerator idGenerator,
// Public --------------------------------------------------------
- /* (non-Javadoc)
- * @see org.hornetq.jms.persistence.JMSStorageManager#recoverConnectionFactories()
- */
+ @Override
public List<PersistedConnectionFactory> recoverConnectionFactories()
{
List<PersistedConnectionFactory> cfs = new ArrayList<PersistedConnectionFactory>(mapFactories.size());
cfs.addAll(mapFactories.values());
return cfs;
}
- /* (non-Javadoc)
- * @see org.hornetq.jms.persistence.JMSStorageManager#storeConnectionFactory(org.hornetq.jms.persistence.PersistedConnectionFactory)
- */
+ @Override
public void storeConnectionFactory(final PersistedConnectionFactory connectionFactory) throws Exception
{
deleteConnectionFactory(connectionFactory.getName());
@@ -153,19 +149,15 @@ public void deleteConnectionFactory(final String cfName) throws Exception
}
}
- /* (non-Javadoc)
- * @see org.hornetq.jms.persistence.JMSStorageManager#recoverDestinations()
- */
+ @Override
public List<PersistedDestination> recoverDestinations()
{
List<PersistedDestination> destinations = new ArrayList<PersistedDestination>(this.destinations.size());
destinations.addAll(this.destinations.values());
return destinations;
}
- /* (non-Javadoc)
- * @see org.hornetq.jms.persistence.JMSStorageManager#storeDestination(org.hornetq.jms.persistence.PersistedDestination)
- */
+ @Override
public void storeDestination(final PersistedDestination destination) throws Exception
{
deleteDestination(destination.getType(), destination.getName());
View
91 ...rver/src/main/java/org/hornetq/jms/persistence/impl/nullpm/NullJMSStorageManagerImpl.java
@@ -16,7 +16,6 @@
import java.util.Collections;
import java.util.List;
-import org.hornetq.core.replication.ReplicationEndpoint;
import org.hornetq.jms.persistence.JMSStorageManager;
import org.hornetq.jms.persistence.config.PersistedConnectionFactory;
import org.hornetq.jms.persistence.config.PersistedDestination;
@@ -33,140 +32,78 @@
public class NullJMSStorageManagerImpl implements JMSStorageManager
{
- /* (non-Javadoc)
- * @see org.hornetq.jms.persistence.JMSStorageManager#deleteConnectionFactory(java.lang.String)
- */
+ @Override
public void deleteConnectionFactory(String connectionFactory) throws Exception
{
}
- /* (non-Javadoc)
- * @see org.hornetq.jms.persistence.JMSStorageManager#recoverConnectionFactories()
- */
+ @Override
public List<PersistedConnectionFactory> recoverConnectionFactories()
{
return Collections.emptyList();
}
- /* (non-Javadoc)
- * @see org.hornetq.jms.persistence.JMSStorageManager#recoverDestinations()
- */
+ @Override
public List<PersistedDestination> recoverDestinations()
{
return Collections.emptyList();
}
- /* (non-Javadoc)
- * @see org.hornetq.jms.persistence.JMSStorageManager#storeConnectionFactory(org.hornetq.jms.persistence.PersistedConnectionFactory)
- */
+ @Override
public void storeConnectionFactory(PersistedConnectionFactory connectionFactory) throws Exception
{
}
- /* (non-Javadoc)
- * @see org.hornetq.jms.persistence.JMSStorageManager#storeDestination(org.hornetq.jms.persistence.PersistedDestination)
- */
+ @Override
public void storeDestination(PersistedDestination destination)
{
}
- /* (non-Javadoc)
- * @see org.hornetq.jms.persistence.JMSStorageManager#deleteDestination (org.hornetq.jms.persistence.PersistedDestination)
- */
- public void deleteDestination(String name) throws Exception
- {
-
- }
-
- /* (non-Javadoc)
- * @see org.hornetq.core.server.HornetQComponent#isStarted()
- */
+ @Override
public boolean isStarted()
{
return true;
}
- /* (non-Javadoc)
- * @see org.hornetq.core.server.HornetQComponent#start()
- */
+ @Override
public void start() throws Exception
{
}
- /* (non-Javadoc)
- * @see org.hornetq.core.server.HornetQComponent#stop()
- */
+ @Override
public void stop() throws Exception
{
}
- /* (non-Javadoc)
- * @see org.hornetq.jms.persistence.JMSStorageManager#addJNDI(org.hornetq.jms.persistence.PersistedType, java.lang.String, java.lang.String)
- */
+ @Override
public void addJNDI(PersistedType type, String name, String ... address) throws Exception
{
}
- /* (non-Javadoc)
- * @see org.hornetq.jms.persistence.JMSStorageManager#deleteJNDI(org.hornetq.jms.persistence.PersistedType, java.lang.String, java.lang.String)
- */
+ @Override
public void deleteJNDI(PersistedType type, String name, String address) throws Exception
{
}
- /* (non-Javadoc)
- * @see org.hornetq.jms.persistence.JMSStorageManager#deleteDestination(org.hornetq.jms.persistence.PersistedType, java.lang.String)
- */
+ @Override
public void deleteDestination(PersistedType type, String name) throws Exception
{
}
- /* (non-Javadoc)
- * @see org.hornetq.jms.persistence.JMSStorageManager#deleteJNDI(org.hornetq.jms.persistence.PersistedType, java.lang.String)
- */
+ @Override
public void deleteJNDI(PersistedType type, String name) throws Exception
{
}
- /* (non-Javadoc)
- * @see org.hornetq.jms.persistence.JMSStorageManager#recoverPersistedJNDI()
- */
+ @Override
public List<PersistedJNDI> recoverPersistedJNDI() throws Exception
{
return Collections.emptyList();
}
- /* (non-Javadoc)
- * @see org.hornetq.jms.persistence.JMSStorageManager#installReplication(org.hornetq.core.replication.ReplicationEndpoint)
- */
- public void installReplication(ReplicationEndpoint replicationEndpoint) throws Exception
- {
- }
-
- /* (non-Javadoc)
- * @see org.hornetq.jms.persistence.JMSStorageManager#load()
- */
+ @Override
public void load() throws Exception
{
}
-
- // Constants -----------------------------------------------------
-
- // Attributes ----------------------------------------------------
-
- // Static --------------------------------------------------------
-
- // Constructors --------------------------------------------------
-
- // Public --------------------------------------------------------
-
- // Package protected ---------------------------------------------
-
- // Protected -----------------------------------------------------
-
- // Private -------------------------------------------------------
-
- // Inner classes -------------------------------------------------
-
}
View
12 .../src/main/java/org/hornetq/jms/server/config/impl/ConnectionFactoryConfigurationImpl.java
@@ -513,9 +513,7 @@ public void setGroupID(final String groupID)
// Encoding Support Implementation --------------------------------------------------------------
- /* (non-Javadoc)
- * @see org.hornetq.core.journal.EncodingSupport#decode(org.hornetq.api.core.HornetQBuffer)
- */
+ @Override
public void decode(final HornetQBuffer buffer)
{
persisted = true;
@@ -603,9 +601,7 @@ public void decode(final HornetQBuffer buffer)
factoryType = JMSFactoryType.valueOf(buffer.readInt());
}
- /* (non-Javadoc)
- * @see org.hornetq.core.journal.EncodingSupport#encode(org.hornetq.api.core.HornetQBuffer)
- */
+ @Override
public void encode(final HornetQBuffer buffer)
{
persisted = true;
@@ -693,9 +689,7 @@ public void encode(final HornetQBuffer buffer)
buffer.writeInt(factoryType.intValue());
}
- /* (non-Javadoc)
- * @see org.hornetq.core.journal.EncodingSupport#getEncodeSize()
- */
+ @Override
public int getEncodeSize()
{
int size = BufferHelper.sizeOfSimpleString(name) +
View
24 hornetq-jms-server/src/main/java/org/hornetq/jms/server/impl/JMSServerManagerImpl.java
@@ -752,10 +752,7 @@ public boolean addConnectionFactoryToJNDI(final String name, final String jndiBi
return added;
}
- /* (non-Javadoc)
- * @see org.hornetq.jms.server.JMSServerManager#removeQueueFromJNDI(java.lang.String, java.lang.String)
- */
-
+ @Override
public boolean removeQueueFromJNDI(String name, String jndi) throws Exception
{
checkInitialised();
@@ -770,9 +767,7 @@ public boolean removeQueueFromJNDI(String name, String jndi) throws Exception
return removed;
}
- /* (non-Javadoc)
- * @see org.hornetq.jms.server.JMSServerManager#removeQueueFromJNDI(java.lang.String, java.lang.String)
- */
+ @Override
public boolean removeQueueFromJNDI(final String name) throws Exception
{
final AtomicBoolean valueReturn = new AtomicBoolean(false);
@@ -802,10 +797,7 @@ public void runException() throws Exception
return valueReturn.get();
}
- /* (non-Javadoc)
- * @see org.hornetq.jms.server.JMSServerManager#removeTopicFromJNDI(java.lang.String, java.lang.String)
- */
-
+ @Override
public boolean removeTopicFromJNDI(String name, String jndi) throws Exception
{
checkInitialised();
@@ -853,10 +845,7 @@ public void runException() throws Exception
return valueReturn.get();
}
- /* (non-Javadoc)
- * @see org.hornetq.jms.server.JMSServerManager#removeConnectionFactoryFromJNDI(java.lang.String, java.lang.String)
- */
-
+ @Override
public boolean removeConnectionFactoryFromJNDI(String name, String jndi) throws Exception
{
checkInitialised();
@@ -868,10 +857,7 @@ public boolean removeConnectionFactoryFromJNDI(String name, String jndi) throws
return true;
}
- /* (non-Javadoc)
- * @see org.hornetq.jms.server.JMSServerManager#removeConnectionFactoryFromJNDI(java.lang.String, java.lang.String)
- */
-
+ @Override
public boolean removeConnectionFactoryFromJNDI(String name) throws Exception
{
checkInitialised();
View
8 hornetq-jms-server/src/main/java/org/hornetq/jms/server/recovery/RecoveryDiscovery.java
@@ -173,9 +173,7 @@ public void nodeDown(long eventUID, String nodeID)
}
- /* (non-Javadoc)
- * @see org.hornetq.core.remoting.FailureListener#connectionFailed(org.hornetq.api.core.HornetQException, boolean)
- */
+ @Override
public void connectionFailed(HornetQException exception, boolean failedOver)
{
if (exception.getType() == HornetQExceptionType.DISCONNECTED)
@@ -191,9 +189,7 @@ public void connectionFailed(HornetQException exception, boolean failedOver)
HornetQRecoveryRegistry.getInstance().failedDiscovery(this);
}
- /* (non-Javadoc)
- * @see org.hornetq.api.core.client.SessionFailureListener#beforeReconnect(org.hornetq.api.core.HornetQException)
- */
+ @Override
public void beforeReconnect(HornetQException exception)
{
}
View
8 hornetq-journal/src/main/java/org/hornetq/core/journal/impl/AIOSequentialFile.java
@@ -116,9 +116,7 @@ public synchronized void close() throws Exception
notifyAll();
}
- /* (non-Javadoc)
- * @see org.hornetq.core.journal.SequentialFile#waitForClose()
- */
+ @Override
public synchronized void waitForClose() throws Exception
{
while (isOpen())
@@ -258,9 +256,7 @@ public String toString()
// Public methods
// -----------------------------------------------------------------------------------------------------
- /* (non-Javadoc)
- * @see org.hornetq.core.asyncio.IOExceptionListener#onException(int, java.lang.String)
- */
+ @Override
public void onIOException(Exception code, String message)
{
factory.onIOError(code, message, this);
View
8 ...tq-journal/src/main/java/org/hornetq/core/journal/impl/AbstractSequentialFileFactory.java
@@ -131,9 +131,7 @@ public void start()
}
- /* (non-Javadoc)
- * @see org.hornetq.core.journal.SequentialFileFactory#onIOError(java.lang.Exception, java.lang.String, org.hornetq.core.journal.SequentialFile)
- */
+ @Override
public void onIOError(Exception exception, String message, SequentialFile file)
{
if (critialErrorListener != null)
@@ -142,9 +140,7 @@ public void onIOError(Exception exception, String message, SequentialFile file)
}
}
- /* (non-Javadoc)
- * @see org.hornetq.core.journal.SequentialFileFactory#activate(org.hornetq.core.journal.SequentialFile)
- */
+ @Override
public void activateBuffer(final SequentialFile file)
{
if (timedBuffer != null)
View
4 hornetq-journal/src/main/java/org/hornetq/core/journal/impl/DummyCallback.java
@@ -45,9 +45,7 @@ public void waitCompletion() throws Exception
{
}
- /* (non-Javadoc)
- * @see org.hornetq.core.journal.IOCompletion#linedUp()
- */
+ @Override
public void storeLineUp()
{
}
View
8 hornetq-journal/src/main/java/org/hornetq/core/journal/impl/JournalCompactor.java
@@ -625,17 +625,13 @@ void execute() throws Exception
}
}
- /* (non-Javadoc)
- * @see org.hornetq.core.journal.impl.JournalRecordsProvider#getCompactor()
- */
+ @Override
public JournalCompactor getCompactor()
{
return null;
}
- /* (non-Javadoc)
- * @see org.hornetq.core.journal.impl.JournalRecordsProvider#getRecords()
- */
+ @Override
public Map<Long, JournalRecord> getRecords()
{
return newRecords;
View
12 hornetq-journal/src/main/java/org/hornetq/core/journal/impl/JournalFileImpl.java
@@ -199,25 +199,19 @@ private synchronized AtomicInteger getOrCreateNegCount(final JournalFile file)
return count;
}
- /* (non-Javadoc)
- * @see org.hornetq.core.journal.impl.JournalFile#addSize(int)
- */
+ @Override
public void addSize(final int bytes)
{
liveBytes.addAndGet(bytes);
}
- /* (non-Javadoc)
- * @see org.hornetq.core.journal.impl.JournalFile#decSize(int)
- */
+ @Override
public void decSize(final int bytes)
{
liveBytes.addAndGet(-bytes);
}
- /* (non-Javadoc)
- * @see org.hornetq.core.journal.impl.JournalFile#getSize()
- */
+ @Override
public int getLiveSize()
{
return liveBytes.get();
View
4 hornetq-journal/src/main/java/org/hornetq/core/journal/impl/JournalImpl.java
@@ -1153,9 +1153,7 @@ public void appendPrepareRecord(final long txID,
}
}
- /* (non-Javadoc)
- * @see org.hornetq.core.journal.Journal#lineUpContex(org.hornetq.core.journal.IOCompletion)
- */
+ @Override
public void lineUpContex(IOCompletion callback)
{
callback.storeLineUp();
View
4 hornetq-journal/src/main/java/org/hornetq/core/journal/impl/SimpleWaitIOCallback.java
@@ -85,9 +85,7 @@ public boolean waitCompletion(final long timeout) throws Exception
return retValue;
}
- /* (non-Javadoc)
- * @see org.hornetq.core.journal.IOCompletion#linedUp()
- */
+ @Override
public void storeLineUp()
{
}
View
4 hornetq-journal/src/main/java/org/hornetq/core/journal/impl/dataformat/JournalAddRecord.java
@@ -51,9 +51,7 @@ public JournalAddRecord(final boolean add, final long id, final byte recordType,
this.add = add;
}
- /* (non-Javadoc)
- * @see org.hornetq.core.journal.EncodingSupport#encode(org.hornetq.api.core.buffers.HornetQBuffer)
- */
+ @Override
public void encode(final HornetQBuffer buffer)
{
if (add)
View
4 ...journal/src/main/java/org/hornetq/core/journal/impl/dataformat/JournalDeleteRecordTX.java
@@ -47,9 +47,7 @@ public JournalDeleteRecordTX(final long txID, final long id, final EncodingSuppo
this.record = record;
}
- /* (non-Javadoc)
- * @see org.hornetq.core.journal.EncodingSupport#encode(org.hornetq.api.core.buffers.HornetQBuffer)
- */
+ @Override
public void encode(final HornetQBuffer buffer)
{
buffer.writeByte(JournalImpl.DELETE_RECORD_TX);
View
4 ...urnal/src/main/java/org/hornetq/core/journal/impl/dataformat/JournalRollbackRecordTX.java
@@ -32,9 +32,7 @@ public JournalRollbackRecordTX(final long txID)
this.txID = txID;
}
- /* (non-Javadoc)
- * @see org.hornetq.core.journal.EncodingSupport#encode(org.hornetq.api.core.buffers.HornetQBuffer)
- */
+ @Override
public void encode(final HornetQBuffer buffer)
{
buffer.writeByte(JournalImpl.ROLLBACK_RECORD);
View
32 hornetq-server/src/main/java/org/hornetq/core/config/impl/ConfigurationImpl.java
@@ -498,17 +498,13 @@ public void setBindingsDirectory(final String dir)
}
- /* (non-Javadoc)
- * @see org.hornetq.core.config.Configuration#getPageMaxConcurrentIO()
- */
+ @Override
public int getPageMaxConcurrentIO()
{
return maxConcurrentPageIO;
}
- /* (non-Javadoc)
- * @see org.hornetq.core.config.Configuration#setPageMaxConcurrentIO(int)
- */
+ @Override
public void setPageMaxConcurrentIO(int maxIO)
{
this.maxConcurrentPageIO = maxIO;
@@ -1200,33 +1196,25 @@ else if (!pagingDirectory.equals(other.pagingDirectory))
return true;
}
- /* (non-Javadoc)
- * @see org.hornetq.core.config.Configuration#getAddressesSettings()
- */
+ @Override
public Map<String, AddressSettings> getAddressesSettings()
{
return addressesSettings;
}
- /* (non-Javadoc)
- * @see org.hornetq.core.config.Configuration#setAddressesSettings(java.util.Map)
- */
+ @Override
public void setAddressesSettings(final Map<String, AddressSettings> addressesSettings)
{
this.addressesSettings = addressesSettings;
}
- /* (non-Javadoc)
- * @see org.hornetq.core.config.Configuration#getSecurityRoles()
- */
+ @Override
public Map<String, Set<Role>> getSecurityRoles()
{
return securitySettings;
}
- /* (non-Javadoc)
- * @see org.hornetq.core.config.Configuration#setSecuritySettings(java.util.Map)
- */
+ @Override
public void setSecurityRoles(final Map<String, Set<Role>> securitySettings)
{
this.securitySettings = securitySettings;
@@ -1262,17 +1250,13 @@ public void setConnectorServiceConfigurations(final List<ConnectorServiceConfigu
this.connectorServiceConfigurations = configs;
}
- /* (non-Javadoc)
- * @see org.hornetq.core.config.Configuration#getName()
- */
+ @Override
public String getName()
{
return name;
}
- /* (non-Javadoc)
- * @see org.hornetq.core.config.Configuration#setName(java.lang.String)
- */
+ @Override
public void setName(String name)
{
this.name = name;
View
4 hornetq-server/src/main/java/org/hornetq/core/management/impl/QueueControlImpl.java
@@ -884,9 +884,7 @@ public boolean isPaused() throws Exception
}
}
- /* (non-Javadoc)
- * @see org.hornetq.api.core.management.QueueControl#listConsumersAsJSON()
- */
+ @Override
public String listConsumersAsJSON() throws Exception
{
checkStarted();
View
48 hornetq-server/src/main/java/org/hornetq/core/paging/cursor/PagedReferenceImpl.java
@@ -110,9 +110,7 @@ public int getPersistedCount()
}
- /* (non-Javadoc)
- * @see org.hornetq.core.server.MessageReference#getMessageMemoryEstimate()
- */
+ @Override
public int getMessageMemoryEstimate()
{
if (messageEstimate < 0)
@@ -123,17 +121,13 @@ public int getMessageMemoryEstimate()
}
- /* (non-Javadoc)
- * @see org.hornetq.core.server.MessageReference#copy(org.hornetq.core.server.Queue)
- */
+ @Override
public MessageReference copy(final Queue queue)
{
return new PagedReferenceImpl(this.position, this.getPagedMessage(), this.subscription);
}
- /* (non-Javadoc)
- * @see org.hornetq.core.server.MessageReference#getScheduledDeliveryTime()
- */
+ @Override
public long getScheduledDeliveryTime()
{
if (deliveryTime == null)
@@ -151,33 +145,25 @@ public long getScheduledDeliveryTime()
return deliveryTime;
}
- /* (non-Javadoc)
- * @see org.hornetq.core.server.MessageReference#setScheduledDeliveryTime(long)
- */
+ @Override
public void setScheduledDeliveryTime(final long scheduledDeliveryTime)
{
deliveryTime = scheduledDeliveryTime;
}
- /* (non-Javadoc)
- * @see org.hornetq.core.server.MessageReference#getDeliveryCount()
- */
+ @Override
public int getDeliveryCount()
{
return deliveryCount.get();
}
- /* (non-Javadoc)
- * @see org.hornetq.core.server.MessageReference#setDeliveryCount(int)
- */
+ @Override
public void setDeliveryCount(final int deliveryCount)
{
this.deliveryCount.set(deliveryCount);
}
- /* (non-Javadoc)
- * @see org.hornetq.core.server.MessageReference#incrementDeliveryCount()
- */
+ @Override
public void incrementDeliveryCount()
{
deliveryCount.incrementAndGet();
@@ -188,9 +174,7 @@ public void incrementDeliveryCount()
}
- /* (non-Javadoc)
- * @see org.hornetq.core.server.MessageReference#decrementDeliveryCount()
- */
+ @Override
public void decrementDeliveryCount()
{
deliveryCount.decrementAndGet();
@@ -200,33 +184,25 @@ public void decrementDeliveryCount()
}
}
- /* (non-Javadoc)
- * @see org.hornetq.core.server.MessageReference#getQueue()
- */
+ @Override
public Queue getQueue()
{
return subscription.getQueue();
}
- /* (non-Javadoc)
- * @see org.hornetq.core.server.MessageReference#handled()
- */
+ @Override
public void handled()
{
getQueue().referenceHandled();
}
- /* (non-Javadoc)
- * @see org.hornetq.core.server.MessageReference#acknowledge()
- */
+ @Override
public void acknowledge() throws Exception
{
subscription.ack(this);
}
- /* (non-Javadoc)
- * @see org.hornetq.core.server.MessageReference#acknowledge(org.hornetq.core.transaction.Transaction)
- */
+ @Override
public void acknowledge(final Transaction tx) throws Exception
{
subscription.ackTx(tx, this);
View
4 hornetq-server/src/main/java/org/hornetq/core/paging/cursor/impl/PagePositionImpl.java
@@ -84,9 +84,7 @@ public int getMessageNr()
return messageNr;
}
- /* (non-Javadoc)
- * @see java.lang.Comparable#compareTo(java.lang.Object)
- */
+ @Override
public int compareTo(PagePosition o)
{
if (pageNr > o.getPageNr())
View
20 hornetq-server/src/main/java/org/hornetq/core/paging/cursor/impl/PageSubscriptionImpl.java
@@ -482,9 +482,7 @@ public void ackTx(final Transaction tx, final PagedReference reference) throws E
}
}
- /* (non-Javadoc)
- * @see org.hornetq.core.paging.cursor.PageCursor#confirm(org.hornetq.core.paging.cursor.PagePosition)
- */
+ @Override
public void ack(final PagedReference reference) throws Exception
{
// Need to do the ACK and counter atomically (inside a TX) or the counter could get out of sync
@@ -526,9 +524,7 @@ public String toString()
});
}
- /* (non-Javadoc)
- * @see org.hornetq.core.paging.cursor.PageCursor#getFirstPage()
- */
+ @Override
public long getFirstPage()
{
synchronized (consumedPages)
@@ -604,18 +600,14 @@ public void reloadACK(final PagePosition position)
recoveredACK.add(position);
}
- /* (non-Javadoc)
- * @see org.hornetq.core.paging.cursor.PageCursor#recoverPreparedACK(org.hornetq.core.paging.cursor.PagePosition)
- */
+ @Override
public void reloadPreparedACK(final Transaction tx, final PagePosition position)
{
deliveredCount.incrementAndGet();
installTXCallback(tx, position);
}
- /* (non-Javadoc)
- * @see org.hornetq.core.paging.cursor.PageCursor#positionIgnored(org.hornetq.core.paging.cursor.PagePosition)
- */
+ @Override
public void positionIgnored(final PagePosition position)
{
processACK(position);
@@ -702,9 +694,7 @@ public void destroy() throws Exception
}
}
- /* (non-Javadoc)
- * @see org.hornetq.core.paging.cursor.PageCursor#getId()
- */
+ @Override
public long getId()
{
return cursorId;
View
4 hornetq-server/src/main/java/org/hornetq/core/paging/impl/PageTransactionInfoImpl.java
@@ -271,9 +271,7 @@ public String toString()
")";
}
- /* (non-Javadoc)
- * @see org.hornetq.core.paging.PageTransactionInfo#deliverAfterCommit(org.hornetq.core.paging.cursor.PageCursor, org.hornetq.core.paging.cursor.PagePosition)
- */
+ @Override
public synchronized boolean deliverAfterCommit(PageSubscription cursor, PagePosition cursorPos)
{
if (committed && useRedelivery)
View
12 ...etq-server/src/main/java/org/hornetq/core/persistence/config/PersistedAddressSetting.java
@@ -97,9 +97,7 @@ public AddressSettings getSetting()
return setting;
}
- /* (non-Javadoc)
- * @see org.hornetq.core.journal.EncodingSupport#decode(org.hornetq.api.core.HornetQBuffer)
- */
+ @Override
public void decode(HornetQBuffer buffer)
{
addressMatch = buffer.readSimpleString();
@@ -108,19 +106,15 @@ public void decode(HornetQBuffer buffer)
setting.decode(buffer);
}
- /* (non-Javadoc)
- * @see org.hornetq.core.journal.EncodingSupport#encode(org.hornetq.api.core.HornetQBuffer)
- */
+ @Override
public void encode(HornetQBuffer buffer)
{
buffer.writeSimpleString(addressMatch);
setting.encode(buffer);
}
- /* (non-Javadoc)
- * @see org.hornetq.core.journal.EncodingSupport#getEncodeSize()
- */
+ @Override
public int getEncodeSize()
{
return addressMatch.sizeof() + setting.getEncodeSize();
View
12 hornetq-server/src/main/java/org/hornetq/core/persistence/config/PersistedRoles.java
@@ -164,9 +164,7 @@ public String getManageRoles()
return manageRoles.toString();
}
- /* (non-Javadoc)
- * @see org.hornetq.core.journal.EncodingSupport#encode(org.hornetq.api.core.HornetQBuffer)
- */
+ @Override
public void encode(final HornetQBuffer buffer)
{
buffer.writeSimpleString(addressMatch);
@@ -179,9 +177,7 @@ public void encode(final HornetQBuffer buffer)
buffer.writeNullableSimpleString(manageRoles);
}
- /* (non-Javadoc)
- * @see org.hornetq.core.journal.EncodingSupport#getEncodeSize()
- */
+ @Override
public int getEncodeSize()
{
return addressMatch.sizeof() + SimpleString.sizeofNullableString(sendRoles) +
@@ -194,9 +190,7 @@ public int getEncodeSize()
}
- /* (non-Javadoc)
- * @see org.hornetq.core.journal.EncodingSupport#decode(org.hornetq.api.core.HornetQBuffer)
- */
+ @Override
public void decode(final HornetQBuffer buffer)
{
addressMatch = buffer.readSimpleString();
View
8 ...server/src/main/java/org/hornetq/core/persistence/impl/journal/JournalStorageManager.java
@@ -2253,17 +2253,13 @@ public void afterPageRead() throws Exception
}
}
- /* (non-Javadoc)
- * @see org.hornetq.core.persistence.StorageManager#allocateDirectBuffer(long)
- */
+ @Override
public ByteBuffer allocateDirectBuffer(int size)
{
return journalFF.allocateDirectBuffer(size);
}
- /* (non-Javadoc)
- * @see org.hornetq.core.persistence.StorageManager#freeDirectuffer(java.nio.ByteBuffer)
- */
+ @Override
public void freeDirectBuffer(ByteBuffer buffer)
{
journalFF.releaseBuffer(buffer);
View
50 ...src/main/java/org/hornetq/core/persistence/impl/nullpm/NullStorageLargeServerMessage.java
@@ -45,16 +45,12 @@ public NullStorageLargeServerMessage()
super();
}
- /* (non-Javadoc)
- * @see org.hornetq.core.server.LargeServerMessage#release()
- */
+ @Override
public void releaseResources()
{
}
- /* (non-Javadoc)
- * @see org.hornetq.core.server.LargeServerMessage#addBytes(byte[])
- */
+ @Override
public synchronized void addBytes(final byte[] bytes)
{
if (buffer == null)
@@ -66,58 +62,26 @@ public synchronized void addBytes(final byte[] bytes)
buffer.writeBytes(bytes);
}
- /* (non-Javadoc)
- * @see org.hornetq.core.server.LargeServerMessage#deleteFile()
- */
+ @Override
public void deleteFile() throws Exception
{
// nothing to be done here.. we don really have a file on this Storage
}
- /* (non-Javadoc)
- * @see org.hornetq.core.server.LargeServerMessage#complete()
- */
- public void complete() throws Exception
- {
- // nothing to be done here.. we don really have a file on this Storage
-
- }
-
@Override
public boolean isLargeMessage()
{
return true;
}
- /* (non-Javadoc)
- * @see org.hornetq.core.server.LargeServerMessage#isComplete()
- */
- public boolean isComplete()
- {
- // nothing to be done on null persistence
- return true;
- }
-
- /* (non-Javadoc)
- * @see org.hornetq.core.server.LargeServerMessage#setComplete(boolean)
- */
- public void setComplete(final boolean isComplete)
- {
- // nothing to be done on null persistence
- }
-
- /* (non-Javadoc)
- * @see org.hornetq.core.server.LargeServerMessage#isFileExists()
- */
+ @Override
public boolean isFileExists() throws Exception
{
// There are no real files on null persistence
return true;
}