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.logging.log4j.core.net;
18  
19  import javax.jms.JMSException;
20  import javax.jms.Queue;
21  import javax.jms.QueueConnection;
22  import javax.jms.QueueConnectionFactory;
23  import javax.jms.QueueReceiver;
24  import javax.jms.QueueSession;
25  import javax.jms.Session;
26  import javax.naming.Context;
27  import javax.naming.InitialContext;
28  import javax.naming.NamingException;
29  import java.io.BufferedReader;
30  import java.io.InputStreamReader;
31  
32  /**
33   * Receives Log Events over a JMS Queue. This implementation expects that all messages will
34   * contain a serialized LogEvent.
35   */
36  public class JMSQueueReceiver extends AbstractJMSReceiver {
37  
38      /**
39       * Constructor.
40       * @param qcfBindingName The QueueConnectionFactory binding name.
41       * @param queueBindingName The Queue binding name.
42       * @param username The userid to connect to the queue.
43       * @param password The password to connect to the queue.
44       */
45      public JMSQueueReceiver(String qcfBindingName, String queueBindingName, String username, String password) {
46  
47          try {
48              Context ctx = new InitialContext();
49              QueueConnectionFactory queueConnectionFactory;
50              queueConnectionFactory = (QueueConnectionFactory) lookup(ctx, qcfBindingName);
51              QueueConnection queueConnection = queueConnectionFactory.createQueueConnection(username, password);
52              queueConnection.start();
53              QueueSession queueSession = queueConnection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
54              Queue queue = (Queue) ctx.lookup(queueBindingName);
55              QueueReceiver queueReceiver = queueSession.createReceiver(queue);
56              queueReceiver.setMessageListener(this);
57          } catch (JMSException e) {
58              logger.error("Could not read JMS message.", e);
59          } catch (NamingException e) {
60              logger.error("Could not read JMS message.", e);
61          } catch (RuntimeException e) {
62              logger.error("Could not read JMS message.", e);
63          }
64      }
65  
66      /**
67       * Main startup for the receiver.
68       * @param args The command line arguments.
69       * @throws Exception if an error occurs.
70       */
71      public static void main(String[] args) throws Exception {
72          if (args.length != 4) {
73              usage("Wrong number of arguments.");
74          }
75  
76          String qcfBindingName = args[0];
77          String queueBindingName = args[1];
78          String username = args[2];
79          String password = args[3];
80  
81          new JMSQueueReceiver(qcfBindingName, queueBindingName, username, password);
82  
83          BufferedReader stdin = new BufferedReader(new InputStreamReader(System.in));
84          // Loop until the word "exit" is typed
85          System.out.println("Type \"exit\" to quit JMSQueueReceiver.");
86          while (true) {
87              String s = stdin.readLine();
88              if (s.equalsIgnoreCase("exit")) {
89                  System.out.println("Exiting. Kill the application if it does not exit "
90                      + "due to daemon threads.");
91                  return;
92              }
93          }
94      }
95  
96  
97      private static void usage(String msg) {
98          System.err.println(msg);
99          System.err.println("Usage: java " + JMSQueueReceiver.class.getName()
100             + " QueueConnectionFactoryBindingName QueueBindingName username password");
101         System.exit(1);
102     }
103 }