[jboss-cvs] JBoss Messaging SVN: r5126 - branches/Branch_Chunk_Clebert/tests/src/org/jboss/messaging/tests/integration/chunkmessage.

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

Author: clebert.suconic at jboss.com
Date: 2008-10-16 17:44:34 -0400 (Thu, 16 Oct 2008)
New Revision: 5126

Modified:
   branches/Branch_Chunk_Clebert/tests/src/org/jboss/messaging/tests/integration/chunkmessage/MessageChunkTest.java
Log:
Cleanup and format

Modified: branches/Branch_Chunk_Clebert/tests/src/org/jboss/messaging/tests/integration/chunkmessage/MessageChunkTest.java
===================================================================
--- branches/Branch_Chunk_Clebert/tests/src/org/jboss/messaging/tests/integration/chunkmessage/MessageChunkTest.java	2008-10-16 21:42:42 UTC (rev 5125)
+++ branches/Branch_Chunk_Clebert/tests/src/org/jboss/messaging/tests/integration/chunkmessage/MessageChunkTest.java	2008-10-16 21:44:34 UTC (rev 5126)
@@ -121,34 +121,34 @@
       // The other binding is acked... The file must be deleted
 
       clearData();
-      
+
       try
       {
-   
+
          messagingService = createService(true);
-   
+
          messagingService.start();
-   
-         SimpleString queue[] = new SimpleString[] {new SimpleString("queue1"), new SimpleString("queue2") };
-         
+
+         SimpleString queue[] = new SimpleString[] { new SimpleString("queue1"), new SimpleString("queue2") };
+
          ClientSessionFactory sf = createInVMFactory();
-   
+
          ClientSession session = sf.createSession(false, true, true, false);
-   
+
          session.createQueue(ADDRESS, queue[0], null, true, false);
          session.createQueue(ADDRESS, queue[1], null, true, false);
-   
+
          FileClientMessage clientFile = session.createFileMessage(true);
-   
+
          File tmpFile = new File(temporaryDir + "/" + "tmpUpload.data");
-   
+
          RandomAccessFile random = new RandomAccessFile(tmpFile, "rw");
          FileChannel channel = random.getChannel();
-   
+
          ByteBuffer buffer = ByteBuffer.allocate(4);
-         
-         int numberOfIntegers = 10000; 
-   
+
+         int numberOfIntegers = 10000;
+
          for (int i = 0; i < numberOfIntegers; i++)
          {
             buffer.rewind();
@@ -156,35 +156,35 @@
             buffer.rewind();
             channel.write(buffer);
          }
-   
+
          channel.close();
          random.close();
-   
+
          clientFile.setFile(tmpFile);
-   
+
          ClientProducer producer = session.createProducer(ADDRESS);
          producer.send(clientFile);
-         
+
          producer.close();
-         
+
          readMessage(session, queue[0], numberOfIntegers);
-   
+
          session.close();
-         
+
          messagingService.stop();
-   
+
          messagingService = createService(true);
-   
+
          messagingService.start();
-         
+
          sf = createInVMFactory();
-   
+
          session = sf.createSession(false, true, true, false);
-         
+
          readMessage(session, queue[1], numberOfIntegers);
-         
+
          session.close();
-         
+
          File largeMessagesFileDir = new File(largeMessagesDir);
          assertEquals(0, largeMessagesFileDir.listFiles().length);
       }
@@ -199,7 +199,6 @@
          }
       }
 
-
    }
 
    /**
@@ -210,26 +209,26 @@
     * @throws FileNotFoundException
     * @throws IOException
     */
-   private void readMessage(ClientSession session, SimpleString queueToRead, int numberOfIntegers) throws MessagingException,
-                                                                                                  FileNotFoundException,
-                                                                                                  IOException
+   private void readMessage(final ClientSession session, final SimpleString queueToRead, final int numberOfIntegers) throws MessagingException,
+                                                                                                                    FileNotFoundException,
+                                                                                                                    IOException
    {
       ClientConsumer consumer = session.createConsumer(queueToRead);
-      
+
       consumer.setLargeMessagesAsFiles(true);
       consumer.setLargeMessagesDir(new File(clientLargeMessagesDir));
-      
+
       session.start();
-      
-      FileClientMessage clientMessage = (FileClientMessage) consumer.receive(4000);
-      
+
+      FileClientMessage clientMessage = (FileClientMessage)consumer.receive(4000);
+
       assertNotNull(clientMessage);
       File receivedFile = clientMessage.getFile();
-      
+
       checkFileRead(receivedFile, numberOfIntegers);
-      
+
       clientMessage.processed();
-      
+
       consumer.close();
    }
 
@@ -238,25 +237,25 @@
     * @throws FileNotFoundException
     * @throws IOException
     */
-   private void checkFileRead(File receivedFile, int numberOfIntegers) throws FileNotFoundException, IOException
+   private void checkFileRead(final File receivedFile, final int numberOfIntegers) throws FileNotFoundException,
+                                                                                  IOException
    {
       RandomAccessFile random2 = new RandomAccessFile(receivedFile, "r");
       FileChannel channel2 = random2.getChannel();
 
       ByteBuffer buffer2 = ByteBuffer.allocate(4);
-      
+
       channel2.position(0l);
-      
-      for (int i=0;i<numberOfIntegers;i++)
+
+      for (int i = 0; i < numberOfIntegers; i++)
       {
          buffer2.rewind();
          channel2.read(buffer2);
          buffer2.rewind();
-         
+
          assertEquals(i, buffer2.getInt());
       }
-      
-      
+
       channel2.close();
    }