[jboss-cvs] JBoss Messaging SVN: r5100 - in branches/Branch_Chunk_Clebert: src/main/org/jboss/messaging/core/server/impl and 1 other directory.

[jboss-cvs-commits at lists.jboss.org]

Author: clebert.suconic at jboss.com
Date: 2008-10-10 10:29:11 -0400 (Fri, 10 Oct 2008)
New Revision: 5100

Modified:
   branches/Branch_Chunk_Clebert/.classpath
   branches/Branch_Chunk_Clebert/src/main/org/jboss/messaging/core/server/impl/ServerProducerImpl.java
Log:
some cleanup

Modified: branches/Branch_Chunk_Clebert/.classpath
===================================================================
--- branches/Branch_Chunk_Clebert/.classpath	2008-10-10 00:24:42 UTC (rev 5099)
+++ branches/Branch_Chunk_Clebert/.classpath	2008-10-10 14:29:11 UTC (rev 5100)
@@ -64,5 +64,6 @@
 	<classpathentry kind="lib" path="tests/tmpfiles"/>
 	<classpathentry kind="lib" path="thirdparty/apache-mina/lib/mina-core-2.0.0-M3-20080730.120633-1.jar" sourcepath="thirdparty/apache-mina/lib/mina-core-2.0.0-M3-20080730.120633-1-sources.jar"/>
 	<classpathentry kind="lib" path="thirdparty/netty/lib/netty-3.0.0.CR4.jar"/>
+	<classpathentry kind="var" path="ANT_HOME"/>
 	<classpathentry kind="output" path="eclipse-output"/>
 </classpath>

Modified: branches/Branch_Chunk_Clebert/src/main/org/jboss/messaging/core/server/impl/ServerProducerImpl.java
===================================================================
--- branches/Branch_Chunk_Clebert/src/main/org/jboss/messaging/core/server/impl/ServerProducerImpl.java	2008-10-10 00:24:42 UTC (rev 5099)
+++ branches/Branch_Chunk_Clebert/src/main/org/jboss/messaging/core/server/impl/ServerProducerImpl.java	2008-10-10 14:29:11 UTC (rev 5100)
@@ -22,13 +22,16 @@
 
 package org.jboss.messaging.core.server.impl;
 
+import java.nio.ByteBuffer;
 import java.util.concurrent.atomic.AtomicInteger;
 
 import org.jboss.messaging.core.exception.MessagingException;
 import org.jboss.messaging.core.postoffice.FlowController;
 import org.jboss.messaging.core.remoting.Channel;
 import org.jboss.messaging.core.remoting.Packet;
+import org.jboss.messaging.core.remoting.impl.ByteBufferWrapper;
 import org.jboss.messaging.core.remoting.impl.wireformat.SessionProducerFlowCreditMessage;
+import org.jboss.messaging.core.remoting.spi.MessagingBuffer;
 import org.jboss.messaging.core.server.ServerLargeMessage;
 import org.jboss.messaging.core.server.ServerMessage;
 import org.jboss.messaging.core.server.ServerProducer;
@@ -121,22 +124,6 @@
       currentlargeMessage = message;
    }
 
-
-   public void sendChunk(final byte[] message, final int position, final int totalSize) throws Exception
-   {
-      currentlargeMessage.addBytes(message);
-      if (position + message.length > totalSize)
-      {
-         throw new MessagingException(MessagingException.ILLEGAL_STATE, "Invalid ChunkSize sent over the wire");
-      }
-      else if (position + message.length == totalSize)
-      {
-         System.out.println("Sending complete message now");
-         send(currentlargeMessage);
-         this.currentlargeMessage = null;
-      }
-   }
-
    public void requestAndSendCredits() throws Exception
    {
       if (!waiting)