I have a problem with this code:
import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.MessageProducer;
import javax.jms.QueueConnection;
import javax.jms.QueueConnectionFactory;
import javax.jms.QueueSession;
import javax.jms.Session;
import org.apache.activemq.ActiveMQConnection;
import org.apache.activemq.ActiveMQConnectionFactory;
import org.apache.activemq.ActiveMQSession;
import org.apache.activemq.BlobMessage;
import org.apache.activemq.command.ActiveMQBlobMessage;
import org.apache.activemq.command.ActiveMQQueue;
public class Sending {
/**
* @param args
* @throws IOException
*/
public static void main(String[] args) throws IOException {
// TODO Auto-generated method stub
long a1 = System.currentTimeMillis();
ActiveMQConnectionFactory cf = new ActiveMQConnectionFactory(
"tcp://localhost:61616");
ActiveMQConnection conn = null;
ActiveMQSession session = null;
try {
conn = (ActiveMQConnection)cf.createConnection();
session = (ActiveMQSession) conn.createSession(false,
Session.AUTO_ACKNOWLEDGE);
Destination destination = new ActiveMQQueue("Queue");
MessageProducer producer = session.createProducer(destination);
BlobMessage message = session.createBlobMessage(new
File("src\\BlobMessage\\file\\foto.jpg"));
System.out.println(message.getInputStream());
producer.send(message);
} catch (JMSException e) {
e.printStackTrace();
} finally {
try {
if (session != null) {
session.close();
}
if (conn != null) {
conn.close();
}
} catch (JMSException ex) {
}
}
a1 = System.currentTimeMillis() - a1;
System.out.println(a1);
}
}
When i create blobmessage object and print his inputstream pirnted NULL, why???
then when i send the message the file not sending.
Please may anybody help me??
Ing. Iósev Pérez Rivero
Dirección Técnica - IP
Universidad de las Ciencias Informaticas