java怎么向activemq发送消息?谁有原代码 比较简单的就可以了 只要发的就可以

Question

我支持一下。//  service:jmx:rmi:///jndi/rmi://localhost:1099/jmxrmi
// ?jms.blobTransferPolicy.defaultUploadUrl=http://lcoalhost:"+8161+"/fileserver/
public void sendMess() throws JMSException {
long beginTime = System.currentTimeMillis();
ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(
"999999999", "1", "tcp://localhost:61616");
//"admin", "admin", "tcp://localhost:61616");
// Create a Connection
ActiveMQConnection connection = (ActiveMQConnection) connectionFactory
.createConnection();
connection.setCopyMessageOnSend(false);
connection.start();

// Create a Session
ActiveMQSession session = (ActiveMQSession) connection.createSession(
false, Session.AUTO_ACKNOWLEDGE);
File f1 = new File("C:/testmqdata");
String[] fileNames = f1.list();
for (int i = 0, n = fileNames.length; i < n; i++) {
InputStream inputStream = null;
try {
inputStream = new FileInputStream("C:/testmqdata/"
+ fileNames[i]);
} catch (FileNotFoundException e) {
e.printStackTrace();
}
// Create a messages
byte[] stockData = null; /* 股票信息是一个字节数组 */
try {
stockData = this.getBytesFromIS(inputStream);
} catch (IOException e) {
e.printStackTrace();
}
ActiveMQBytesMessage message = (ActiveMQBytesMessage) session.createBytesMessage();
message.writeBytes(stockData);
Map map = new HashMap();
map.put("dd","dd");
map.put("cc","ddd");
map.put("bb","vv");
message.setProperties(map);
// Create the destination (Queue)
Destination destination = session.createQueue("999999999");
// Create a MessageProducer from the Session to the Queue
MessageProducer producer = session.createProducer(destination);
producer.setDeliveryMode(DeliveryMode.PERSISTENT);
producer.send(message);
// Tell the producer to send the message
System.out.println("Sent message: " + message.hashCode() + " : "
+ Thread.currentThread().getName());
}
// Clean up
session.close();
connection.close();
long endTime = System.currentTimeMillis();

System.out.println("send Time "+(endTime - beginTime));
}