[jboss-cvs] JBoss Messaging SVN: r5925 - in branches/JBMESSAGING_1394/src/main/org/jboss/messaging/core/remoting: spi and 1 other directory.
jboss-cvs-commits at lists.jboss.org
jboss-cvs-commits at lists.jboss.org
Tue Feb 24 23:22:25 EST 2009
Author: clebert.suconic at jboss.com
Date: 2009-02-24 23:22:25 -0500 (Tue, 24 Feb 2009)
New Revision: 5925
Modified:
branches/JBMESSAGING_1394/src/main/org/jboss/messaging/core/remoting/buffers/AbstractChannelBuffer.java
branches/JBMESSAGING_1394/src/main/org/jboss/messaging/core/remoting/buffers/ChannelBuffer.java
branches/JBMESSAGING_1394/src/main/org/jboss/messaging/core/remoting/buffers/HeapChannelBuffer.java
branches/JBMESSAGING_1394/src/main/org/jboss/messaging/core/remoting/spi/MessagingBuffer.java
Log:
backup
Modified: branches/JBMESSAGING_1394/src/main/org/jboss/messaging/core/remoting/buffers/AbstractChannelBuffer.java
===================================================================
--- branches/JBMESSAGING_1394/src/main/org/jboss/messaging/core/remoting/buffers/AbstractChannelBuffer.java 2009-02-25 02:48:17 UTC (rev 5924)
+++ branches/JBMESSAGING_1394/src/main/org/jboss/messaging/core/remoting/buffers/AbstractChannelBuffer.java 2009-02-25 04:22:25 UTC (rev 5925)
@@ -29,6 +29,9 @@
import java.nio.channels.GatheringByteChannel;
import java.nio.channels.ScatteringByteChannel;
+import org.jboss.messaging.core.remoting.spi.MessagingBuffer;
+import org.jboss.messaging.util.SimpleString;
+
/**
* A skeletal implementation of a buffer.
*
@@ -37,7 +40,7 @@
*
* @version $Rev: 303 $, $Date: 2008-09-24 18:48:32 +0900 (Wed, 24 Sep 2008) $
*/
-public abstract class AbstractChannelBuffer implements ChannelBuffer
+public abstract class AbstractChannelBuffer implements ChannelBuffer, MessagingBuffer
{
private int readerIndex;
@@ -591,4 +594,174 @@
throw new IndexOutOfBoundsException();
}
}
+
+ public Object getUnderlyingBuffer()
+ {
+ return this;
+ }
+
+ public abstract byte[] array();
+
+ /* (non-Javadoc)
+ * @see org.jboss.messaging.core.remoting.spi.MessagingBuffer#readBoolean()
+ */
+ public boolean readBoolean()
+ {
+ // TODO Auto-generated method stub
+ return false;
+ }
+
+ /* (non-Javadoc)
+ * @see org.jboss.messaging.core.remoting.spi.MessagingBuffer#readChar()
+ */
+ public char readChar()
+ {
+ // TODO Auto-generated method stub
+ return 0;
+ }
+
+ /* (non-Javadoc)
+ * @see org.jboss.messaging.core.remoting.spi.MessagingBuffer#readDouble()
+ */
+ public double readDouble()
+ {
+ // TODO Auto-generated method stub
+ return 0;
+ }
+
+ /* (non-Javadoc)
+ * @see org.jboss.messaging.core.remoting.spi.MessagingBuffer#readFloat()
+ */
+ public float readFloat()
+ {
+ // TODO Auto-generated method stub
+ return 0;
+ }
+
+ /* (non-Javadoc)
+ * @see org.jboss.messaging.core.remoting.spi.MessagingBuffer#readNullableSimpleString()
+ */
+ public SimpleString readNullableSimpleString()
+ {
+ // TODO Auto-generated method stub
+ return null;
+ }
+
+ /* (non-Javadoc)
+ * @see org.jboss.messaging.core.remoting.spi.MessagingBuffer#readNullableString()
+ */
+ public String readNullableString()
+ {
+ // TODO Auto-generated method stub
+ return null;
+ }
+
+ /* (non-Javadoc)
+ * @see org.jboss.messaging.core.remoting.spi.MessagingBuffer#readSimpleString()
+ */
+ public SimpleString readSimpleString()
+ {
+ // TODO Auto-generated method stub
+ return null;
+ }
+
+ /* (non-Javadoc)
+ * @see org.jboss.messaging.core.remoting.spi.MessagingBuffer#readString()
+ */
+ public String readString()
+ {
+ // TODO Auto-generated method stub
+ return null;
+ }
+
+ /* (non-Javadoc)
+ * @see org.jboss.messaging.core.remoting.spi.MessagingBuffer#readUTF()
+ */
+ public String readUTF() throws Exception
+ {
+ // TODO Auto-generated method stub
+ return null;
+ }
+
+ /* (non-Javadoc)
+ * @see org.jboss.messaging.core.remoting.spi.MessagingBuffer#writeBoolean(boolean)
+ */
+ public void writeBoolean(boolean val)
+ {
+ // TODO Auto-generated method stub
+
+ }
+
+ /* (non-Javadoc)
+ * @see org.jboss.messaging.core.remoting.spi.MessagingBuffer#writeChar(char)
+ */
+ public void writeChar(char val)
+ {
+ // TODO Auto-generated method stub
+
+ }
+
+ /* (non-Javadoc)
+ * @see org.jboss.messaging.core.remoting.spi.MessagingBuffer#writeDouble(double)
+ */
+ public void writeDouble(double val)
+ {
+ // TODO Auto-generated method stub
+
+ }
+
+ /* (non-Javadoc)
+ * @see org.jboss.messaging.core.remoting.spi.MessagingBuffer#writeFloat(float)
+ */
+ public void writeFloat(float val)
+ {
+ // TODO Auto-generated method stub
+
+ }
+
+ /* (non-Javadoc)
+ * @see org.jboss.messaging.core.remoting.spi.MessagingBuffer#writeNullableSimpleString(org.jboss.messaging.util.SimpleString)
+ */
+ public void writeNullableSimpleString(SimpleString val)
+ {
+ // TODO Auto-generated method stub
+
+ }
+
+ /* (non-Javadoc)
+ * @see org.jboss.messaging.core.remoting.spi.MessagingBuffer#writeNullableString(java.lang.String)
+ */
+ public void writeNullableString(String val)
+ {
+ // TODO Auto-generated method stub
+
+ }
+
+ /* (non-Javadoc)
+ * @see org.jboss.messaging.core.remoting.spi.MessagingBuffer#writeSimpleString(org.jboss.messaging.util.SimpleString)
+ */
+ public void writeSimpleString(SimpleString val)
+ {
+ // TODO Auto-generated method stub
+
+ }
+
+ /* (non-Javadoc)
+ * @see org.jboss.messaging.core.remoting.spi.MessagingBuffer#writeString(java.lang.String)
+ */
+ public void writeString(String val)
+ {
+ // TODO Auto-generated method stub
+
+ }
+
+ /* (non-Javadoc)
+ * @see org.jboss.messaging.core.remoting.spi.MessagingBuffer#writeUTF(java.lang.String)
+ */
+ public void writeUTF(String utf) throws Exception
+ {
+ // TODO Auto-generated method stub
+
+ }
+
}
Modified: branches/JBMESSAGING_1394/src/main/org/jboss/messaging/core/remoting/buffers/ChannelBuffer.java
===================================================================
--- branches/JBMESSAGING_1394/src/main/org/jboss/messaging/core/remoting/buffers/ChannelBuffer.java 2009-02-25 02:48:17 UTC (rev 5924)
+++ branches/JBMESSAGING_1394/src/main/org/jboss/messaging/core/remoting/buffers/ChannelBuffer.java 2009-02-25 04:22:25 UTC (rev 5925)
@@ -30,8 +30,8 @@
import java.nio.channels.GatheringByteChannel;
import java.nio.channels.ScatteringByteChannel;
import java.nio.charset.UnsupportedCharsetException;
-import java.util.NoSuchElementException;
+import org.jboss.netty.buffer.ChannelBufferIndexFinder;
import org.jboss.netty.buffer.ChannelBufferInputStream;
import org.jboss.netty.buffer.ChannelBufferOutputStream;
Modified: branches/JBMESSAGING_1394/src/main/org/jboss/messaging/core/remoting/buffers/HeapChannelBuffer.java
===================================================================
--- branches/JBMESSAGING_1394/src/main/org/jboss/messaging/core/remoting/buffers/HeapChannelBuffer.java 2009-02-25 02:48:17 UTC (rev 5924)
+++ branches/JBMESSAGING_1394/src/main/org/jboss/messaging/core/remoting/buffers/HeapChannelBuffer.java 2009-02-25 04:22:25 UTC (rev 5925)
@@ -33,6 +33,8 @@
import java.nio.channels.ScatteringByteChannel;
import java.nio.charset.UnsupportedCharsetException;
+import org.jboss.messaging.util.SimpleString;
+
/**
* A skeletal implementation for Java heap buffers.
*
@@ -268,4 +270,15 @@
throw new UnsupportedCharsetException(charsetName);
}
}
+
+
+ /* (non-Javadoc)
+ * @see org.jboss.messaging.core.remoting.spi.MessagingBuffer#array()
+ */
+ public byte[] array()
+ {
+ return array;
+ }
+
+
}
Modified: branches/JBMESSAGING_1394/src/main/org/jboss/messaging/core/remoting/spi/MessagingBuffer.java
===================================================================
--- branches/JBMESSAGING_1394/src/main/org/jboss/messaging/core/remoting/spi/MessagingBuffer.java 2009-02-25 02:48:17 UTC (rev 5924)
+++ branches/JBMESSAGING_1394/src/main/org/jboss/messaging/core/remoting/spi/MessagingBuffer.java 2009-02-25 04:22:25 UTC (rev 5925)
@@ -123,16 +123,11 @@
void clear();
- void markReaderIndex();
-
void resetReaderIndex();
- void markWriterIndex();
-
void resetWriterIndex();
- void discardReadBytes();
-
+ // get rid of this
Object getUnderlyingBuffer();
}
More information about the jboss-cvs-commits
mailing list