[jboss-cvs] JBoss Messaging SVN: r6368 - trunk/examples/jms/large-message/src/org/jboss/jms/example.
jboss-cvs-commits at lists.jboss.org
jboss-cvs-commits at lists.jboss.org
Wed Apr 8 11:17:26 EDT 2009
Author: clebert.suconic at jboss.com
Date: 2009-04-08 11:17:26 -0400 (Wed, 08 Apr 2009)
New Revision: 6368
Modified:
trunk/examples/jms/large-message/src/org/jboss/jms/example/LargeMessageExample.java
Log:
sorry about this accidental commit.
Modified: trunk/examples/jms/large-message/src/org/jboss/jms/example/LargeMessageExample.java
===================================================================
--- trunk/examples/jms/large-message/src/org/jboss/jms/example/LargeMessageExample.java 2009-04-08 14:52:44 UTC (rev 6367)
+++ trunk/examples/jms/large-message/src/org/jboss/jms/example/LargeMessageExample.java 2009-04-08 15:17:26 UTC (rev 6368)
@@ -21,12 +21,6 @@
*/
package org.jboss.jms.example;
-import java.io.BufferedInputStream;
-import java.io.BufferedOutputStream;
-import java.io.File;
-import java.io.FileInputStream;
-import java.io.FileOutputStream;
-
import javax.jms.BytesMessage;
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
@@ -36,8 +30,6 @@
import javax.jms.Session;
import javax.naming.InitialContext;
-import org.jboss.messaging.jms.client.JBossMessage;
-
/**
* A simple JMS Queue example that creates a producer and consumer on a queue and sends then receives a message.
*
@@ -54,7 +46,6 @@
{
Connection connection = null;
InitialContext initialContext = null;
- File tmpFile = File.createTempFile("example", ".jbm");
try
{
//Step 1. Create an initial context to perform the JNDI lookup.
@@ -75,25 +66,12 @@
//Step 6. Create a JMS Message Producer
MessageProducer producer = session.createProducer(queue);
- {
- FileOutputStream fileOut = new FileOutputStream(tmpFile);
- BufferedOutputStream buffOut = new BufferedOutputStream(fileOut);
- byte[] outBuffer = new byte[1024 * 1024];
- for (int i = 0; i < 100 ; i++)
- {
- buffOut.write(outBuffer);
- }
- buffOut.close();
- outBuffer = null;
- }
-
- FileInputStream fileInput = new FileInputStream(tmpFile);
- BufferedInputStream buffered = new BufferedInputStream(fileInput);
-
//Step 7. Create a BytesMessage with 1MB arbitrary bytes
BytesMessage message = session.createBytesMessage();
+ byte[] bytes = new byte[100 * 1024 * 1024];
+ message.writeBytes(bytes);
- ((JBossMessage)message).getCoreMessage().setBodyInputStream(buffered);
+ System.out.println("Sending message of " + bytes.length + " bytes");
//Step 8. Send the Message
producer.send(message);
@@ -110,14 +88,8 @@
//Step 11. Receive the message
BytesMessage messageReceived = (BytesMessage) messageConsumer.receive(60000);
-
- byte bytes[] = new byte[1024 * 1024];
- for (int i = 0; i < 100 ; i++)
- {
- messageReceived.readBytes(bytes);
- }
- System.out.println("Received message: " + /*messageReceived.getBodyLength() + */" bytes");
+ System.out.println("Received message: " + messageReceived.getBodyLength() + " bytes");
initialContext.close();
@@ -125,13 +97,6 @@
}
finally
{
- try
- {
- tmpFile.delete();
- }
- catch (Throwable ignored)
- {
- }
//Step 12. Be sure to close our JMS resources!
if (initialContext != null)
{
More information about the jboss-cvs-commits
mailing list