Mailing-List: contact users-help@activemq.apache.org; run by ezmlm
Precedence: bulk
Reply-To: users@activemq.apache.org
Received-SPF: pass (athena.apache.org: domain of lists@nabble.com designates
 216.139.236.158 as permitted sender)
Message-ID: <12071917.post@talk.nabble.com>
Date: Thu, 9 Aug 2007 05:54:34 -0700 (PDT)
From: "Viali.Lee" <Viali.Lee@Hotmail.COM>
To: users@activemq.apache.org
Subject: BlobMessage doesn't work...
MIME-Version: 1.0
Content-Type: text/plain; charset=us-ascii
Content-Transfer-Encoding: 7bit


I download the ActiveMQ 5.0-SNAPSHOT and unzip it, then run
/bin/activemq.bat. 
After that, I wrote a Producer and Consumer to test the BlobMessage feature
of ActiveMQ 5.0-SNAPSHOT, but failed!!!

Producer.java:

import java.io.File;
import javax.jms.*;
import org.apache.activemq.*;
public class Producer 
{
	public static void main(String[] args) throws Exception 
	{
		ActiveMQConnectionFactory connectionFactory = new
ActiveMQConnectionFactory("tcp://localhost:61616");			
		Connection connection = connectionFactory.createConnection();
		connection.start();
		ActiveMQSession session = (ActiveMQSession)
connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
		Destination destination = session.createQueue("message.larger.input");
		MessageProducer producer = session.createProducer(destination);
		BlobMessage message =  session.createBlobMessage(new
File("D://1.1K.Test.xml"));
		producer.send(message);		
		session.close();
		connection.close();
	}
}


Consumer.java:

import java.io.*;
import javax.jms.*;
import javax.jms.Message;
import org.apache.activemq.*;
public class Consumer 
{
	public static void main(String[] args) throws Exception 
	{
		ActiveMQConnectionFactory connectionFactory = new
ActiveMQConnectionFactory("tcp://localhost:61616");
		Connection connection = connectionFactory.createConnection();
		connection.start();
		ActiveMQSession session = (ActiveMQSession)
connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
		Destination destination = session.createQueue("message.larger.input");
		MessageConsumer consumer = session.createConsumer(destination);
		Message message = consumer.receive(10000);

		BlobMessage blobMessage = (BlobMessage) message;
		InputStream in = blobMessage.getInputStream();
		byte[] b = new byte[2048];
		File file = new File("D://result.xml");
		FileOutputStream out = new FileOutputStream(file);
		while (in.read(b) > 0) {
			out.write(b);
		}
		out.close();
		session.close();
		connection.close();
	}
}

error:
Exception in thread "main" java.lang.NullPointerException
the inputstream received by Consumer is null.

who knows what happened??
-- 
View this message in context: http://www.nabble.com/BlobMessage-doesn%27t-work...-tf4242461s2354.html#a12071917
Sent from the ActiveMQ - User mailing list archive at Nabble.com.