activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r1390949 - in /activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire: ./ jms-example-composite-destinations/src/main/java/example/composite/dest/ jms-example-durable-sub/src/main/java/example/topic/durable/ jms-exa...
Date Thu, 27 Sep 2012 11:39:36 GMT
Author: chirino
Date: Thu Sep 27 11:39:34 2012
New Revision: 1390949

URL: http://svn.apache.org/viewvc?rev=1390949&view=rev
Log:
Fixes APLO-263 : Remove slf4j from openwire examples

Applying Christian Posta's patch.  Thanks!

Modified:
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-composite-destinations/src/main/java/example/composite/dest/Consumer.java
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-composite-destinations/src/main/java/example/composite/dest/Producer.java
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-durable-sub/src/main/java/example/topic/durable/Publisher.java
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-durable-sub/src/main/java/example/topic/durable/Subscriber.java
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-exclusive-consumer/src/main/java/example/queue/exclusive/Consumer.java
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-exclusive-consumer/src/main/java/example/queue/exclusive/Producer.java
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-message-browser/src/main/java/example/browser/Browser.java
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-message-browser/src/main/java/example/browser/Producer.java
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-queue-selector/src/main/java/example/queue/selector/Consumer.java
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-queue-selector/src/main/java/example/queue/selector/Producer.java
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-queue/src/main/java/example/queue/Consumer.java
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-queue/src/main/java/example/queue/Producer.java
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-temp-destinations/src/main/java/example/tempdest/Consumer.java
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-temp-destinations/src/main/java/example/tempdest/ProducerRequestReply.java
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-topic/src/main/java/example/topic/Publisher.java
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-topic/src/main/java/example/topic/Subscriber.java
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-transaction/src/main/java/example/transaction/Client.java
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-wildcard-consumer/src/main/java/example/wildcard/Client.java
    activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/pom.xml

Modified: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-composite-destinations/src/main/java/example/composite/dest/Consumer.java
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-composite-destinations/src/main/java/example/composite/dest/Consumer.java?rev=1390949&r1=1390948&r2=1390949&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-composite-destinations/src/main/java/example/composite/dest/Consumer.java (original)
+++ activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-composite-destinations/src/main/java/example/composite/dest/Consumer.java Thu Sep 27 11:39:34 2012
@@ -18,8 +18,6 @@ package example.composite.dest;
 
 import example.util.Util;
 import org.apache.activemq.ActiveMQConnectionFactory;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
 
 import javax.jms.*;
 
