1 28 29 package sampleappli; 32 33 import javax.ejb.MessageDrivenBean; 34 import javax.ejb.MessageDrivenContext; 35 import javax.jms.Message; 36 import javax.jms.MessageListener; 37 import javax.jms.TextMessage; 38 39 import javax.naming.Context; 40 import javax.naming.InitialContext; 41 42 import java.io.DataOutputStream; 43 import java.io.BufferedOutputStream; 44 import java.io.File; 45 import java.io.FileOutputStream; 46 47 50 public class OrderBean implements MessageDrivenBean, MessageListener { 51 52 private transient MessageDrivenContext mdbContext; 53 54 String filename = null; 55 56 60 63 public OrderBean() { 64 } 65 66 76 77 public void setMessageDrivenContext(MessageDrivenContext ctx) { 78 mdbContext = ctx; 79 Context initialContext = null; 80 if (filename == null) { 81 try { 82 initialContext = new InitialContext(); 83 filename = (String) initialContext.lookup("java:comp/env/orderfilename"); 85 } catch (Exception e) { 86 System.err.println("cannot lookup environment"); 87 } 88 } 89 } 90 91 99 public void ejbRemove() { 100 } 101 102 105 public void ejbCreate() { 106 } 107 108 111 public void onMessage(Message message) { 112 TextMessage msg = (TextMessage) message; 113 try { 114 File f = new File(System.getProperty("java.io.tmpdir") + File.separator + System.getProperty("user.name") 115 + "_" + filename); 116 DataOutputStream fileout = new DataOutputStream(new BufferedOutputStream(new FileOutputStream(f 117 .getCanonicalPath(), true))); 118 fileout.writeBytes(msg.getText() + System.getProperty("line.separator")); 119 fileout.close(); 120 } catch (Exception e) { 121 System.err.println("OrderBean onMessage Exception caught: " + e); 122 } 123 } 124 } | Popular Tags |