[jboss-cvs] JBoss Messaging SVN: r4720 - in branches/Branch_Message_Chunking/src/main/org/jboss/messaging/core/remoting: impl and 1 other directory.
jboss-cvs-commits at lists.jboss.org
jboss-cvs-commits at lists.jboss.org
Thu Jul 24 08:28:28 EDT 2008
Author: ataylor
Date: 2008-07-24 08:28:28 -0400 (Thu, 24 Jul 2008)
New Revision: 4720
Modified:
branches/Branch_Message_Chunking/src/main/org/jboss/messaging/core/remoting/PacketFragment.java
branches/Branch_Message_Chunking/src/main/org/jboss/messaging/core/remoting/impl/PacketAssemblerImpl.java
branches/Branch_Message_Chunking/src/main/org/jboss/messaging/core/remoting/impl/PacketFragmentBufferImpl.java
branches/Branch_Message_Chunking/src/main/org/jboss/messaging/core/remoting/impl/PacketFragmentImpl.java
Log:
cleaned up
Modified: branches/Branch_Message_Chunking/src/main/org/jboss/messaging/core/remoting/PacketFragment.java
===================================================================
--- branches/Branch_Message_Chunking/src/main/org/jboss/messaging/core/remoting/PacketFragment.java 2008-07-24 08:46:41 UTC (rev 4719)
+++ branches/Branch_Message_Chunking/src/main/org/jboss/messaging/core/remoting/PacketFragment.java 2008-07-24 12:28:28 UTC (rev 4720)
@@ -11,8 +11,6 @@
int getCorrelationId();
- MessagingBuffer getMessagingBuffer();
-
int getLength();
boolean isLastPacket();
@@ -31,7 +29,71 @@
void setLastPacket(boolean lastPacket);
- int getHeaderSize();
+ boolean checkSpace(int size);
- void setLength(int i);
+ boolean hasReadSpace(int size);
+
+ void putFloat(float val);
+
+ void putInt(int i);
+
+ void putByte(byte b);
+
+ void putLong(long l);
+
+ void putBoolean(boolean b);
+
+ void putBytes(byte[] bytes, int i, int i1);
+
+ void putDouble(double val);
+
+ void putShort(short val);
+
+ void putChar(char val);
+
+ int getInt();
+
+ long getLong();
+
+ short getShort();
+
+ boolean getBoolean();
+
+ byte getByte();
+
+ void getBytes(byte[] data);
+
+ void getBytes(byte[] data, int read, int left);
+
+ float getFloat();
+
+ double getDouble();
+
+ char getChar();
+
+ short getUnsignedByte();
+
+ int getBodyLength();
+
+ void setBodyLength(int bodyLength);
+
+ void writeHeaders();
+
+ int remaining();
+
+ int limit();
+
+ PacketFragment createNextPacketFragment(int packetFragmentSize);
+
+ void putBoolean(int actualPos, boolean val);
+
+ void putInt(int actualPos, int val);
+
+ void rewind();
+
+ void flip();
+
+ void position(int position);
+
+ MessagingBuffer getMessagingBuffer();
}
Modified: branches/Branch_Message_Chunking/src/main/org/jboss/messaging/core/remoting/impl/PacketAssemblerImpl.java
===================================================================
--- branches/Branch_Message_Chunking/src/main/org/jboss/messaging/core/remoting/impl/PacketAssemblerImpl.java 2008-07-24 08:46:41 UTC (rev 4719)
+++ branches/Branch_Message_Chunking/src/main/org/jboss/messaging/core/remoting/impl/PacketAssemblerImpl.java 2008-07-24 12:28:28 UTC (rev 4720)
@@ -117,6 +117,7 @@
PacketFragmentBuffer buff = new PacketFragmentBufferImpl(packetId.getAndIncrement(), buffer, packetFragmentSize);
messagingCodec.encode(buff, message);
buff.prepare();
+ buff.flip();
for (PacketFragment packetFragment : buff.getPacketFragments())
{
outputHandler.handle(packetFragment.getMessagingBuffer());
@@ -164,6 +165,6 @@
throws Exception
{
Packet packet = messagingCodec.decode(buffer);
- decoderHandler.handle(packet);
+ decoderHandler.handle(packet);
}
}
Modified: branches/Branch_Message_Chunking/src/main/org/jboss/messaging/core/remoting/impl/PacketFragmentBufferImpl.java
===================================================================
--- branches/Branch_Message_Chunking/src/main/org/jboss/messaging/core/remoting/impl/PacketFragmentBufferImpl.java 2008-07-24 08:46:41 UTC (rev 4719)
+++ branches/Branch_Message_Chunking/src/main/org/jboss/messaging/core/remoting/impl/PacketFragmentBufferImpl.java 2008-07-24 12:28:28 UTC (rev 4720)
@@ -21,11 +21,11 @@
*/
package org.jboss.messaging.core.remoting.impl;
-import org.jboss.messaging.util.DataConstants;
import org.jboss.messaging.util.SimpleString;
import org.jboss.messaging.util.MessagingBuffer;
import static org.jboss.messaging.util.DataConstants.NULL;
import static org.jboss.messaging.util.DataConstants.NOT_NULL;
+import static org.jboss.messaging.util.DataConstants.*;
import org.jboss.messaging.core.remoting.impl.wireformat.PacketFragmentBuffer;
import org.jboss.messaging.core.remoting.PacketFragment;
@@ -49,16 +49,12 @@
private int size = 0;
private int correlationId = 0;
private int packetFragmentSize;
+ private int position = 0;
public PacketFragmentBufferImpl(int packetId, MessagingBuffer buffer, int packetFragmentSize)
{
packetFragments = new ArrayList<PacketFragment>();
- packetFragments.add(new PacketFragmentImpl(packetId, false, correlationId++, buffer));
- putInt(-1);
- putBoolean(false);
- putInt(getCurrentFragment().getPacketId());
- putInt(getCurrentFragment().getCorrelationId());
- getCurrentFragment().setDataStartPosition(getCurrentBuffer().position());
+ packetFragments.add(new PacketFragmentImpl(packetId, correlationId++, buffer));
this.packetFragmentSize = packetFragmentSize;
}
@@ -76,32 +72,37 @@
public void putFloat(float val)
{
- checkBufferSpace(DataConstants.SIZE_FLOAT);
- getCurrentBuffer().putFloat(val);
+ checkWriteSpace(SIZE_FLOAT);
+ getCurrentFragment().putFloat(val);
+ position += SIZE_FLOAT;
}
public void putInt(int i)
{
- checkBufferSpace(DataConstants.SIZE_INT);
- getCurrentBuffer().putInt(i);
+ checkWriteSpace(SIZE_INT);
+ getCurrentFragment().putInt(i);
+ position += SIZE_INT;
}
public void putByte(byte b)
{
- checkBufferSpace(DataConstants.SIZE_BYTE);
- getCurrentBuffer().putByte(b);
+ checkWriteSpace(SIZE_BYTE);
+ getCurrentFragment().putByte(b);
+ position += SIZE_BYTE;
}
public void putLong(long l)
{
- checkBufferSpace(DataConstants.SIZE_LONG);
- getCurrentBuffer().putLong(l);
+ checkWriteSpace(SIZE_LONG);
+ getCurrentFragment().putLong(l);
+ position += SIZE_LONG;
}
public void putBoolean(boolean b)
{
- checkBufferSpace(DataConstants.SIZE_BOOLEAN);
- getCurrentBuffer().putBoolean(b);
+ checkWriteSpace(SIZE_BOOLEAN);
+ getCurrentFragment().putBoolean(b);
+ position += SIZE_BOOLEAN;
}
public void putNullableString(String nullableString)
@@ -141,9 +142,9 @@
public void putBytes(byte[] bytes, int i, int i1)
{
- if(hasWriteSpace(i1 - i))
+ if(getCurrentFragment().checkSpace(i1 - i))
{
- getCurrentBuffer().putBytes(bytes, i, i1);
+ getCurrentFragment().putBytes(bytes, i, i1);
}
else
{
@@ -151,9 +152,9 @@
int written = 0;
while(written < i1)
{
- int left = getCurrentBuffer().limit() - getCurrentBuffer().position();
+ int left = getCurrentFragment().remaining();
int towrite = left + written > i1?i1 - written:left;
- getCurrentBuffer().putBytes(bytes, i, towrite);
+ getCurrentFragment().putBytes(bytes, i, towrite);
written+=towrite;
i += left;
if(written < i1)
@@ -161,8 +162,8 @@
setNextFragment();
}
}
-
}
+ position += (i1 - i);
}
public void putBytes(byte[] bytes)
@@ -172,20 +173,23 @@
public void putShort(short val)
{
- checkBufferSpace(DataConstants.SIZE_SHORT);
- getCurrentBuffer().putShort(val);
+ checkWriteSpace(SIZE_SHORT);
+ getCurrentFragment().putShort(val);
+ position += SIZE_SHORT;
}
public void putDouble(double val)
{
- checkBufferSpace(DataConstants.SIZE_DOUBLE);
- getCurrentBuffer().putDouble(val);
+ checkWriteSpace(SIZE_DOUBLE);
+ getCurrentFragment().putDouble(val);
+ position += SIZE_DOUBLE;
}
public void putChar(char val)
{
- checkBufferSpace(DataConstants.SIZE_CHAR);
- getCurrentBuffer().putChar(val);
+ checkWriteSpace(SIZE_CHAR);
+ getCurrentFragment().putChar(val);
+ position += SIZE_CHAR;
}
public void putUTF(String str)
@@ -199,16 +203,32 @@
public void putBoolean(int pos, boolean val)
{
- int bufferPos = getBufferPosition(pos);
- int actualPos = pos - getPreviousBuffersSize(bufferPos);
- packetFragments.get(bufferPos).getMessagingBuffer().putBoolean(actualPos, val);
+ int currentpos = 0;
+ for (PacketFragment packetFragment : packetFragments)
+ {
+ if(pos < packetFragment.getBodyLength())
+ {
+ packetFragment.putBoolean(pos - currentpos, val);
+ return;
+ }
+ currentpos += packetFragment.getBodyLength();
+ }
+ throw new IndexOutOfBoundsException();
}
public void putInt(int pos, int val)
{
- int bufferPos = getBufferPosition(pos);
- int actualPos = pos - getPreviousBuffersSize(bufferPos) + getCurrentFragment().getHeaderSize() + DataConstants.SIZE_INT;
- packetFragments.get(bufferPos).getMessagingBuffer().putInt(actualPos, val);
+ int currentpos = 0;
+ for (PacketFragment packetFragment : packetFragments)
+ {
+ if(pos < packetFragment.getBodyLength())
+ {
+ packetFragment.putInt(pos - currentpos, val);
+ return;
+ }
+ currentpos += packetFragment.getBodyLength();
+ }
+ throw new IndexOutOfBoundsException();
}
@@ -239,15 +259,24 @@
public void position(int position)
{
- int bufferPos = getBufferPosition(position);
- int actualPos = position - getPreviousBuffersSize(bufferPos);
- currentPos = bufferPos;
- getCurrentBuffer().position(actualPos);
+ int currentpos = 0;
+ for (int i = 0; i < packetFragments.size(); i++)
+ {
+ PacketFragment packetFragment = packetFragments.get(i);
+ currentpos += packetFragment.getBodyLength();
+ if (position < packetFragment.getBodyLength())
+ {
+ currentpos = i;
+ this.position = position;
+ packetFragment.position(position - currentpos);
+ return;
+ }
+ }
}
public int position()
{
- return getPreviousBuffersSize() + (getCurrentBuffer().position() - getCurrentFragment().getHeaderSize() - DataConstants.SIZE_INT);
+ return position;
}
public MessagingBuffer slice()
@@ -257,7 +286,7 @@
public MessagingBuffer createNewBuffer(int len)
{
- return new PacketFragmentBufferImpl(getCurrentFragment().getPacketId(),getCurrentBuffer().createNewBuffer(len), packetFragmentSize);
+ return null;
}
@@ -287,44 +316,51 @@
public void flip()
{
- for (int i = 0; i < packetFragments.size(); i++)
+ for (PacketFragment packetFragment : packetFragments)
{
- packetFragments.get(i).getMessagingBuffer().flip();
+ packetFragment.flip();
}
+ currentPos = 0;
+ position = 0;
}
public void rewind()
{
- for (int i = 0; i < packetFragments.size(); i++)
+ for (PacketFragment packetFragment : packetFragments)
{
- packetFragments.get(i).getMessagingBuffer().rewind();
+ packetFragment.rewind();
}
currentPos = 0;
+ position = 0;
}
public int getInt()
{
- checkReadSize(DataConstants.SIZE_INT);
- return getCurrentBuffer().getInt();
+ checkReadSpace(SIZE_INT);
+ position += SIZE_INT;
+ return getCurrentFragment().getInt();
}
public long getLong()
{
- checkReadSize(DataConstants.SIZE_LONG);
- return getCurrentBuffer().getLong();
+ checkReadSpace(SIZE_LONG);
+ position += SIZE_LONG;
+ return getCurrentFragment().getLong();
}
public short getShort()
{
- checkReadSize(DataConstants.SIZE_SHORT);
- return getCurrentBuffer().getShort();
+ checkReadSpace(SIZE_SHORT);
+ position += SIZE_SHORT;
+ return getCurrentFragment().getShort();
}
public boolean getBoolean()
{
- checkReadSize(DataConstants.SIZE_BOOLEAN);
- return getCurrentBuffer().getBoolean();
+ checkReadSpace(SIZE_BOOLEAN);
+ position += SIZE_BOOLEAN;
+ return getCurrentFragment().getBoolean();
}
public String getNullableString()
@@ -366,16 +402,17 @@
public byte getByte()
{
- checkReadSize(DataConstants.SIZE_BYTE);
- return getCurrentBuffer().getByte();
+ checkReadSpace(SIZE_BYTE);
+ position += SIZE_BYTE;
+ return getCurrentFragment().getByte();
}
public void getBytes(byte[] data)
{
- int left = getCurrentFragment().getEndPosition() - getCurrentBuffer().position();
+ int left = getCurrentFragment().remaining();
if(data.length <= left)
{
- getCurrentBuffer().getBytes(data);
+ getCurrentFragment().getBytes(data);
}
else
{
@@ -383,9 +420,9 @@
int read = 0;
while (read < size)
{
- left = getCurrentFragment().getEndPosition() - getCurrentBuffer().position();
+ left = getCurrentFragment().remaining();
- getCurrentBuffer().getBytes(data, read, left);
+ getCurrentFragment().getBytes(data, read, left);
read += left;
if(read < size)
{
@@ -396,25 +433,29 @@
}
}
+ position += data.length;
}
public float getFloat()
{
- checkReadSize(DataConstants.SIZE_FLOAT);
- return getCurrentBuffer().getFloat();
+ checkReadSpace(SIZE_FLOAT);
+ position += SIZE_FLOAT;
+ return getCurrentFragment().getFloat();
}
public double getDouble()
{
- checkReadSize(DataConstants.SIZE_DOUBLE);
- return getCurrentBuffer().getDouble();
+ checkReadSpace(SIZE_DOUBLE);
+ position += SIZE_DOUBLE;
+ return getCurrentFragment().getDouble();
}
public char getChar()
{
- checkReadSize(DataConstants.SIZE_CHAR);
- return getCurrentBuffer().getChar();
+ checkReadSpace(SIZE_CHAR);
+ position += SIZE_CHAR;
+ return getCurrentFragment().getChar();
}
public List<PacketFragment> getPacketFragments()
@@ -424,55 +465,52 @@
public void prepare()
{
- for (int i = 0; i < packetFragments.size(); i++)
+ for (PacketFragment packetFragment : packetFragments)
{
- PacketFragment packetFragment = packetFragments.get(i);
- int len = packetFragment.getMessagingBuffer().position() - packetFragment.getDataStartPosition() + getCurrentFragment().getHeaderSize();
- packetFragment.getMessagingBuffer().putInt(0, len);
- if(i == packetFragments.size() - 1)
- {
- packetFragment.getMessagingBuffer().putBoolean(DataConstants.SIZE_INT, true);
- }
- packetFragment.getMessagingBuffer().flip();
+ packetFragment.writeHeaders();
}
}
public short getUnsignedByte()
{
- checkReadSize(DataConstants.SIZE_SHORT);
- return getCurrentBuffer().getUnsignedByte();
+ checkReadSpace(SIZE_SHORT);
+ return getCurrentFragment().getUnsignedByte();
}
public int getUnsignedShort()
{
- checkReadSize(DataConstants.SIZE_INT);
- return getCurrentBuffer().getUnsignedByte();
+ checkReadSpace(SIZE_INT);
+ return getCurrentFragment().getUnsignedByte();
}
public int remaining()
{
- return getPostBuffersSize() + getCurrentBuffer().remaining();
+ return getCurrentFragment().remaining();
}
public int limit()
{
- return getPreviousBuffersSize() + getCurrentBuffer().limit();
+ int currentLimit = 0;
+ for (PacketFragment packetFragment : packetFragments)
+ {
+ currentLimit += packetFragment.limit();
+ }
+ return currentLimit;
}
// Private -------------------------------------------------------
- private void checkReadSize(int size)
+ private void checkReadSpace(int size)
{
- if(!hasReadSpace(size))
+ if(!getCurrentFragment().checkSpace(size))
{
currentPos++;
- getCurrentFragment().reset();
}
}
- private void checkBufferSpace(int size)
+ private void checkWriteSpace(int size)
{
- if(!hasWriteSpace(size))
+ if(!getCurrentFragment().checkSpace(size))
{
setNextFragment();
}
@@ -480,79 +518,15 @@
private void setNextFragment()
{
- getCurrentFragment().setLength(getCurrentBuffer().position());
- packetFragments.add(new PacketFragmentImpl(getCurrentFragment().getPacketId(), false, getCurrentFragment().getCorrelationId() + 1,
- getCurrentBuffer().createNewBuffer(packetFragmentSize)));
+ packetFragments.add(getCurrentFragment().createNextPacketFragment(packetFragmentSize));
currentPos++;
- putInt(-1);
- putBoolean(false);
- putInt(getCurrentFragment().getPacketId());
- putInt(getCurrentFragment().getCorrelationId());
- getCurrentFragment().setDataStartPosition(getCurrentBuffer().position());
}
- private boolean hasWriteSpace(int size)
- {
- int left = getCurrentBuffer().limit() - getCurrentBuffer().position();
- return size<=left;
- }
- private boolean hasReadSpace(int size)
- {
- return getCurrentBuffer().position() + size <= getCurrentFragment().getEndPosition();
- }
-
private PacketFragment getCurrentFragment()
{
return packetFragments.get(currentPos);
}
- private MessagingBuffer getCurrentBuffer()
- {
- return getCurrentFragment().getMessagingBuffer();
- }
- private int getPreviousBuffersSize()
- {
- return getPreviousBuffersSize(currentPos);
- }
-
- private int getPostBuffersSize()
- {
- return getPostBuffersSize(currentPos);
- }
-
- private int getPreviousBuffersSize(int currentPos)
- {
- int ret = 0;
- for(int i = 0; i < currentPos; i++)
- {
- ret+=packetFragments.get(i).getLength() - getCurrentFragment().getHeaderSize() - DataConstants.SIZE_INT;
- }
- return ret;
- }
-
- private int getPostBuffersSize(int currentPos)
- {
- int ret = 0;
- for(int i = currentPos + 1; i < packetFragments.size(); i++)
- {
- ret+=packetFragments.get(i).getLength();
- }
- return ret;
- }
-
- private int getBufferPosition(int position)
- {
- int pos = 0;
- for (int i = 0; i < packetFragments.size(); i++)
- {
- int end = packetFragments.get(i).getLength();
- if(position > pos && position < end)
- {
- return i;
- }
- }
- return pos;
- }
}
Modified: branches/Branch_Message_Chunking/src/main/org/jboss/messaging/core/remoting/impl/PacketFragmentImpl.java
===================================================================
--- branches/Branch_Message_Chunking/src/main/org/jboss/messaging/core/remoting/impl/PacketFragmentImpl.java 2008-07-24 08:46:41 UTC (rev 4719)
+++ branches/Branch_Message_Chunking/src/main/org/jboss/messaging/core/remoting/impl/PacketFragmentImpl.java 2008-07-24 12:28:28 UTC (rev 4720)
@@ -22,19 +22,18 @@
package org.jboss.messaging.core.remoting.impl;
import org.jboss.messaging.util.MessagingBuffer;
-import org.jboss.messaging.util.DataConstants;
+import static org.jboss.messaging.util.DataConstants.*;
import org.jboss.messaging.core.remoting.PacketFragment;
import org.jboss.messaging.core.remoting.MessageCache;
-import org.jboss.messaging.core.remoting.impl.mina.IoBufferWrapper;
/**
* A fragment of a full packet that holds a portion of a full message within a buffer.
- *
+ *
* @author <a href="mailto:andy.taylor at jboss.org">Andy Taylor</a>
*/
public class PacketFragmentImpl implements PacketFragment
{
- private int length;
+ private int bodyLength = 0;
private int packetId;
private int correlationId;
private boolean lastPacket;
@@ -49,7 +48,7 @@
this.lastPacket = lastPacket;
this.correlationId = correlationId;
this.messageCache = messageCache;
- this.length = length;
+ this.bodyLength = length - getHeaderSize();
this.sessionId = id;
dataStartPosition = 0;
}
@@ -59,22 +58,27 @@
this.packetId = packetId;
this.lastPacket = lastPacket;
this.correlationId = correlationId;
- this.length = length;
+ this.bodyLength = length - getHeaderSize();
this.messagingBuffer = messagingBuffer;
dataStartPosition = messagingBuffer.position();
}
- public PacketFragmentImpl(int packetId, boolean lastPacket, int correlationId, MessagingBuffer messagingBuffer)
+ public PacketFragmentImpl(int packetId, int correlationId, MessagingBuffer messagingBuffer)
{
this.packetId = packetId;
- this.lastPacket = lastPacket;
+ this.lastPacket = true;
this.correlationId = correlationId;
this.messagingBuffer = messagingBuffer;
+ messagingBuffer.putInt(-1);
+ messagingBuffer.putBoolean(true);
+ messagingBuffer.putInt(packetId);
+ messagingBuffer.putInt(correlationId);
+ dataStartPosition = messagingBuffer.position();
}
- public int getHeaderSize()
+ private int getHeaderSize()
{
- return (DataConstants.SIZE_INT * 2) + DataConstants.SIZE_BOOLEAN;
+ return (SIZE_INT * 3) + SIZE_BOOLEAN;
}
public int getPacketId()
{
@@ -103,14 +107,9 @@
public int getLength()
{
- return length;
+ return bodyLength + getHeaderSize();
}
- public void setLength(int i)
- {
- length = i;
- }
-
public boolean isLastPacket()
{
return lastPacket;
@@ -120,7 +119,7 @@
{
if(messagingBuffer == null)
{
- messagingBuffer = messageCache.retrieve(length - 9, sessionId, packetId, correlationId);
+ messagingBuffer = messageCache.retrieve(getLength(), sessionId, packetId, correlationId);
}
return messagingBuffer;
}
@@ -146,4 +145,186 @@
messagingBuffer.position(dataStartPosition);
}
}
+
+ public boolean checkSpace(int size)
+ {
+ int left = messagingBuffer.limit() - messagingBuffer.position();
+ return size<=left;
+ }
+
+ public boolean hasReadSpace(int size)
+ {
+ return messagingBuffer.position() + size <= messagingBuffer.limit();
+ }
+
+ public void putFloat(float val)
+ {
+ messagingBuffer.putFloat(val);
+ bodyLength += SIZE_FLOAT;
+ }
+
+ public void putInt(int i)
+ {
+ messagingBuffer.putInt(i);
+ bodyLength += SIZE_INT;
+ }
+
+ public void putByte(byte b)
+ {
+ messagingBuffer.putByte(b);
+ bodyLength += SIZE_BYTE;
+ }
+
+ public void putLong(long l)
+ {
+ messagingBuffer.putLong(l);
+ bodyLength += SIZE_LONG;
+ }
+
+ public void putBytes(byte[] bytes, int i, int i1)
+ {
+ messagingBuffer.putBytes(bytes, i, i1);
+ bodyLength += (i1 - i);
+ }
+
+ public void putDouble(double val)
+ {
+ messagingBuffer.putDouble(val);
+ bodyLength += SIZE_DOUBLE;
+ }
+
+ public void putShort(short val)
+ {
+ messagingBuffer.putShort(val);
+ bodyLength += SIZE_SHORT;
+ }
+
+ public void putChar(char val)
+ {
+ messagingBuffer.putChar(val);
+ bodyLength += SIZE_CHAR;
+ }
+
+ public void putBoolean(boolean b)
+ {
+ messagingBuffer.putBoolean(b);
+ bodyLength += SIZE_BOOLEAN;
+ }
+
+ public int getInt()
+ {
+ return messagingBuffer.getInt();
+ }
+
+ public long getLong()
+ {
+ return messagingBuffer.getLong();
+ }
+
+ public short getShort()
+ {
+ return messagingBuffer.getShort();
+ }
+
+ public boolean getBoolean()
+ {
+ return messagingBuffer.getBoolean();
+ }
+
+ public byte getByte()
+ {
+ return messagingBuffer.getByte();
+ }
+
+ public void getBytes(byte[] data)
+ {
+ messagingBuffer.getBytes(data);
+ }
+
+ public void getBytes(byte[] data, int read, int left)
+ {
+ messagingBuffer.getBytes(data, read, left);
+ }
+
+ public float getFloat()
+ {
+ return messagingBuffer.getFloat();
+ }
+
+ public double getDouble()
+ {
+ return messagingBuffer.getDouble();
+ }
+
+ public char getChar()
+ {
+ return messagingBuffer.getChar();
+ }
+
+ public short getUnsignedByte()
+ {
+ return messagingBuffer.getUnsignedByte();
+ }
+
+ public int getBodyLength()
+ {
+ return bodyLength;
+ }
+
+ public void setBodyLength(int bodyLength)
+ {
+ this.bodyLength = bodyLength;
+ }
+
+ public int remaining()
+ {
+ return messagingBuffer.remaining();
+ }
+
+ public int limit()
+ {
+ return messagingBuffer.limit() - getHeaderSize();
+ }
+
+ public void writeHeaders()
+ {
+ messagingBuffer.putInt(0, getLength() - SIZE_INT);
+ //we initially wrote true anyway
+ if(!isLastPacket())
+ {
+ messagingBuffer.putBoolean(SIZE_INT, isLastPacket());
+ }
+ }
+
+ public PacketFragment createNextPacketFragment(int packetFragmentSize)
+ {
+ setLastPacket(false);
+ return new PacketFragmentImpl(packetId, correlationId + 1,
+ messagingBuffer.createNewBuffer(packetFragmentSize));
+ }
+
+ public void putBoolean(int pos, boolean val)
+ {
+ messagingBuffer.putBoolean(pos + getHeaderSize(), val);
+ }
+
+ public void putInt(int pos, int val)
+ {
+ messagingBuffer.putInt(pos + getHeaderSize(), val);
+ }
+
+ public void rewind()
+ {
+ messagingBuffer.rewind();
+ }
+
+ public void flip()
+ {
+ messagingBuffer.flip();
+ }
+
+ public void position(int position)
+ {
+ messagingBuffer.position(position);
+ }
}
More information about the jboss-cvs-commits
mailing list