@@ -28,7 +26,6 @@ import javax.jms.*;
  */
 public class Consumer {
 
-    private static final Logger LOG = LoggerFactory.getLogger(Consumer.class);
     private static final String BROKER_HOST = "tcp://localhost:%d";
     private static final int BROKER_PORT = Util.getBrokerPort();
     private static final String BROKER_URL = String.format(BROKER_HOST, BROKER_PORT);
@@ -36,7 +33,7 @@ public class Consumer {
     private static final long TIMEOUT = 20000;
 
     public static void main(String[] args) {
-        LOG.info("\nWaiting to receive messages... will timeout after " + TIMEOUT / 1000 +"s");
+        System.out.println("\nWaiting to receive messages... will timeout after " + TIMEOUT / 1000 +"s");
         ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("admin", "password", BROKER_URL);
         Connection connection = null;
 
@@ -63,7 +60,7 @@ public class Consumer {
                 if (message != null) {
                     if (message instanceof TextMessage) {
                         String text = ((TextMessage) message).getText();
-                        LOG.info("Got " + i++ + ". message on test-queue: " + text);
+                        System.out.println("Got " + i++ + ". message on test-queue: " + text);
                     }
                 } else {
                     break;
@@ -74,7 +71,7 @@ public class Consumer {
                 if (message != null) {
                     if (message instanceof TextMessage) {
                         String text = ((TextMessage) message).getText();
-                        LOG.info("Got " + i++ + ". message on test-queue-foo: " + text);
+                        System.out.println("Got " + i++ + ". message on test-queue-foo: " + text);
                     }
                 } else {
                     break;
@@ -85,7 +82,7 @@ public class Consumer {
                 if (message != null) {
                     if (message instanceof TextMessage) {
                         String text = ((TextMessage) message).getText();
-                        LOG.info("Got " + i++ + ". message on test-queue-bar: " + text);
+                        System.out.println("Got " + i++ + ". message on test-queue-bar: " + text);
                     }
                 } else {
                     break;
@@ -96,7 +93,7 @@ public class Consumer {
                 if (message != null) {
                     if (message instanceof TextMessage) {
                         String text = ((TextMessage) message).getText();
-                        LOG.info("Got " + i++ + ". message on test-topic-bar: " + text);
+                        System.out.println("Got " + i++ + ". message on test-topic-bar: " + text);
                     }
                 } else {
                     break;
@@ -108,14 +105,14 @@ public class Consumer {
             session.close();
 
         } catch (Exception e) {
-            LOG.error("Caught exception!", e);
+            System.out.println("Caught exception!");
         }
         finally {
             if (connection != null) {
                 try {
                     connection.close();
                 } catch (JMSException e) {
-                    LOG.error("Could not close an open connection...", e);
+                    System.out.println("Could not close an open connection...");
                 }
             }
         }

Modified: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-composite-destinations/src/main/java/example/composite/dest/Producer.java
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-composite-destinations/src/main/java/example/composite/dest/Producer.java?rev=1390949&r1=1390948&r2=1390949&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-composite-destinations/src/main/java/example/composite/dest/Producer.java (original)
+++ activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-composite-destinations/src/main/java/example/composite/dest/Producer.java Thu Sep 27 11:39:34 2012
@@ -18,8 +18,6 @@ package example.composite.dest;
 
 import example.util.Util;
 import org.apache.activemq.ActiveMQConnectionFactory;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
 
 import javax.jms.*;
 
@@ -27,7 +25,6 @@ import javax.jms.*;
  * @author <a href="http://www.christianposta.com/blog">Christian Posta</a>
  */
 public class Producer {
-    private static final Logger LOG = LoggerFactory.getLogger(Producer.class);
     private static final String BROKER_HOST = "tcp://localhost:%d";
     private static final int BROKER_PORT = Util.getBrokerPort();
     private static final String BROKER_URL = String.format(BROKER_HOST, BROKER_PORT);
@@ -51,7 +48,7 @@ public class Producer {
 
             for (int i = 0; i < NUM_MESSAGES_TO_SEND; i++) {
                 TextMessage message = session.createTextMessage("Message #" + i);
-                LOG.info("Sending message #" + i);
+                System.out.println("Sending message #" + i);
                 producer.send(message);
                 Thread.sleep(DELAY);
             }
@@ -60,14 +57,14 @@ public class Producer {
             session.close();
 
         } catch (Exception e) {
-            LOG.error("Caught exception!", e);
+            System.out.println("Caught exception!");
         }
         finally {
             if (connection != null) {
                 try {
                     connection.close();
                 } catch (JMSException e) {
-                    LOG.error("Could not close an open connection...", e);
+                    System.out.println("Could not close an open connection...");
                 }
             }
         }

Modified: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-durable-sub/src/main/java/example/topic/durable/Publisher.java
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-durable-sub/src/main/java/example/topic/durable/Publisher.java?rev=1390949&r1=1390948&r2=1390949&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-durable-sub/src/main/java/example/topic/durable/Publisher.java (original)
+++ activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-durable-sub/src/main/java/example/topic/durable/Publisher.java Thu Sep 27 11:39:34 2012
@@ -18,8 +18,6 @@ package example.topic.durable;
 
 import example.util.Util;
 import org.apache.activemq.ActiveMQConnectionFactory;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
 
 import javax.jms.*;
 
@@ -27,7 +25,6 @@ import javax.jms.*;
  * @author <a href="http://www.christianposta.com/blog">Christian Posta</a>
  */
 public class Publisher {
-    private static final Logger LOG = LoggerFactory.getLogger(Publisher.class);
     private static final String BROKER_HOST = "tcp://localhost:%d";
     private static final int BROKER_PORT = Util.getBrokerPort();
     private static final String BROKER_URL = String.format(BROKER_HOST, BROKER_PORT);
@@ -51,7 +48,7 @@ public class Publisher {
 
             for (int i = 0; i < NUM_MESSAGES_TO_SEND; i++) {
                 TextMessage message = session.createTextMessage("Message #" + i);
-                LOG.info("Sending message #" + i);
+                System.out.println("Sending message #" + i);
                 producer.send(message);
                 Thread.sleep(DELAY);
             }
@@ -63,14 +60,14 @@ public class Publisher {
             session.close();
 
         } catch (Exception e) {
-            LOG.error("Caught exception!", e);
+            System.out.println("Caught exception!");
         }
         finally {
             if (connection != null) {
                 try {
                     connection.close();
                 } catch (JMSException e) {
-                    LOG.error("Could not close an open connection...", e);
+                    System.out.println("Could not close an open connection...");
                 }
             }
         }

Modified: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-durable-sub/src/main/java/example/topic/durable/Subscriber.java
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-durable-sub/src/main/java/example/topic/durable/Subscriber.java?rev=1390949&r1=1390948&r2=1390949&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-durable-sub/src/main/java/example/topic/durable/Subscriber.java (original)
+++ activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-durable-sub/src/main/java/example/topic/durable/Subscriber.java Thu Sep 27 11:39:34 2012
@@ -18,8 +18,6 @@ package example.topic.durable;
 
 import example.util.Util;
 import org.apache.activemq.ActiveMQConnectionFactory;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
 
 import javax.jms.*;
 import java.util.concurrent.CountDownLatch;
@@ -28,7 +26,6 @@ import java.util.concurrent.CountDownLat
  * @author <a href="http://www.christianposta.com/blog">Christian Posta</a>
  */
 public class Subscriber implements MessageListener {
-    private static final Logger LOG = LoggerFactory.getLogger(Subscriber.class);
 
     private static final String BROKER_HOST = "tcp://localhost:%d";
     private static final int BROKER_PORT = Util.getBrokerPort();
@@ -42,7 +39,7 @@ public class Subscriber implements Messa
     }
 
     public static void main(String[] args) {
-        LOG.info("\nWaiting to receive messages... Either waiting for END message or press Ctrl+C to exit");
+        System.out.println("\nWaiting to receive messages... Either waiting for END message or press Ctrl+C to exit");
         ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("admin", "password", BROKER_URL);
         Connection connection = null;
         final CountDownLatch latch = new CountDownLatch(1);
@@ -66,14 +63,14 @@ public class Subscriber implements Messa
             session.close();
 
         } catch (Exception e) {
-            LOG.error("Caught exception!", e);
+            System.out.println("Caught exception!");
         }
         finally {
             if (connection != null) {
                 try {
                     connection.close();
                 } catch (JMSException e) {
-                    LOG.error("Could not close an open connection...", e);
+                    System.out.println("Could not close an open connection...");
                 }
             }
         }
@@ -85,15 +82,15 @@ public class Subscriber implements Messa
             if (message instanceof TextMessage) {
                 String text = ((TextMessage) message).getText();
                 if ("END".equalsIgnoreCase(text)) {
-                    LOG.info("Received END message!");
+                    System.out.println("Received END message!");
                     countDownLatch.countDown();
                 }
                 else {
-                    LOG.info("Received message:" +text);
+                    System.out.println("Received message:" +text);
                 }
             }
         } catch (JMSException e) {
-            LOG.error("Got a JMS Exception!", e);
+            System.out.println("Got a JMS Exception!");
         }
     }
 }

Modified: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-exclusive-consumer/src/main/java/example/queue/exclusive/Consumer.java
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-exclusive-consumer/src/main/java/example/queue/exclusive/Consumer.java?rev=1390949&r1=1390948&r2=1390949&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-exclusive-consumer/src/main/java/example/queue/exclusive/Consumer.java (original)
+++ activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-exclusive-consumer/src/main/java/example/queue/exclusive/Consumer.java Thu Sep 27 11:39:34 2012
@@ -18,8 +18,6 @@ package example.queue.exclusive;
 
 import example.util.Util;
 import org.apache.activemq.ActiveMQConnectionFactory;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
 
 import javax.jms.*;
 
@@ -28,7 +26,6 @@ import javax.jms.*;
  */
 public class Consumer {
 
-    private static final Logger LOG = LoggerFactory.getLogger(Consumer.class);
     private static final String BROKER_HOST = "tcp://localhost:%d";
     private static final int BROKER_PORT = Util.getBrokerPort();
     private static final String BROKER_URL = String.format(BROKER_HOST, BROKER_PORT);
@@ -36,7 +33,7 @@ public class Consumer {
     private static final long TIMEOUT = 20000;
 
     public static void main(String[] args) {
-        LOG.info("\nWaiting to receive messages... will timeout after " + TIMEOUT / 1000 +"s");
+        System.out.println("\nWaiting to receive messages... will timeout after " + TIMEOUT / 1000 +"s");
         ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("admin", "password", BROKER_URL);
         Connection connection = null;
 
@@ -56,7 +53,7 @@ public class Consumer {
                 if (message != null) {
                     if (message instanceof TextMessage) {
                         String text = ((TextMessage) message).getText();
-                        LOG.info("Got " + i++ + ". message: " + text);
+                        System.out.println("Got " + i++ + ". message: " + text);
                     }
                 } else {
                     break;
@@ -67,14 +64,14 @@ public class Consumer {
             session.close();
 
         } catch (Exception e) {
-            LOG.error("Caught exception!", e);
+            System.out.println("Caught exception!");
         }
         finally {
             if (connection != null) {
                 try {
                     connection.close();
                 } catch (JMSException e) {
-                    LOG.error("Could not close an open connection...", e);
+                    System.out.println("Could not close an open connection...");
                 }
             }
         }

Modified: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-exclusive-consumer/src/main/java/example/queue/exclusive/Producer.java
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-exclusive-consumer/src/main/java/example/queue/exclusive/Producer.java?rev=1390949&r1=1390948&r2=1390949&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-exclusive-consumer/src/main/java/example/queue/exclusive/Producer.java (original)
+++ activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-exclusive-consumer/src/main/java/example/queue/exclusive/Producer.java Thu Sep 27 11:39:34 2012
@@ -18,8 +18,6 @@ package example.queue.exclusive;
 
 import example.util.Util;
 import org.apache.activemq.ActiveMQConnectionFactory;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
 
 import javax.jms.*;
 
@@ -27,7 +25,6 @@ import javax.jms.*;
  * @author <a href="http://www.christianposta.com/blog">Christian Posta</a>
  */
 public class Producer {
-    private static final Logger LOG = LoggerFactory.getLogger(Producer.class);
     private static final String BROKER_HOST = "tcp://localhost:%d";
     private static final int BROKER_PORT = Util.getBrokerPort();
     private static final String BROKER_URL = String.format(BROKER_HOST, BROKER_PORT);
@@ -51,7 +48,7 @@ public class Producer {
 
             for (int i = 0; i < NUM_MESSAGES_TO_SEND; i++) {
                 TextMessage message = session.createTextMessage("Message #" + i);
-                LOG.info("Sending message #" + i);
+                System.out.println("Sending message #" + i);
                 producer.send(message);
                 Thread.sleep(DELAY);
             }
@@ -60,14 +57,14 @@ public class Producer {
             session.close();
 
         } catch (Exception e) {
-            LOG.error("Caught exception!", e);
+            System.out.println("Caught exception!");
         }
         finally {
             if (connection != null) {
                 try {
                     connection.close();
                 } catch (JMSException e) {
-                    LOG.error("Could not close an open connection...", e);
+                    System.out.println("Could not close an open connection...");
                 }
             }
         }

Modified: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-message-browser/src/main/java/example/browser/Browser.java
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-message-browser/src/main/java/example/browser/Browser.java?rev=1390949&r1=1390948&r2=1390949&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-message-browser/src/main/java/example/browser/Browser.java (original)
+++ activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-message-browser/src/main/java/example/browser/Browser.java Thu Sep 27 11:39:34 2012
@@ -18,8 +18,6 @@ package example.browser;
 
 import example.util.Util;
 import org.apache.activemq.ActiveMQConnectionFactory;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
 
 import javax.jms.*;
 import java.util.Enumeration;
@@ -29,7 +27,6 @@ import java.util.concurrent.TimeUnit;
  * @author <a href="http://www.christianposta.com/blog">Christian Posta</a>
  */
 public class Browser {
-    private static final Logger LOG = LoggerFactory.getLogger(Browser.class);
     private static final String BROKER_HOST = "tcp://localhost:%d";
     private static final int BROKER_PORT = Util.getBrokerPort();
     private static final String BROKER_URL = String.format(BROKER_HOST, BROKER_PORT);
@@ -60,14 +57,14 @@ public class Browser {
             session.close();
 
         } catch (Exception e) {
-            LOG.error("Caught exception!", e);
+            System.out.println("Caught exception!");
         }
         finally {
             if (connection != null) {
                 try {
                     connection.close();
                 } catch (JMSException e) {
-                    LOG.error("Could not close an open connection...", e);
+                    System.out.println("Could not close an open connection...");
                 }
             }
         }

Modified: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-message-browser/src/main/java/example/browser/Producer.java
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-message-browser/src/main/java/example/browser/Producer.java?rev=1390949&r1=1390948&r2=1390949&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-message-browser/src/main/java/example/browser/Producer.java (original)
+++ activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-message-browser/src/main/java/example/browser/Producer.java Thu Sep 27 11:39:34 2012
@@ -18,8 +18,6 @@ package example.browser;
 
 import example.util.Util;
 import org.apache.activemq.ActiveMQConnectionFactory;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
 
 import javax.jms.*;
 
@@ -27,7 +25,6 @@ import javax.jms.*;
  * @author <a href="http://www.christianposta.com/blog">Christian Posta</a>
  */
 public class Producer {
-    private static final Logger LOG = LoggerFactory.getLogger(Producer.class);
     private static final String BROKER_HOST = "tcp://localhost:%d";
     private static final int BROKER_PORT = Util.getBrokerPort();
     private static final String BROKER_URL = String.format(BROKER_HOST, BROKER_PORT);
@@ -51,7 +48,7 @@ public class Producer {
 
             for (int i = 0; i < NUM_MESSAGES_TO_SEND; i++) {
                 TextMessage message = session.createTextMessage("Message #" + i);
-                LOG.info("Sending message #" + i);
+                System.out.println("Sending message #" + i);
                 producer.send(message);
                 Thread.sleep(DELAY);
             }
@@ -60,14 +57,14 @@ public class Producer {
             session.close();
 
         } catch (Exception e) {
-            LOG.error("Caught exception!", e);
+            System.out.println("Caught exception!");
         }
         finally {
             if (connection != null) {
                 try {
                     connection.close();
                 } catch (JMSException e) {
-                    LOG.error("Could not close an open connection...", e);
+                    System.out.println("Could not close an open connection...");
                 }
             }
         }

Modified: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-queue-selector/src/main/java/example/queue/selector/Consumer.java
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-queue-selector/src/main/java/example/queue/selector/Consumer.java?rev=1390949&r1=1390948&r2=1390949&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-queue-selector/src/main/java/example/queue/selector/Consumer.java (original)
+++ activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-queue-selector/src/main/java/example/queue/selector/Consumer.java Thu Sep 27 11:39:34 2012
@@ -18,8 +18,6 @@ package example.queue.selector;
 
 import example.util.Util;
 import org.apache.activemq.ActiveMQConnectionFactory;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
 
 import javax.jms.*;
 
@@ -28,7 +26,6 @@ import javax.jms.*;
  */
 public class Consumer {
 
-    private static final Logger LOG = LoggerFactory.getLogger(Consumer.class);
     private static final String BROKER_HOST = "tcp://localhost:%d";
     private static final int BROKER_PORT = Util.getBrokerPort();
     private static final String BROKER_URL = String.format(BROKER_HOST, BROKER_PORT);
@@ -36,7 +33,7 @@ public class Consumer {
     private static final long TIMEOUT = 20000;
 
     public static void main(String[] args) {
-        LOG.info("\nWaiting to receive messages... will timeout after " + TIMEOUT / 1000 +"s");
+        System.out.println("\nWaiting to receive messages... will timeout after " + TIMEOUT / 1000 +"s");
         ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("admin", "password", BROKER_URL);
         Connection connection = null;
 
@@ -56,7 +53,7 @@ public class Consumer {
                 if (message != null) {
                     if (message instanceof TextMessage) {
                         String text = ((TextMessage) message).getText();
-                        LOG.info("Got " + i++ + ". message: " + text);
+                        System.out.println("Got " + i++ + ". message: " + text);
                     }
                 } else {
                     break;
@@ -67,14 +64,14 @@ public class Consumer {
             session.close();
 
         } catch (Exception e) {
-            LOG.error("Caught exception!", e);
+            System.out.println("Caught exception!");
         }
         finally {
             if (connection != null) {
                 try {
                     connection.close();
                 } catch (JMSException e) {
-                    LOG.error("Could not close an open connection...", e);
+                    System.out.println("Could not close an open connection...");
                 }
             }
         }

Modified: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-queue-selector/src/main/java/example/queue/selector/Producer.java
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-queue-selector/src/main/java/example/queue/selector/Producer.java?rev=1390949&r1=1390948&r2=1390949&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-queue-selector/src/main/java/example/queue/selector/Producer.java (original)
+++ activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-queue-selector/src/main/java/example/queue/selector/Producer.java Thu Sep 27 11:39:34 2012
@@ -18,8 +18,6 @@ package example.queue.selector;
 
 import example.util.Util;
 import org.apache.activemq.ActiveMQConnectionFactory;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
 
 import javax.jms.*;
 
@@ -27,7 +25,6 @@ import javax.jms.*;
  * @author <a href="http://www.christianposta.com/blog">Christian Posta</a>
  */
 public class Producer {
-    private static final Logger LOG = LoggerFactory.getLogger(Producer.class);
     private static final String BROKER_HOST = "tcp://localhost:%d";
     private static final int BROKER_PORT = Util.getBrokerPort();
     private static final String BROKER_URL = String.format(BROKER_HOST, BROKER_PORT);
@@ -51,12 +48,12 @@ public class Producer {
 
             for (int i = 0; i < NUM_MESSAGES_TO_SEND; i++) {
                 TextMessage message = session.createTextMessage("Message #" + i);
-                LOG.info("Sending message #" + i);
+                System.out.println("Sending message #" + i);
                 if (i % 2 == 0) {
-                    LOG.info("Sending to me");
+                    System.out.println("Sending to me");
                     message.setStringProperty("intended", "me");
                 } else {
-                    LOG.info("Sending to you");
+                    System.out.println("Sending to you");
                     message.setStringProperty("intended", "you");
                 }
                 producer.send(message);
@@ -67,14 +64,14 @@ public class Producer {
             session.close();
 
         } catch (Exception e) {
-            LOG.error("Caught exception!", e);
+            System.out.println("Caught exception!");
         }
         finally {
             if (connection != null) {
                 try {
                     connection.close();
                 } catch (JMSException e) {
-                    LOG.error("Could not close an open connection...", e);
+                    System.out.println("Could not close an open connection...");
                 }
             }
         }

Modified: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-queue/src/main/java/example/queue/Consumer.java
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-queue/src/main/java/example/queue/Consumer.java?rev=1390949&r1=1390948&r2=1390949&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-queue/src/main/java/example/queue/Consumer.java (original)
+++ activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-queue/src/main/java/example/queue/Consumer.java Thu Sep 27 11:39:34 2012
@@ -18,8 +18,6 @@ package example.queue;
 
 import example.util.Util;
 import org.apache.activemq.ActiveMQConnectionFactory;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
 
 import javax.jms.*;
 
@@ -28,7 +26,6 @@ import javax.jms.*;
  */
 public class Consumer {
 
-    private static final Logger LOG = LoggerFactory.getLogger(Consumer.class);
     private static final String BROKER_HOST = "tcp://localhost:%d";
     private static final int BROKER_PORT = Util.getBrokerPort();
     private static final String BROKER_URL = String.format(BROKER_HOST, BROKER_PORT);
@@ -36,7 +33,7 @@ public class Consumer {
     private static final long TIMEOUT = 20000;
 
     public static void main(String[] args) {
-        LOG.info("\nWaiting to receive messages... will timeout after " + TIMEOUT / 1000 +"s");
+        System.out.println("\nWaiting to receive messages... will timeout after " + TIMEOUT / 1000 +"s");
         ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("admin", "password", BROKER_URL);
         Connection connection = null;
 
@@ -56,7 +53,7 @@ public class Consumer {
                 if (message != null) {
                     if (message instanceof TextMessage) {
                         String text = ((TextMessage) message).getText();
-                        LOG.info("Got " + i++ + ". message: " + text);
+                        System.out.println("Got " + i++ + ". message: " + text);
                     }
                 } else {
                     break;
@@ -67,14 +64,14 @@ public class Consumer {
             session.close();
 
         } catch (Exception e) {
-            LOG.error("Caught exception!", e);
+            System.out.println("Caught exception!");
         }
         finally {
             if (connection != null) {
                 try {
                     connection.close();
                 } catch (JMSException e) {
-                    LOG.error("Could not close an open connection...", e);
+                    System.out.println("Could not close an open connection...");
                 }
             }
         }

Modified: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-queue/src/main/java/example/queue/Producer.java
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-queue/src/main/java/example/queue/Producer.java?rev=1390949&r1=1390948&r2=1390949&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-queue/src/main/java/example/queue/Producer.java (original)
+++ activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-queue/src/main/java/example/queue/Producer.java Thu Sep 27 11:39:34 2012
@@ -18,8 +18,6 @@ package example.queue;
 
 import example.util.Util;
 import org.apache.activemq.ActiveMQConnectionFactory;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
 
 import javax.jms.*;
 
@@ -27,7 +25,6 @@ import javax.jms.*;
  * @author <a href="http://www.christianposta.com/blog">Christian Posta</a>
  */
 public class Producer {
-    private static final Logger LOG = LoggerFactory.getLogger(Producer.class);
     private static final String BROKER_HOST = "tcp://localhost:%d";
     private static final int BROKER_PORT = Util.getBrokerPort();
     private static final String BROKER_URL = String.format(BROKER_HOST, BROKER_PORT);
@@ -51,7 +48,7 @@ public class Producer {
 
             for (int i = 0; i < NUM_MESSAGES_TO_SEND; i++) {
                 TextMessage message = session.createTextMessage("Message #" + i);
-                LOG.info("Sending message #" + i);
+                System.out.println("Sending message #" + i);
                 producer.send(message);
                 Thread.sleep(DELAY);
             }
@@ -60,14 +57,14 @@ public class Producer {
             session.close();
 
         } catch (Exception e) {
-            LOG.error("Caught exception!", e);
+            System.out.println("Caught exception!");
         }
         finally {
             if (connection != null) {
                 try {
                     connection.close();
                 } catch (JMSException e) {
-                    LOG.error("Could not close an open connection...", e);
+                    System.out.println("Could not close an open connection...");
                 }
             }
         }

Modified: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-temp-destinations/src/main/java/example/tempdest/Consumer.java
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-temp-destinations/src/main/java/example/tempdest/Consumer.java?rev=1390949&r1=1390948&r2=1390949&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-temp-destinations/src/main/java/example/tempdest/Consumer.java (original)
+++ activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-temp-destinations/src/main/java/example/tempdest/Consumer.java Thu Sep 27 11:39:34 2012
@@ -17,8 +17,6 @@ package example.tempdest; /**
 
 import example.util.Util;
 import org.apache.activemq.ActiveMQConnectionFactory;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
 
 import javax.jms.*;
 
@@ -26,7 +24,6 @@ import javax.jms.*;
  * @author <a href="http://www.christianposta.com/blog">Christian Posta</a>
  */
 public class Consumer {
-    private static final Logger LOG = LoggerFactory.getLogger(Consumer.class);
     private static final String BROKER_HOST = "tcp://localhost:%d";
     private static final int BROKER_PORT = Util.getBrokerPort();
     private static final String BROKER_URL = String.format(BROKER_HOST, BROKER_PORT);
@@ -34,7 +31,7 @@ public class Consumer {
     private static final long TIMEOUT = 20000;
 
     public static void main(String[] args) {
-        LOG.info("\nWaiting to receive messages... will timeout after " + TIMEOUT / 1000 +"s");
+        System.out.println("\nWaiting to receive messages... will timeout after " + TIMEOUT / 1000 +"s");
         ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("admin", "password", BROKER_URL);
         Connection connection = null;
 
@@ -54,7 +51,7 @@ public class Consumer {
                 if (message != null) {
                     if (message instanceof TextMessage) {
                         String text = ((TextMessage) message).getText();
-                        LOG.info("Got " + i++ + ". message: " + text);
+                        System.out.println("Got " + i++ + ". message: " + text);
                         Destination replyTo = message.getJMSReplyTo();
                         MessageProducer producer = session.createProducer(replyTo);
                         producer.send(session.createTextMessage("You made it to the consumer, here is your response"));
@@ -69,14 +66,14 @@ public class Consumer {
             session.close();
 
         } catch (Exception e) {
-            LOG.error("Caught exception!", e);
+            System.out.println("Caught exception!");
         }
         finally {
             if (connection != null) {
                 try {
                     connection.close();
                 } catch (JMSException e) {
-                    LOG.error("Could not close an open connection...", e);
+                    System.out.println("Could not close an open connection...");
                 }
             }
         }

Modified: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-temp-destinations/src/main/java/example/tempdest/ProducerRequestReply.java
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-temp-destinations/src/main/java/example/tempdest/ProducerRequestReply.java?rev=1390949&r1=1390948&r2=1390949&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-temp-destinations/src/main/java/example/tempdest/ProducerRequestReply.java (original)
+++ activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-temp-destinations/src/main/java/example/tempdest/ProducerRequestReply.java Thu Sep 27 11:39:34 2012
@@ -17,8 +17,6 @@ package example.tempdest; /**
 
 import example.util.Util;
 import org.apache.activemq.ActiveMQConnectionFactory;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
 
 import javax.jms.*;
 import java.util.concurrent.TimeUnit;
@@ -28,7 +26,6 @@ import java.util.concurrent.TimeUnit;
  */
 public class ProducerRequestReply{
 
-    private static final Logger LOG = LoggerFactory.getLogger(ProducerRequestReply.class);
     private static final String BROKER_HOST = "tcp://localhost:%d";
     private static final int BROKER_PORT = Util.getBrokerPort();
     private static final String BROKER_URL = String.format(BROKER_HOST, BROKER_PORT);
@@ -72,14 +69,14 @@ public class ProducerRequestReply{
             session.close();
 
         } catch (Exception e) {
-            LOG.error("Caught exception!", e);
+            System.out.println("Caught exception!");
         }
         finally {
             if (connection != null) {
                 try {
                     connection.close();
                 } catch (JMSException e) {
-                    LOG.error("Could not close an open connection...", e);
+                    System.out.println("Could not close an open connection...");
                 }
             }
         }

Modified: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-topic/src/main/java/example/topic/Publisher.java
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-topic/src/main/java/example/topic/Publisher.java?rev=1390949&r1=1390948&r2=1390949&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-topic/src/main/java/example/topic/Publisher.java (original)
+++ activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-topic/src/main/java/example/topic/Publisher.java Thu Sep 27 11:39:34 2012
@@ -18,8 +18,6 @@ package example.topic;
 
 import example.util.Util;
 import org.apache.activemq.ActiveMQConnectionFactory;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
 
 import javax.jms.*;
 
@@ -27,7 +25,6 @@ import javax.jms.*;
  * @author <a href="http://www.christianposta.com/blog">Christian Posta</a>
  */
 public class Publisher {
-    private static final Logger LOG = LoggerFactory.getLogger(Publisher.class);
     private static final String BROKER_HOST = "tcp://localhost:%d";
     private static final int BROKER_PORT = Util.getBrokerPort();
     private static final String BROKER_URL = String.format(BROKER_HOST, BROKER_PORT);
@@ -51,7 +48,7 @@ public class Publisher {
 
             for (int i = 0; i < NUM_MESSAGES_TO_SEND; i++) {
                 TextMessage message = session.createTextMessage("Message #" + i);
-                LOG.info("Sending message #" + i);
+                System.out.println("Sending message #" + i);
                 producer.send(message);
                 Thread.sleep(DELAY);
             }
@@ -63,14 +60,14 @@ public class Publisher {
             session.close();
 
         } catch (Exception e) {
-            LOG.error("Caught exception!", e);
+            System.out.println("Caught exception!");
         }
         finally {
             if (connection != null) {
                 try {
                     connection.close();
                 } catch (JMSException e) {
-                    LOG.error("Could not close an open connection...", e);
+                    System.out.println("Could not close an open connection...");
                 }
             }
         }

Modified: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-topic/src/main/java/example/topic/Subscriber.java
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-topic/src/main/java/example/topic/Subscriber.java?rev=1390949&r1=1390948&r2=1390949&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-topic/src/main/java/example/topic/Subscriber.java (original)
+++ activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-topic/src/main/java/example/topic/Subscriber.java Thu Sep 27 11:39:34 2012
@@ -18,8 +18,6 @@ package example.topic;
 
 import example.util.Util;
 import org.apache.activemq.ActiveMQConnectionFactory;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
 
 import javax.jms.*;
 import java.util.concurrent.CountDownLatch;
@@ -28,7 +26,6 @@ import java.util.concurrent.CountDownLat
  * @author <a href="http://www.christianposta.com/blog">Christian Posta</a>
  */
 public class Subscriber implements MessageListener {
-    private static final Logger LOG = LoggerFactory.getLogger(Subscriber.class);
 
     private static final String BROKER_HOST = "tcp://localhost:%d";
     private static final int BROKER_PORT = Util.getBrokerPort();
@@ -42,7 +39,7 @@ public class Subscriber implements Messa
     }
 
     public static void main(String[] args) {
-        LOG.info("\nWaiting to receive messages... Either waiting for END message or press Ctrl+C to exit");
+        System.out.println("\nWaiting to receive messages... Either waiting for END message or press Ctrl+C to exit");
         ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("admin", "password", BROKER_URL);
         Connection connection = null;
         final CountDownLatch latch = new CountDownLatch(1);
@@ -63,14 +60,14 @@ public class Subscriber implements Messa
             session.close();
 
         } catch (Exception e) {
-            LOG.error("Caught exception!", e);
+            System.out.println("Caught exception!");
         }
         finally {
             if (connection != null) {
                 try {
                     connection.close();
                 } catch (JMSException e) {
-                    LOG.error("Could not close an open connection...", e);
+                    System.out.println("Could not close an open connection...");
                 }
             }
         }
@@ -82,15 +79,15 @@ public class Subscriber implements Messa
             if (message instanceof TextMessage) {
                 String text = ((TextMessage) message).getText();
                 if ("END".equalsIgnoreCase(text)) {
-                    LOG.info("Received END message!");
+                    System.out.println("Received END message!");
                     countDownLatch.countDown();
                 }
                 else {
-                    LOG.info("Received message:" +text);
+                    System.out.println("Received message:" +text);
                 }
             }
         } catch (JMSException e) {
-            LOG.error("Got a JMS Exception!", e);
+            System.out.println("Got a JMS Exception!");
         }
     }
 }

Modified: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-transaction/src/main/java/example/transaction/Client.java
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-transaction/src/main/java/example/transaction/Client.java?rev=1390949&r1=1390948&r2=1390949&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-transaction/src/main/java/example/transaction/Client.java (original)
+++ activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-transaction/src/main/java/example/transaction/Client.java Thu Sep 27 11:39:34 2012
@@ -19,8 +19,6 @@ package example.transaction;
 import example.util.Util;
 import org.apache.activemq.ActiveMQConnectionFactory;
 import org.apache.activemq.command.ActiveMQTopic;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
 
 import javax.jms.*;
 import java.util.Scanner;
@@ -29,7 +27,6 @@ import java.util.Scanner;
  * @author <a href="http://www.christianposta.com/blog">Christian Posta</a>
  */
 public class Client {
-    private static final Logger LOG = LoggerFactory.getLogger(Client.class);
     private static final String BROKER_HOST = "tcp://localhost:%d";
     private static final int BROKER_PORT = Util.getBrokerPort();
     private static final String BROKER_URL = String.format(BROKER_HOST, BROKER_PORT);
@@ -57,9 +54,9 @@ public class Client {
                     if (message instanceof TextMessage) {
                         try {
                             String value = ((TextMessage) message).getText();
-                            LOG.info("We received a new message: " + value);
+                            System.out.println("We received a new message: " + value);
                         } catch (JMSException e) {
-                            LOG.error("Could not read the receiver's topic because of a JMSException", e);
+                            System.out.println("Could not read the receiver's topic because of a JMSException");
                         }
                     }
                 }
@@ -74,14 +71,14 @@ public class Client {
             receiverSession.close();
 
         } catch (Exception e) {
-            LOG.error("Caught exception!", e);
+            System.out.println("Caught exception!");
         }
         finally {
             if (connection != null) {
                 try {
                     connection.close();
                 } catch (JMSException e) {
-                    LOG.error("Could not close an open connection...", e);
+                    System.out.println("Could not close an open connection...");
                 }
             }
         }
@@ -94,7 +91,7 @@ public class Client {
         while (true) {
             String line = inputReader.nextLine();
             if (line == null) {
-                LOG.info("Done!");
+                System.out.println("Done!");
                 break;
             } else if (line.length() > 0) {
                 if (line.trim().equals("ROLLBACK")) {

Modified: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-wildcard-consumer/src/main/java/example/wildcard/Client.java
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-wildcard-consumer/src/main/java/example/wildcard/Client.java?rev=1390949&r1=1390948&r2=1390949&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-wildcard-consumer/src/main/java/example/wildcard/Client.java (original)
+++ activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-wildcard-consumer/src/main/java/example/wildcard/Client.java Thu Sep 27 11:39:34 2012
@@ -19,8 +19,6 @@ package example.wildcard;
 import example.util.Util;
 import org.apache.activemq.ActiveMQConnectionFactory;
 import org.apache.activemq.command.ActiveMQTopic;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
 
 import javax.jms.*;
 import java.util.Scanner;
@@ -29,7 +27,6 @@ import java.util.Scanner;
  * @author <a href="http://www.christianposta.com/blog">Christian Posta</a>
  */
 public class Client {
-    private static final Logger LOG = LoggerFactory.getLogger(Client.class);
     private static final Boolean NON_TRANSACTED = false;
     private static final String BROKER_HOST = "tcp://localhost:%d";
     private static final int BROKER_PORT = Util.getBrokerPort();
@@ -60,10 +57,10 @@ public class Client {
                     try {
                         if (message instanceof TextMessage) {
                             String text = ((TextMessage) message).getText();
-                            LOG.info("We received a new message: " + text);
+                            System.out.println("We received a new message: " + text);
                         }
                     } catch (JMSException e) {
-                        LOG.error("Could not read the receiver's topic because of a JMSException", e);
+                        System.out.println("Could not read the receiver's topic because of a JMSException");
                     }
                 }
             });
@@ -77,16 +74,16 @@ public class Client {
             while (true) {
                 String line = inputReader.nextLine();
                 if (line == null) {
-                    LOG.info("Done!");
+                    System.out.println("Done!");
                     break;
                 } else if (line.length() > 0) {
                     try {
                         TextMessage message = senderSession.createTextMessage();
                         message.setText(line);
-                        LOG.info("Sending a message: " + message.getText());
+                        System.out.println("Sending a message: " + message.getText());
                         sender.send(message);
                     } catch (JMSException e) {
-                        LOG.error("Exception during publishing a message: ", e);
+                        System.out.println("Exception during publishing a message: ");
                     }
                 }
             }
@@ -97,13 +94,13 @@ public class Client {
             senderSession.close();
 
         } catch (Exception e) {
-            LOG.error("Caught exception!", e);
+            System.out.println("Caught exception!");
         } finally {
             if (connection != null) {
                 try {
                     connection.close();
                 } catch (JMSException e) {
-                    LOG.error("When trying to close connection: ", e);
+                    System.out.println("When trying to close connection: ");
                 }
             }
         }

Modified: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/pom.xml
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/pom.xml?rev=1390949&r1=1390948&r2=1390949&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/pom.xml (original)
+++ activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/pom.xml Thu Sep 27 11:39:34 2012
@@ -38,7 +38,7 @@
         <module>jms-example-composite-destinations</module>
     </modules>
 
-    <name>OpenWire example</name>
+    <name>JMS / OpeWire Examples for Apollo</name>
     <description>Apollo OpenWire Java Examples</description>
 
     <properties>
@@ -64,11 +64,6 @@
             <artifactId>activemq-core</artifactId>
             <version>${activemq.version}</version>
         </dependency>
-        <dependency>
-            <groupId>org.slf4j</groupId>
-            <artifactId>slf4j-log4j12</artifactId>
-            <version>1.6.4</version>
-        </dependency>
     </dependencies>
 
     <build>



Mime
View raw message