activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From clebertsuco...@apache.org
Subject [36/53] [abbrv] [partial] activemq-artemis git commit: automatic checkstyle change
Date Mon, 10 Aug 2015 15:13:35 GMT
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/bac96047/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/CompressedLargeMessageControllerImpl.java
----------------------------------------------------------------------
diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/CompressedLargeMessageControllerImpl.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/CompressedLargeMessageControllerImpl.java
index c616f6b..1e93ced 100644
--- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/CompressedLargeMessageControllerImpl.java
+++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/CompressedLargeMessageControllerImpl.java
@@ -33,50 +33,43 @@ import org.apache.activemq.artemis.utils.InflaterReader;
 import org.apache.activemq.artemis.utils.InflaterWriter;
 import org.apache.activemq.artemis.utils.UTF8Util;
 
-final class CompressedLargeMessageControllerImpl implements LargeMessageController
-{
+final class CompressedLargeMessageControllerImpl implements LargeMessageController {
+
    private static final String OPERATION_NOT_SUPPORTED = "Operation not supported";
 
    private final LargeMessageController bufferDelegate;
 
-   public CompressedLargeMessageControllerImpl(final LargeMessageController bufferDelegate)
-   {
+   public CompressedLargeMessageControllerImpl(final LargeMessageController bufferDelegate) {
       this.bufferDelegate = bufferDelegate;
    }
 
    /**
     *
     */
-   public void discardUnusedPackets()
-   {
+   public void discardUnusedPackets() {
       bufferDelegate.discardUnusedPackets();
    }
 
    /**
     * Add a buff to the List, or save it to the OutputStream if set
     */
-   public void addPacket(byte[] chunk, int flowControlSize, boolean isContinues)
-   {
+   public void addPacket(byte[] chunk, int flowControlSize, boolean isContinues) {
       bufferDelegate.addPacket(chunk, flowControlSize, isContinues);
    }
 
-   public synchronized void cancel()
-   {
+   public synchronized void cancel() {
       bufferDelegate.cancel();
    }
 
-   public synchronized void close()
-   {
+   public synchronized void close() {
       bufferDelegate.cancel();
    }
 
-   public void setOutputStream(final OutputStream output) throws ActiveMQException
-   {
+   public void setOutputStream(final OutputStream output) throws ActiveMQException {
       bufferDelegate.setOutputStream(new InflaterWriter(output));
    }
 
-   public synchronized void saveBuffer(final OutputStream output) throws ActiveMQException
-   {
+   public synchronized void saveBuffer(final OutputStream output) throws ActiveMQException {
       setOutputStream(output);
       waitCompletion(0);
    }
@@ -84,31 +77,25 @@ final class CompressedLargeMessageControllerImpl implements LargeMessageControll
    /**
     * @param timeWait Milliseconds to Wait. 0 means forever
     */
-   public synchronized boolean waitCompletion(final long timeWait) throws ActiveMQException
-   {
+   public synchronized boolean waitCompletion(final long timeWait) throws ActiveMQException {
       return bufferDelegate.waitCompletion(timeWait);
    }
 
    @Override
-   public int capacity()
-   {
+   public int capacity() {
       return -1;
    }
 
    DataInputStream dataInput = null;
 
-   private DataInputStream getStream()
-   {
-      if (dataInput == null)
-      {
-         try
-         {
+   private DataInputStream getStream() {
+      if (dataInput == null) {
+         try {
             InputStream input = new ActiveMQBufferInputStream(bufferDelegate);
 
             dataInput = new DataInputStream(new InflaterReader(input));
          }
-         catch (Exception e)
-         {
+         catch (Exception e) {
             throw new RuntimeException(e.getMessage(), e);
          }
 
@@ -116,509 +103,408 @@ final class CompressedLargeMessageControllerImpl implements LargeMessageControll
       return dataInput;
    }
 
-   private void positioningNotSupported()
-   {
+   private void positioningNotSupported() {
       throw new IllegalStateException("Position not supported over compressed large messages");
    }
 
-   public byte readByte()
-   {
-      try
-      {
+   public byte readByte() {
+      try {
          return getStream().readByte();
       }
-      catch (Exception e)
-      {
+      catch (Exception e) {
          throw new RuntimeException(e.getMessage(), e);
       }
    }
 
    @Override
-   public byte getByte(final int index)
-   {
+   public byte getByte(final int index) {
       positioningNotSupported();
       return 0;
    }
 
    @Override
-   public void getBytes(final int index, final ActiveMQBuffer dst, final int dstIndex, final int length)
-   {
+   public void getBytes(final int index, final ActiveMQBuffer dst, final int dstIndex, final int length) {
       positioningNotSupported();
    }
 
    @Override
-   public void getBytes(final int index, final byte[] dst, final int dstIndex, final int length)
-   {
+   public void getBytes(final int index, final byte[] dst, final int dstIndex, final int length) {
       positioningNotSupported();
    }
 
    @Override
-   public void getBytes(final int index, final ByteBuffer dst)
-   {
+   public void getBytes(final int index, final ByteBuffer dst) {
       positioningNotSupported();
    }
 
    @Override
-   public int getInt(final int index)
-   {
+   public int getInt(final int index) {
       positioningNotSupported();
       return 0;
    }
 
    @Override
-   public long getLong(final int index)
-   {
+   public long getLong(final int index) {
       positioningNotSupported();
       return 0;
    }
 
    @Override
-   public short getShort(final int index)
-   {
+   public short getShort(final int index) {
       positioningNotSupported();
       return 0;
    }
 
    @Override
-   public void setByte(final int index, final byte value)
-   {
+   public void setByte(final int index, final byte value) {
       throw new IllegalAccessError(OPERATION_NOT_SUPPORTED);
    }
 
    @Override
-   public void setBytes(final int index, final ActiveMQBuffer src, final int srcIndex, final int length)
-   {
+   public void setBytes(final int index, final ActiveMQBuffer src, final int srcIndex, final int length) {
       throw new IllegalAccessError(OPERATION_NOT_SUPPORTED);
    }
 
    @Override
-   public void setBytes(final int index, final byte[] src, final int srcIndex, final int length)
-   {
+   public void setBytes(final int index, final byte[] src, final int srcIndex, final int length) {
       throw new IllegalAccessError(OPERATION_NOT_SUPPORTED);
    }
 
    @Override
-   public void setBytes(final int index, final ByteBuffer src)
-   {
+   public void setBytes(final int index, final ByteBuffer src) {
       throw new IllegalAccessError(OPERATION_NOT_SUPPORTED);
    }
 
    @Override
-   public void setInt(final int index, final int value)
-   {
+   public void setInt(final int index, final int value) {
       throw new IllegalAccessError(OPERATION_NOT_SUPPORTED);
    }
 
    @Override
-   public void setLong(final int index, final long value)
-   {
+   public void setLong(final int index, final long value) {
       throw new IllegalAccessError(OPERATION_NOT_SUPPORTED);
    }
 
    @Override
-   public void setShort(final int index, final short value)
-   {
+   public void setShort(final int index, final short value) {
       throw new IllegalAccessError(OPERATION_NOT_SUPPORTED);
    }
 
    @Override
-   public ByteBuffer toByteBuffer(final int index, final int length)
-   {
+   public ByteBuffer toByteBuffer(final int index, final int length) {
       throw new IllegalAccessError(OPERATION_NOT_SUPPORTED);
    }
 
-   public int readerIndex()
-   {
+   public int readerIndex() {
       return 0;
    }
 
-   public void readerIndex(final int readerIndex)
-   {
+   public void readerIndex(final int readerIndex) {
       // TODO
    }
 
-   public int writerIndex()
-   {
+   public int writerIndex() {
       // TODO
       return 0;
    }
 
-   public long getSize()
-   {
+   public long getSize() {
       return this.bufferDelegate.getSize();
    }
 
-   public void writerIndex(final int writerIndex)
-   {
+   public void writerIndex(final int writerIndex) {
       throw new IllegalAccessError(OPERATION_NOT_SUPPORTED);
    }
 
-   public void setIndex(final int readerIndex, final int writerIndex)
-   {
+   public void setIndex(final int readerIndex, final int writerIndex) {
       positioningNotSupported();
    }
 
-   public void clear()
-   {
+   public void clear() {
    }
 
-   public boolean readable()
-   {
+   public boolean readable() {
       return true;
    }
 
-   public boolean writable()
-   {
+   public boolean writable() {
       return false;
    }
 
-   public int readableBytes()
-   {
+   public int readableBytes() {
       return 1;
    }
 
-   public int writableBytes()
-   {
+   public int writableBytes() {
       return 0;
    }
 
-   public void markReaderIndex()
-   {
+   public void markReaderIndex() {
       throw new IllegalAccessError(OPERATION_NOT_SUPPORTED);
    }
 
-   public void resetReaderIndex()
-   {
+   public void resetReaderIndex() {
       // TODO: reset positioning if possible
    }
 
-   public void markWriterIndex()
-   {
+   public void markWriterIndex() {
       throw new IllegalAccessError(OPERATION_NOT_SUPPORTED);
    }
 
-   public void resetWriterIndex()
-   {
+   public void resetWriterIndex() {
       throw new IllegalAccessError(OPERATION_NOT_SUPPORTED);
    }
 
-   public void discardReadBytes()
-   {
+   public void discardReadBytes() {
       throw new IllegalAccessError(OPERATION_NOT_SUPPORTED);
    }
 
-   public short getUnsignedByte(final int index)
-   {
+   public short getUnsignedByte(final int index) {
       return (short) (getByte(index) & 0xFF);
    }
 
-   public int getUnsignedShort(final int index)
-   {
+   public int getUnsignedShort(final int index) {
       return getShort(index) & 0xFFFF;
    }
 
-   public long getUnsignedInt(final int index)
-   {
+   public long getUnsignedInt(final int index) {
       return getInt(index) & 0xFFFFFFFFL;
    }
 
-   public void getBytes(int index, final byte[] dst)
-   {
+   public void getBytes(int index, final byte[] dst) {
       // TODO: optimize this by using System.arraycopy
-      for (int i = 0; i < dst.length; i++)
-      {
+      for (int i = 0; i < dst.length; i++) {
          dst[i] = getByte(index++);
       }
    }
 
-   public void getBytes(final int index, final ActiveMQBuffer dst)
-   {
+   public void getBytes(final int index, final ActiveMQBuffer dst) {
       getBytes(index, dst, dst.writableBytes());
    }
 
-   public void getBytes(final int index, final ActiveMQBuffer dst, final int length)
-   {
-      if (length > dst.writableBytes())
-      {
+   public void getBytes(final int index, final ActiveMQBuffer dst, final int length) {
+      if (length > dst.writableBytes()) {
          throw new IndexOutOfBoundsException();
       }
       getBytes(index, dst, dst.writerIndex(), length);
       dst.writerIndex(dst.writerIndex() + length);
    }
 
-   public void setBytes(final int index, final byte[] src)
-   {
+   public void setBytes(final int index, final byte[] src) {
       throw new IllegalAccessError(OPERATION_NOT_SUPPORTED);
    }
 
-   public void setBytes(final int index, final ActiveMQBuffer src)
-   {
+   public void setBytes(final int index, final ActiveMQBuffer src) {
       throw new IllegalAccessError(OPERATION_NOT_SUPPORTED);
    }
 
-   public void setBytes(final int index, final ActiveMQBuffer src, final int length)
-   {
+   public void setBytes(final int index, final ActiveMQBuffer src, final int length) {
       throw new IllegalAccessError(OPERATION_NOT_SUPPORTED);
    }
 
-   public short readUnsignedByte()
-   {
-      try
-      {
+   public short readUnsignedByte() {
+      try {
          return (short) getStream().readUnsignedByte();
       }
-      catch (Exception e)
-      {
+      catch (Exception e) {
          throw new IllegalStateException(e.getMessage(), e);
       }
    }
 
-   public short readShort()
-   {
-      try
-      {
+   public short readShort() {
+      try {
          return getStream().readShort();
       }
-      catch (Exception e)
-      {
+      catch (Exception e) {
          throw new IllegalStateException(e.getMessage(), e);
       }
    }
 
-   public int readUnsignedShort()
-   {
-      try
-      {
+   public int readUnsignedShort() {
+      try {
          return getStream().readUnsignedShort();
       }
-      catch (Exception e)
-      {
+      catch (Exception e) {
          throw new IllegalStateException(e.getMessage(), e);
       }
    }
 
-   public int readInt()
-   {
-      try
-      {
+   public int readInt() {
+      try {
          return getStream().readInt();
       }
-      catch (Exception e)
-      {
+      catch (Exception e) {
          throw new IllegalStateException(e.getMessage(), e);
       }
    }
 
-   public long readUnsignedInt()
-   {
+   public long readUnsignedInt() {
       return readInt() & 0xFFFFFFFFL;
    }
 
-   public long readLong()
-   {
-      try
-      {
+   public long readLong() {
+      try {
          return getStream().readLong();
       }
-      catch (Exception e)
-      {
+      catch (Exception e) {
          throw new IllegalStateException(e.getMessage(), e);
       }
    }
 
-   public void readBytes(final byte[] dst, final int dstIndex, final int length)
-   {
-      try
-      {
+   public void readBytes(final byte[] dst, final int dstIndex, final int length) {
+      try {
          int nReadBytes = getStream().read(dst, dstIndex, length);
-         if (nReadBytes < length)
-         {
+         if (nReadBytes < length) {
             ActiveMQClientLogger.LOGGER.compressedLargeMessageError(length, nReadBytes);
          }
       }
-      catch (Exception e)
-      {
+      catch (Exception e) {
          throw new IllegalStateException(e.getMessage(), e);
       }
    }
 
-   public void readBytes(final byte[] dst)
-   {
+   public void readBytes(final byte[] dst) {
       readBytes(dst, 0, dst.length);
    }
 
-   public void readBytes(final ActiveMQBuffer dst)
-   {
+   public void readBytes(final ActiveMQBuffer dst) {
       readBytes(dst, dst.writableBytes());
    }
 
-   public void readBytes(final ActiveMQBuffer dst, final int length)
-   {
-      if (length > dst.writableBytes())
-      {
+   public void readBytes(final ActiveMQBuffer dst, final int length) {
+      if (length > dst.writableBytes()) {
          throw new IndexOutOfBoundsException();
       }
       readBytes(dst, dst.writerIndex(), length);
       dst.writerIndex(dst.writerIndex() + length);
    }
 
-   public void readBytes(final ActiveMQBuffer dst, final int dstIndex, final int length)
-   {
+   public void readBytes(final ActiveMQBuffer dst, final int dstIndex, final int length) {
       byte[] destBytes = new byte[length];
       readBytes(destBytes);
       dst.setBytes(dstIndex, destBytes);
    }
 
-   public void readBytes(final ByteBuffer dst)
-   {
+   public void readBytes(final ByteBuffer dst) {
       byte[] bytesToGet = new byte[dst.remaining()];
       readBytes(bytesToGet);
       dst.put(bytesToGet);
    }
 
-   public void skipBytes(final int length)
-   {
+   public void skipBytes(final int length) {
 
-      try
-      {
-         for (int i = 0; i < length; i++)
-         {
+      try {
+         for (int i = 0; i < length; i++) {
             getStream().read();
          }
       }
-      catch (Exception e)
-      {
+      catch (Exception e) {
          throw new IllegalStateException(e.getMessage(), e);
       }
    }
 
-   public void writeByte(final byte value)
-   {
+   public void writeByte(final byte value) {
       throw new IllegalAccessError(OPERATION_NOT_SUPPORTED);
    }
 
-   public void writeShort(final short value)
-   {
+   public void writeShort(final short value) {
       throw new IllegalAccessError(OPERATION_NOT_SUPPORTED);
    }
 
-   public void writeInt(final int value)
-   {
+   public void writeInt(final int value) {
       throw new IllegalAccessError(OPERATION_NOT_SUPPORTED);
    }
 
-   public void writeLong(final long value)
-   {
+   public void writeLong(final long value) {
       throw new IllegalAccessError(OPERATION_NOT_SUPPORTED);
    }
 
-   public void writeBytes(final byte[] src, final int srcIndex, final int length)
-   {
+   public void writeBytes(final byte[] src, final int srcIndex, final int length) {
       throw new IllegalAccessError(OPERATION_NOT_SUPPORTED);
    }
 
-   public void writeBytes(final byte[] src)
-   {
+   public void writeBytes(final byte[] src) {
       throw new IllegalAccessError(OPERATION_NOT_SUPPORTED);
    }
 
-   public void writeBytes(final ActiveMQBuffer src, final int length)
-   {
+   public void writeBytes(final ActiveMQBuffer src, final int length) {
       throw new IllegalAccessError(OPERATION_NOT_SUPPORTED);
    }
 
-   public void writeBytes(final ByteBuffer src)
-   {
+   public void writeBytes(final ByteBuffer src) {
       throw new IllegalAccessError(OPERATION_NOT_SUPPORTED);
    }
 
-   public ByteBuffer toByteBuffer()
-   {
+   public ByteBuffer toByteBuffer() {
       throw new IllegalAccessError(OPERATION_NOT_SUPPORTED);
    }
 
-   public Object getUnderlyingBuffer()
-   {
+   public Object getUnderlyingBuffer() {
       return this;
    }
 
    @Override
-   public boolean readBoolean()
-   {
+   public boolean readBoolean() {
       return readByte() != 0;
    }
 
    @Override
-   public char readChar()
-   {
+   public char readChar() {
       return (char) readShort();
    }
 
-   public char getChar(final int index)
-   {
+   public char getChar(final int index) {
       return (char) getShort(index);
    }
 
-   public double getDouble(final int index)
-   {
+   public double getDouble(final int index) {
       return Double.longBitsToDouble(getLong(index));
    }
 
-   public float getFloat(final int index)
-   {
+   public float getFloat(final int index) {
       return Float.intBitsToFloat(getInt(index));
    }
 
-   public ActiveMQBuffer readBytes(final int length)
-   {
+   public ActiveMQBuffer readBytes(final int length) {
       byte[] bytesToGet = new byte[length];
       readBytes(bytesToGet);
       return ActiveMQBuffers.wrappedBuffer(bytesToGet);
    }
 
    @Override
-   public double readDouble()
-   {
+   public double readDouble() {
       return Double.longBitsToDouble(readLong());
    }
 
    @Override
-   public float readFloat()
-   {
+   public float readFloat() {
       return Float.intBitsToFloat(readInt());
    }
 
    @Override
-   public SimpleString readNullableSimpleString()
-   {
+   public SimpleString readNullableSimpleString() {
       int b = readByte();
-      if (b == DataConstants.NULL)
-      {
+      if (b == DataConstants.NULL) {
          return null;
       }
-      else
-      {
+      else {
          return readSimpleString();
       }
    }
 
    @Override
-   public String readNullableString()
-   {
+   public String readNullableString() {
       int b = readByte();
-      if (b == DataConstants.NULL)
-      {
+      if (b == DataConstants.NULL) {
          return null;
       }
-      else
-      {
+      else {
          return readString();
       }
    }
 
    @Override
-   public SimpleString readSimpleString()
-   {
+   public SimpleString readSimpleString() {
       int len = readInt();
       byte[] data = new byte[len];
       readBytes(data);
@@ -626,145 +512,119 @@ final class CompressedLargeMessageControllerImpl implements LargeMessageControll
    }
 
    @Override
-   public String readString()
-   {
+   public String readString() {
       int len = readInt();
 
-      if (len < 9)
-      {
+      if (len < 9) {
          char[] chars = new char[len];
-         for (int i = 0; i < len; i++)
-         {
+         for (int i = 0; i < len; i++) {
             chars[i] = (char) readShort();
          }
          return new String(chars);
       }
-      else if (len < 0xfff)
-      {
+      else if (len < 0xfff) {
          return readUTF();
       }
-      else
-      {
+      else {
          return readSimpleString().toString();
       }
    }
 
    @Override
-   public String readUTF()
-   {
+   public String readUTF() {
       return UTF8Util.readUTF(this);
    }
 
    @Override
-   public void writeBoolean(final boolean val)
-   {
+   public void writeBoolean(final boolean val) {
       throw new IllegalAccessError(OPERATION_NOT_SUPPORTED);
    }
 
    @Override
-   public void writeChar(final char val)
-   {
+   public void writeChar(final char val) {
       throw new IllegalAccessError(OPERATION_NOT_SUPPORTED);
    }
 
    @Override
-   public void writeDouble(final double val)
-   {
+   public void writeDouble(final double val) {
       throw new IllegalAccessError(OPERATION_NOT_SUPPORTED);
 
    }
 
    @Override
-   public void writeFloat(final float val)
-   {
+   public void writeFloat(final float val) {
       throw new IllegalAccessError(OPERATION_NOT_SUPPORTED);
 
    }
 
    @Override
-   public void writeNullableSimpleString(final SimpleString val)
-   {
+   public void writeNullableSimpleString(final SimpleString val) {
       throw new IllegalAccessError(OPERATION_NOT_SUPPORTED);
    }
 
    @Override
-   public void writeNullableString(final String val)
-   {
+   public void writeNullableString(final String val) {
       throw new IllegalAccessError(OPERATION_NOT_SUPPORTED);
    }
 
    @Override
-   public void writeSimpleString(final SimpleString val)
-   {
+   public void writeSimpleString(final SimpleString val) {
       throw new IllegalAccessError(OPERATION_NOT_SUPPORTED);
    }
 
    @Override
-   public void writeString(final String val)
-   {
+   public void writeString(final String val) {
       throw new IllegalAccessError(OPERATION_NOT_SUPPORTED);
    }
 
    @Override
-   public void writeUTF(final String utf)
-   {
+   public void writeUTF(final String utf) {
       throw new IllegalAccessError(OPERATION_NOT_SUPPORTED);
    }
 
-   public ActiveMQBuffer copy()
-   {
+   public ActiveMQBuffer copy() {
       throw new UnsupportedOperationException();
    }
 
-   public ActiveMQBuffer slice(final int index, final int length)
-   {
+   public ActiveMQBuffer slice(final int index, final int length) {
       throw new UnsupportedOperationException();
    }
 
    // Inner classes -------------------------------------------------
 
-   public ByteBuf byteBuf()
-   {
+   public ByteBuf byteBuf() {
       return null;
    }
 
-   public ActiveMQBuffer copy(final int index, final int length)
-   {
+   public ActiveMQBuffer copy(final int index, final int length) {
       throw new IllegalAccessError(OPERATION_NOT_SUPPORTED);
    }
 
-   public ActiveMQBuffer duplicate()
-   {
+   public ActiveMQBuffer duplicate() {
       throw new IllegalAccessError(OPERATION_NOT_SUPPORTED);
    }
 
-   public ActiveMQBuffer readSlice(final int length)
-   {
+   public ActiveMQBuffer readSlice(final int length) {
       throw new IllegalAccessError(OPERATION_NOT_SUPPORTED);
    }
 
-   public void setChar(final int index, final char value)
-   {
+   public void setChar(final int index, final char value) {
       throw new IllegalAccessError(OPERATION_NOT_SUPPORTED);
    }
 
-   public void setDouble(final int index, final double value)
-   {
+   public void setDouble(final int index, final double value) {
       throw new IllegalAccessError(OPERATION_NOT_SUPPORTED);
    }
 
-   public void setFloat(final int index, final float value)
-   {
+   public void setFloat(final int index, final float value) {
       throw new IllegalAccessError(OPERATION_NOT_SUPPORTED);
    }
 
-   public ActiveMQBuffer slice()
-   {
+   public ActiveMQBuffer slice() {
       throw new IllegalAccessError(OPERATION_NOT_SUPPORTED);
    }
 
-   public void writeBytes(final ActiveMQBuffer src, final int srcIndex, final int length)
-   {
+   public void writeBytes(final ActiveMQBuffer src, final int srcIndex, final int length) {
       throw new IllegalAccessError(OPERATION_NOT_SUPPORTED);
    }
 }

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/bac96047/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/DelegatingSession.java
----------------------------------------------------------------------
diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/DelegatingSession.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/DelegatingSession.java
index 3c81c8e..a4296bc 100644
--- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/DelegatingSession.java
+++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/DelegatingSession.java
@@ -42,8 +42,8 @@ import org.apache.activemq.artemis.utils.ConcurrentHashSet;
  * We wrap the real session, so we can add a finalizer on this and close the session
  * on GC if it has not already been closed
  */
-public class DelegatingSession implements ClientSessionInternal
-{
+public class DelegatingSession implements ClientSessionInternal {
+
    private final ClientSessionInternal session;
 
    private final Exception creationStack;
@@ -54,29 +54,23 @@ public class DelegatingSession implements ClientSessionInternal
 
    public static volatile boolean debug;
 
-   public static void dumpSessionCreationStacks()
-   {
+   public static void dumpSessionCreationStacks() {
       ActiveMQClientLogger.LOGGER.dumpingSessionStacks();
 
-      for (DelegatingSession session : DelegatingSession.sessions)
-      {
+      for (DelegatingSession session : DelegatingSession.sessions) {
          ActiveMQClientLogger.LOGGER.dumpingSessionStack(session.creationStack);
       }
    }
 
-
-   public ClientSessionInternal getInternalSession()
-   {
+   public ClientSessionInternal getInternalSession() {
       return session;
    }
 
    @Override
-   protected void finalize() throws Throwable
-   {
+   protected void finalize() throws Throwable {
       // In some scenarios we have seen the JDK finalizing the DelegatingSession while the call to session.close() was still in progress
       //
-      if (!closed && !session.isClosed())
-      {
+      if (!closed && !session.isClosed()) {
          ActiveMQClientLogger.LOGGER.clientSessionNotClosed(creationStack, System.identityHashCode(this));
 
          close();
@@ -85,87 +79,71 @@ public class DelegatingSession implements ClientSessionInternal
       super.finalize();
    }
 
-   public DelegatingSession(final ClientSessionInternal session)
-   {
+   public DelegatingSession(final ClientSessionInternal session) {
       this.session = session;
 
       creationStack = new Exception();
 
-      if (DelegatingSession.debug)
-      {
+      if (DelegatingSession.debug) {
          DelegatingSession.sessions.add(this);
       }
    }
 
-   public boolean isClosing()
-   {
+   public boolean isClosing() {
       return session.isClosing();
    }
 
-   public void acknowledge(final ClientConsumer consumer, final Message message) throws ActiveMQException
-   {
+   public void acknowledge(final ClientConsumer consumer, final Message message) throws ActiveMQException {
       session.acknowledge(consumer, message);
    }
 
-   public void individualAcknowledge(final ClientConsumer consumer, final Message message) throws ActiveMQException
-   {
+   public void individualAcknowledge(final ClientConsumer consumer, final Message message) throws ActiveMQException {
       session.individualAcknowledge(consumer, message);
    }
 
-   public void addConsumer(final ClientConsumerInternal consumer)
-   {
+   public void addConsumer(final ClientConsumerInternal consumer) {
       session.addConsumer(consumer);
    }
 
-   public void addFailureListener(final SessionFailureListener listener)
-   {
+   public void addFailureListener(final SessionFailureListener listener) {
       session.addFailureListener(listener);
    }
 
-   public void addFailoverListener(FailoverEventListener listener)
-   {
+   public void addFailoverListener(FailoverEventListener listener) {
       session.addFailoverListener(listener);
    }
 
-   public void addProducer(final ClientProducerInternal producer)
-   {
+   public void addProducer(final ClientProducerInternal producer) {
       session.addProducer(producer);
    }
 
-   public AddressQuery addressQuery(final SimpleString address) throws ActiveMQException
-   {
+   public AddressQuery addressQuery(final SimpleString address) throws ActiveMQException {
       return session.addressQuery(address);
    }
 
-   public void cleanUp(boolean failingOver) throws ActiveMQException
-   {
+   public void cleanUp(boolean failingOver) throws ActiveMQException {
       session.cleanUp(failingOver);
    }
 
-   public void close() throws ActiveMQException
-   {
+   public void close() throws ActiveMQException {
       closed = true;
 
-      if (DelegatingSession.debug)
-      {
+      if (DelegatingSession.debug) {
          DelegatingSession.sessions.remove(this);
       }
 
       session.close();
    }
 
-   public void commit() throws ActiveMQException
-   {
+   public void commit() throws ActiveMQException {
       session.commit();
    }
 
-   public void commit(final Xid xid, final boolean onePhase) throws XAException
-   {
+   public void commit(final Xid xid, final boolean onePhase) throws XAException {
       session.commit(xid, onePhase);
    }
 
-   public ClientMessage createMessage(final boolean durable)
-   {
+   public ClientMessage createMessage(final boolean durable) {
       return session.createMessage(durable);
    }
 
@@ -173,20 +151,17 @@ public class DelegatingSession implements ClientSessionInternal
                                       final boolean durable,
                                       final long expiration,
                                       final long timestamp,
-                                      final byte priority)
-   {
+                                      final byte priority) {
       return session.createMessage(type, durable, expiration, timestamp, priority);
    }
 
-   public ClientMessage createMessage(final byte type, final boolean durable)
-   {
+   public ClientMessage createMessage(final byte type, final boolean durable) {
       return session.createMessage(type, durable);
    }
 
    public ClientConsumer createConsumer(final SimpleString queueName,
                                         final SimpleString filterString,
-                                        final boolean browseOnly) throws ActiveMQException
-   {
+                                        final boolean browseOnly) throws ActiveMQException {
       return session.createConsumer(queueName, filterString, browseOnly);
    }
 
@@ -194,23 +169,22 @@ public class DelegatingSession implements ClientSessionInternal
                                         final SimpleString filterString,
                                         final int windowSize,
                                         final int maxRate,
-                                        final boolean browseOnly) throws ActiveMQException
-   {
+                                        final boolean browseOnly) throws ActiveMQException {
       return session.createConsumer(queueName, filterString, windowSize, maxRate, browseOnly);
    }
 
-   public ClientConsumer createConsumer(final SimpleString queueName, final SimpleString filterString) throws ActiveMQException
-   {
+   public ClientConsumer createConsumer(final SimpleString queueName,
+                                        final SimpleString filterString) throws ActiveMQException {
       return session.createConsumer(queueName, filterString);
    }
 
-   public ClientConsumer createConsumer(final SimpleString queueName) throws ActiveMQException
-   {
+   public ClientConsumer createConsumer(final SimpleString queueName) throws ActiveMQException {
       return session.createConsumer(queueName);
    }
 
-   public ClientConsumer createConsumer(final String queueName, final String filterString, final boolean browseOnly) throws ActiveMQException
-   {
+   public ClientConsumer createConsumer(final String queueName,
+                                        final String filterString,
+                                        final boolean browseOnly) throws ActiveMQException {
       return session.createConsumer(queueName, filterString, browseOnly);
    }
 
@@ -218,439 +192,375 @@ public class DelegatingSession implements ClientSessionInternal
                                         final String filterString,
                                         final int windowSize,
                                         final int maxRate,
-                                        final boolean browseOnly) throws ActiveMQException
-   {
+                                        final boolean browseOnly) throws ActiveMQException {
       return session.createConsumer(queueName, filterString, windowSize, maxRate, browseOnly);
    }
 
-   public ClientConsumer createConsumer(final String queueName, final String filterString) throws ActiveMQException
-   {
+   public ClientConsumer createConsumer(final String queueName, final String filterString) throws ActiveMQException {
       return session.createConsumer(queueName, filterString);
    }
 
-   public ClientConsumer createConsumer(final String queueName) throws ActiveMQException
-   {
+   public ClientConsumer createConsumer(final String queueName) throws ActiveMQException {
       return session.createConsumer(queueName);
    }
 
-   public ClientConsumer createConsumer(final SimpleString queueName, final boolean browseOnly) throws ActiveMQException
-   {
+   public ClientConsumer createConsumer(final SimpleString queueName,
+                                        final boolean browseOnly) throws ActiveMQException {
       return session.createConsumer(queueName, browseOnly);
    }
 
-   public ClientConsumer createConsumer(final String queueName, final boolean browseOnly) throws ActiveMQException
-   {
+   public ClientConsumer createConsumer(final String queueName, final boolean browseOnly) throws ActiveMQException {
       return session.createConsumer(queueName, browseOnly);
    }
 
-   public ClientProducer createProducer() throws ActiveMQException
-   {
+   public ClientProducer createProducer() throws ActiveMQException {
       return session.createProducer();
    }
 
-   public ClientProducer createProducer(final SimpleString address, final int rate) throws ActiveMQException
-   {
+   public ClientProducer createProducer(final SimpleString address, final int rate) throws ActiveMQException {
       return session.createProducer(address, rate);
    }
 
-   public ClientProducer createProducer(final SimpleString address) throws ActiveMQException
-   {
+   public ClientProducer createProducer(final SimpleString address) throws ActiveMQException {
       return session.createProducer(address);
    }
 
-   public ClientProducer createProducer(final String address) throws ActiveMQException
-   {
+   public ClientProducer createProducer(final String address) throws ActiveMQException {
       return session.createProducer(address);
    }
 
-   public void createQueue(final String address, final String queueName) throws ActiveMQException
-   {
+   public void createQueue(final String address, final String queueName) throws ActiveMQException {
       session.createQueue(address, queueName);
    }
 
-   public void createQueue(final SimpleString address, final SimpleString queueName) throws ActiveMQException
-   {
+   public void createQueue(final SimpleString address, final SimpleString queueName) throws ActiveMQException {
       session.createQueue(address, queueName);
    }
 
-   public void createQueue(final SimpleString address, final SimpleString queueName, final boolean durable) throws ActiveMQException
-   {
+   public void createQueue(final SimpleString address,
+                           final SimpleString queueName,
+                           final boolean durable) throws ActiveMQException {
       session.createQueue(address, queueName, durable);
    }
 
    @Override
-   public void createSharedQueue(SimpleString address, SimpleString queueName, boolean durable) throws ActiveMQException
-   {
+   public void createSharedQueue(SimpleString address,
+                                 SimpleString queueName,
+                                 boolean durable) throws ActiveMQException {
       session.createSharedQueue(address, queueName, durable);
    }
 
    @Override
-   public void createSharedQueue(SimpleString address, SimpleString queueName, SimpleString filter, boolean durable) throws ActiveMQException
-   {
+   public void createSharedQueue(SimpleString address,
+                                 SimpleString queueName,
+                                 SimpleString filter,
+                                 boolean durable) throws ActiveMQException {
       session.createSharedQueue(address, queueName, filter, durable);
    }
 
    public void createQueue(final SimpleString address,
                            final SimpleString queueName,
                            final SimpleString filterString,
-                           final boolean durable) throws ActiveMQException
-   {
+                           final boolean durable) throws ActiveMQException {
       session.createQueue(address, queueName, filterString, durable);
    }
 
-   public void createQueue(final String address, final String queueName, final boolean durable) throws ActiveMQException
-   {
+   public void createQueue(final String address,
+                           final String queueName,
+                           final boolean durable) throws ActiveMQException {
       session.createQueue(address, queueName, durable);
    }
 
    public void createQueue(final String address,
                            final String queueName,
                            final String filterString,
-                           final boolean durable) throws ActiveMQException
-   {
+                           final boolean durable) throws ActiveMQException {
       session.createQueue(address, queueName, filterString, durable);
    }
 
-   public void createTemporaryQueue(final SimpleString address, final SimpleString queueName, final SimpleString filter) throws ActiveMQException
-   {
+   public void createTemporaryQueue(final SimpleString address,
+                                    final SimpleString queueName,
+                                    final SimpleString filter) throws ActiveMQException {
       session.createTemporaryQueue(address, queueName, filter);
    }
 
-   public void createTemporaryQueue(final SimpleString address, final SimpleString queueName) throws ActiveMQException
-   {
+   public void createTemporaryQueue(final SimpleString address, final SimpleString queueName) throws ActiveMQException {
       session.createTemporaryQueue(address, queueName);
    }
 
-   public void createTemporaryQueue(final String address, final String queueName, final String filter) throws ActiveMQException
-   {
+   public void createTemporaryQueue(final String address,
+                                    final String queueName,
+                                    final String filter) throws ActiveMQException {
       session.createTemporaryQueue(address, queueName, filter);
    }
 
-   public void createTemporaryQueue(final String address, final String queueName) throws ActiveMQException
-   {
+   public void createTemporaryQueue(final String address, final String queueName) throws ActiveMQException {
       session.createTemporaryQueue(address, queueName);
    }
 
-   public void deleteQueue(final SimpleString queueName) throws ActiveMQException
-   {
+   public void deleteQueue(final SimpleString queueName) throws ActiveMQException {
       session.deleteQueue(queueName);
    }
 
-   public void deleteQueue(final String queueName) throws ActiveMQException
-   {
+   public void deleteQueue(final String queueName) throws ActiveMQException {
       session.deleteQueue(queueName);
    }
 
-   public void end(final Xid xid, final int flags) throws XAException
-   {
+   public void end(final Xid xid, final int flags) throws XAException {
       session.end(xid, flags);
    }
 
-   public void expire(final ClientConsumer consumer, final Message message) throws ActiveMQException
-   {
+   public void expire(final ClientConsumer consumer, final Message message) throws ActiveMQException {
       session.expire(consumer, message);
    }
 
-   public void forget(final Xid xid) throws XAException
-   {
+   public void forget(final Xid xid) throws XAException {
       session.forget(xid);
    }
 
-   public RemotingConnection getConnection()
-   {
+   public RemotingConnection getConnection() {
       return session.getConnection();
    }
 
-   public int getMinLargeMessageSize()
-   {
+   public int getMinLargeMessageSize() {
       return session.getMinLargeMessageSize();
    }
 
-   public String getName()
-   {
+   public String getName() {
       return session.getName();
    }
 
-   public int getTransactionTimeout() throws XAException
-   {
+   public int getTransactionTimeout() throws XAException {
       return session.getTransactionTimeout();
    }
 
-   public int getVersion()
-   {
+   public int getVersion() {
       return session.getVersion();
    }
 
-   public XAResource getXAResource()
-   {
+   public XAResource getXAResource() {
       return session.getXAResource();
    }
 
-   public void preHandleFailover(RemotingConnection connection)
-   {
+   public void preHandleFailover(RemotingConnection connection) {
       session.preHandleFailover(connection);
    }
 
-   public void handleFailover(final RemotingConnection backupConnection, ActiveMQException cause)
-   {
+   public void handleFailover(final RemotingConnection backupConnection, ActiveMQException cause) {
       session.handleFailover(backupConnection, cause);
    }
 
    @Override
-   public void handleReceiveMessage(ConsumerContext consumerID, ClientMessageInternal message) throws Exception
-   {
+   public void handleReceiveMessage(ConsumerContext consumerID, ClientMessageInternal message) throws Exception {
       session.handleReceiveMessage(consumerID, message);
    }
 
    @Override
-   public void handleReceiveLargeMessage(ConsumerContext consumerID, ClientLargeMessageInternal clientLargeMessage, long largeMessageSize) throws Exception
-   {
+   public void handleReceiveLargeMessage(ConsumerContext consumerID,
+                                         ClientLargeMessageInternal clientLargeMessage,
+                                         long largeMessageSize) throws Exception {
       session.handleReceiveLargeMessage(consumerID, clientLargeMessage, largeMessageSize);
    }
 
    @Override
-   public void handleReceiveContinuation(ConsumerContext consumerID, byte[] chunk, int flowControlSize, boolean isContinues) throws Exception
-   {
+   public void handleReceiveContinuation(ConsumerContext consumerID,
+                                         byte[] chunk,
+                                         int flowControlSize,
+                                         boolean isContinues) throws Exception {
       session.handleReceiveContinuation(consumerID, chunk, flowControlSize, isContinues);
    }
 
    @Override
-   public void handleConsumerDisconnect(ConsumerContext consumerContext) throws ActiveMQException
-   {
+   public void handleConsumerDisconnect(ConsumerContext consumerContext) throws ActiveMQException {
       session.handleConsumerDisconnect(consumerContext);
    }
 
-   public boolean isAutoCommitAcks()
-   {
+   public boolean isAutoCommitAcks() {
       return session.isAutoCommitAcks();
    }
 
-   public boolean isAutoCommitSends()
-   {
+   public boolean isAutoCommitSends() {
       return session.isAutoCommitSends();
    }
 
-   public boolean isBlockOnAcknowledge()
-   {
+   public boolean isBlockOnAcknowledge() {
       return session.isBlockOnAcknowledge();
    }
 
-   public boolean isCacheLargeMessageClient()
-   {
+   public boolean isCacheLargeMessageClient() {
       return session.isCacheLargeMessageClient();
    }
 
-   public boolean isClosed()
-   {
+   public boolean isClosed() {
       return session.isClosed();
    }
 
-   public boolean isSameRM(final XAResource xares) throws XAException
-   {
+   public boolean isSameRM(final XAResource xares) throws XAException {
       return session.isSameRM(xares);
    }
 
-   public boolean isXA()
-   {
+   public boolean isXA() {
       return session.isXA();
    }
 
-   public int prepare(final Xid xid) throws XAException
-   {
+   public int prepare(final Xid xid) throws XAException {
       return session.prepare(xid);
    }
 
-   public QueueQuery queueQuery(final SimpleString queueName) throws ActiveMQException
-   {
+   public QueueQuery queueQuery(final SimpleString queueName) throws ActiveMQException {
       return session.queueQuery(queueName);
    }
 
-   public Xid[] recover(final int flag) throws XAException
-   {
+   public Xid[] recover(final int flag) throws XAException {
       return session.recover(flag);
    }
 
-   public void removeConsumer(final ClientConsumerInternal consumer) throws ActiveMQException
-   {
+   public void removeConsumer(final ClientConsumerInternal consumer) throws ActiveMQException {
       session.removeConsumer(consumer);
    }
 
-   public boolean removeFailureListener(final SessionFailureListener listener)
-   {
+   public boolean removeFailureListener(final SessionFailureListener listener) {
       return session.removeFailureListener(listener);
    }
 
-   public boolean removeFailoverListener(FailoverEventListener listener)
-   {
+   public boolean removeFailoverListener(FailoverEventListener listener) {
       return session.removeFailoverListener(listener);
    }
 
-   public void removeProducer(final ClientProducerInternal producer)
-   {
+   public void removeProducer(final ClientProducerInternal producer) {
       session.removeProducer(producer);
    }
 
-   public void rollback() throws ActiveMQException
-   {
+   public void rollback() throws ActiveMQException {
       session.rollback();
    }
 
-   public boolean isRollbackOnly()
-   {
+   public boolean isRollbackOnly() {
       return session.isRollbackOnly();
    }
 
-   public void rollback(final boolean considerLastMessageAsDelivered) throws ActiveMQException
-   {
+   public void rollback(final boolean considerLastMessageAsDelivered) throws ActiveMQException {
       session.rollback(considerLastMessageAsDelivered);
    }
 
-   public void rollback(final Xid xid) throws XAException
-   {
+   public void rollback(final Xid xid) throws XAException {
       session.rollback(xid);
    }
 
-   public DelegatingSession setSendAcknowledgementHandler(final SendAcknowledgementHandler handler)
-   {
+   public DelegatingSession setSendAcknowledgementHandler(final SendAcknowledgementHandler handler) {
       session.setSendAcknowledgementHandler(handler);
       return this;
    }
 
-   public boolean setTransactionTimeout(final int seconds) throws XAException
-   {
+   public boolean setTransactionTimeout(final int seconds) throws XAException {
       return session.setTransactionTimeout(seconds);
    }
 
-   public void resetIfNeeded() throws ActiveMQException
-   {
+   public void resetIfNeeded() throws ActiveMQException {
       session.resetIfNeeded();
    }
 
-   public DelegatingSession start() throws ActiveMQException
-   {
+   public DelegatingSession start() throws ActiveMQException {
       session.start();
       return this;
    }
 
-   public void start(final Xid xid, final int flags) throws XAException
-   {
+   public void start(final Xid xid, final int flags) throws XAException {
       session.start(xid, flags);
    }
 
-   public void stop() throws ActiveMQException
-   {
+   public void stop() throws ActiveMQException {
       session.stop();
    }
 
-   public ClientSessionFactory getSessionFactory()
-   {
+   public ClientSessionFactory getSessionFactory() {
       return session.getSessionFactory();
    }
 
-   public void setForceNotSameRM(final boolean force)
-   {
+   public void setForceNotSameRM(final boolean force) {
       session.setForceNotSameRM(force);
    }
 
-   public void workDone()
-   {
+   public void workDone() {
       session.workDone();
    }
 
-   public void sendProducerCreditsMessage(final int credits, final SimpleString address)
-   {
+   public void sendProducerCreditsMessage(final int credits, final SimpleString address) {
       session.sendProducerCreditsMessage(credits, address);
    }
 
-   public ClientProducerCredits getCredits(final SimpleString address, final boolean anon)
-   {
+   public ClientProducerCredits getCredits(final SimpleString address, final boolean anon) {
       return session.getCredits(address, anon);
    }
 
-   public void returnCredits(final SimpleString address)
-   {
+   public void returnCredits(final SimpleString address) {
       session.returnCredits(address);
    }
 
-   public void handleReceiveProducerCredits(final SimpleString address, final int credits)
-   {
+   public void handleReceiveProducerCredits(final SimpleString address, final int credits) {
       session.handleReceiveProducerCredits(address, credits);
    }
 
-   public void handleReceiveProducerFailCredits(final SimpleString address, final int credits)
-   {
+   public void handleReceiveProducerFailCredits(final SimpleString address, final int credits) {
       session.handleReceiveProducerFailCredits(address, credits);
    }
 
-   public ClientProducerCreditManager getProducerCreditManager()
-   {
+   public ClientProducerCreditManager getProducerCreditManager() {
       return session.getProducerCreditManager();
    }
 
-   public void setAddress(Message message, SimpleString address)
-   {
+   public void setAddress(Message message, SimpleString address) {
       session.setAddress(message, address);
    }
 
-   public void setPacketSize(int packetSize)
-   {
+   public void setPacketSize(int packetSize) {
       session.setPacketSize(packetSize);
    }
 
-   public void addMetaData(String key, String data) throws ActiveMQException
-   {
+   public void addMetaData(String key, String data) throws ActiveMQException {
       session.addMetaData(key, data);
    }
 
-   public boolean isCompressLargeMessages()
-   {
+   public boolean isCompressLargeMessages() {
       return session.isCompressLargeMessages();
    }
 
    @Override
-   public String toString()
-   {
+   public String toString() {
       return "DelegatingSession [session=" + session + "]";
    }
 
    @Override
-   public void addUniqueMetaData(String key, String data) throws ActiveMQException
-   {
+   public void addUniqueMetaData(String key, String data) throws ActiveMQException {
       session.addUniqueMetaData(key, data);
 
    }
 
-   public void startCall()
-   {
+   public void startCall() {
       session.startCall();
    }
 
-   public void endCall()
-   {
+   public void endCall() {
       session.endCall();
    }
 
    @Override
-   public void setStopSignal()
-   {
+   public void setStopSignal() {
       session.setStopSignal();
    }
 
    @Override
-   public boolean isConfirmationWindowEnabled()
-   {
+   public boolean isConfirmationWindowEnabled() {
       return session.isConfirmationWindowEnabled();
    }
 
    @Override
-   public void scheduleConfirmation(SendAcknowledgementHandler handler, Message msg)
-   {
+   public void scheduleConfirmation(SendAcknowledgementHandler handler, Message msg) {
       session.scheduleConfirmation(handler, msg);
    }
 
    @Override
-   public String getNodeId()
-   {
+   public String getNodeId() {
       return session.getNodeId();
    }
 }

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/bac96047/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/LargeMessageController.java
----------------------------------------------------------------------
diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/LargeMessageController.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/LargeMessageController.java
index 141c0c5..ced3028 100644
--- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/LargeMessageController.java
+++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/LargeMessageController.java
@@ -21,11 +21,10 @@ import java.io.OutputStream;
 import org.apache.activemq.artemis.api.core.ActiveMQBuffer;
 import org.apache.activemq.artemis.api.core.ActiveMQException;
 
-public interface LargeMessageController extends ActiveMQBuffer
-{
+public interface LargeMessageController extends ActiveMQBuffer {
+
    /**
     * Returns the size of this buffer.
-
     */
    long getSize();
 


Mime
View raw message