View Javadoc

1   /*
2    *  Licensed to the Apache Software Foundation (ASF) under one or more
3    *  contributor license agreements.  See the NOTICE file distributed with
4    *  this work for additional information regarding copyright ownership.
5    *  The ASF licenses this file to You under the Apache License, Version 2.0
6    *  (the "License"); you may not use this file except in compliance with
7    *  the License.  You may obtain a copy of the License at
8    *
9    *       http://www.apache.org/licenses/LICENSE-2.0
10   *
11   *  Unless required by applicable law or agreed to in writing, software
12   *  distributed under the License is distributed on an "AS IS" BASIS,
13   *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14   *  See the License for the specific language governing permissions and
15   *  limitations under the License.
16   */
17  package org.apache.geronimo.samples.order;
18  
19  import java.io.BufferedWriter;
20  import java.io.File;
21  import java.io.FileWriter;
22  import java.io.IOException;
23  import java.util.Date;
24  
25  import javax.annotation.Resource;
26  import javax.ejb.MessageDriven;
27  import javax.ejb.ActivationConfigProperty;
28  import javax.ejb.EJBException;
29  import javax.ejb.MessageDrivenBean;
30  import javax.ejb.MessageDrivenContext;
31  import javax.jms.JMSException;
32  import javax.jms.Message;
33  import javax.jms.MessageListener;
34  import javax.jms.TextMessage;
35  
36  //
37  // MessageDrivenBean that listens to items on the
38  // 'OrderQueue' queue and processes them accordingly.
39  //
40  @MessageDriven(activationConfig = {
41                     @ActivationConfigProperty(propertyName="destinationType", propertyValue="javax.jms.Queue"),
42                     @ActivationConfigProperty(propertyName="destination", propertyValue="OrderQueue")
43                 })
44  public class OrderRecvMDB implements MessageListener {
45  
46      private static final String ORDER_MGMT_INFO = "order_mgmt.properties";
47      private static final String ORDER_REPO = "order.repo";
48  
49      public OrderRecvMDB() {
50  
51      }
52  
53      /*
54       * Process a message. <br>
55       * 
56       * @param message The message to process. 
57       */
58      public void onMessage(Message message) {
59          TextMessage textMessage = (TextMessage) message;
60          try {
61              System.out.println("Order Received \n"+ textMessage.getText());
62          }
63          catch ( JMSException e ) {
64              e.printStackTrace();
65          }
66      }
67  }