You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ch...@apache.org on 2012/09/27 13:39:36 UTC
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...
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>