summaryrefslogtreecommitdiff
path: root/java/client/example
diff options
context:
space:
mode:
authorArnaud Simon <arnaudsimon@apache.org>2007-12-07 12:42:26 +0000
committerArnaud Simon <arnaudsimon@apache.org>2007-12-07 12:42:26 +0000
commitca66500163060045415ddd53ccc2642ef1374bc8 (patch)
tree005c3f8594600568526c3fd4ee223a26c88138ec /java/client/example
parent424d95e4579f5d0baceb8358aa4be347929ba33f (diff)
downloadqpid-python-ca66500163060045415ddd53ccc2642ef1374bc8.tar.gz
Removed log4j deps
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@602084 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/client/example')
-rw-r--r--java/client/example/src/main/java/org/apache/qpid/example/log4j.xml2
-rw-r--r--java/client/example/src/main/java/org/apache/qpid/example/publisher/FileMessageDispatcher.java5
-rw-r--r--java/client/example/src/main/java/org/apache/qpid/example/publisher/MonitorMessageDispatcher.java9
-rw-r--r--java/client/example/src/main/java/org/apache/qpid/example/publisher/MonitorPublisher.java9
-rw-r--r--java/client/example/src/main/java/org/apache/qpid/example/publisher/Publisher.java10
-rw-r--r--java/client/example/src/main/java/org/apache/qpid/example/shared/InitialContextHelper.java5
-rw-r--r--java/client/example/src/main/java/org/apache/qpid/example/subscriber/MonitoredSubscriber.java6
-rw-r--r--java/client/example/src/main/java/org/apache/qpid/example/subscriber/MonitoredSubscriptionWrapper.java6
-rw-r--r--java/client/example/src/main/java/org/apache/qpid/example/subscriber/Subscriber.java5
-rw-r--r--java/client/example/src/main/java/org/apache/qpid/example/subscriber/SubscriptionWrapper.java5
10 files changed, 28 insertions, 34 deletions
diff --git a/java/client/example/src/main/java/org/apache/qpid/example/log4j.xml b/java/client/example/src/main/java/org/apache/qpid/example/log4j.xml
index de64423a51..3465e75611 100644
--- a/java/client/example/src/main/java/org/apache/qpid/example/log4j.xml
+++ b/java/client/example/src/main/java/org/apache/qpid/example/log4j.xml
@@ -38,7 +38,7 @@
</appender>
<root>
- <priority value="debug"/>
+ <priority value="info"/>
<appender-ref ref="STDOUT"/>
<appender-ref ref="FileAppender"/>
</root>
diff --git a/java/client/example/src/main/java/org/apache/qpid/example/publisher/FileMessageDispatcher.java b/java/client/example/src/main/java/org/apache/qpid/example/publisher/FileMessageDispatcher.java
index 6a7626c51d..1849f733e9 100644
--- a/java/client/example/src/main/java/org/apache/qpid/example/publisher/FileMessageDispatcher.java
+++ b/java/client/example/src/main/java/org/apache/qpid/example/publisher/FileMessageDispatcher.java
@@ -24,10 +24,11 @@ import java.io.File;
import javax.jms.JMSException;
-import org.apache.log4j.Logger;
import org.apache.qpid.example.shared.FileUtils;
import org.apache.qpid.example.shared.Statics;
+import org.slf4j.LoggerFactory;
+import org.slf4j.Logger;
/**
* Class that sends message files to the Publisher to distribute
@@ -37,7 +38,7 @@ import org.apache.qpid.example.shared.Statics;
public class FileMessageDispatcher
{
- protected static final Logger _logger = Logger.getLogger(FileMessageDispatcher.class);
+ protected static final Logger _logger = LoggerFactory.getLogger(FileMessageDispatcher.class);
protected static Publisher _publisher = null;
diff --git a/java/client/example/src/main/java/org/apache/qpid/example/publisher/MonitorMessageDispatcher.java b/java/client/example/src/main/java/org/apache/qpid/example/publisher/MonitorMessageDispatcher.java
index 8c51f61522..3d16e01af4 100644
--- a/java/client/example/src/main/java/org/apache/qpid/example/publisher/MonitorMessageDispatcher.java
+++ b/java/client/example/src/main/java/org/apache/qpid/example/publisher/MonitorMessageDispatcher.java
@@ -18,8 +18,9 @@
*/
package org.apache.qpid.example.publisher;
-import org.apache.log4j.BasicConfigurator;
-import org.apache.log4j.Logger;
+
+import org.slf4j.LoggerFactory;
+import org.slf4j.Logger;
import javax.jms.DeliveryMode;
import javax.jms.JMSException;
@@ -31,7 +32,7 @@ import javax.jms.JMSException;
public class MonitorMessageDispatcher
{
- private static final Logger _logger = Logger.getLogger(MonitorMessageDispatcher.class);
+ private static final Logger _logger = LoggerFactory.getLogger(MonitorMessageDispatcher.class);
protected static MonitorPublisher _monitorPublisher = null;
@@ -46,8 +47,6 @@ public class MonitorMessageDispatcher
public static void main(String[] args)
{
//Switch on logging appropriately for your app
- BasicConfigurator.configure();
-
try
{
int i =0;
diff --git a/java/client/example/src/main/java/org/apache/qpid/example/publisher/MonitorPublisher.java b/java/client/example/src/main/java/org/apache/qpid/example/publisher/MonitorPublisher.java
index a67b602e58..750f57d9dc 100644
--- a/java/client/example/src/main/java/org/apache/qpid/example/publisher/MonitorPublisher.java
+++ b/java/client/example/src/main/java/org/apache/qpid/example/publisher/MonitorPublisher.java
@@ -18,8 +18,9 @@
*/
package org.apache.qpid.example.publisher;
-import org.apache.log4j.Logger;
import org.apache.qpid.client.BasicMessageProducer;
+import org.slf4j.LoggerFactory;
+import org.slf4j.Logger;
import javax.jms.DeliveryMode;
import javax.jms.JMSException;
@@ -33,7 +34,7 @@ import javax.jms.Session;
public class MonitorPublisher extends Publisher
{
- private static final Logger _log = Logger.getLogger(Publisher.class);
+ private static final Logger _log = LoggerFactory.getLogger(Publisher.class);
BasicMessageProducer _producer;
@@ -64,7 +65,7 @@ public class MonitorPublisher extends Publisher
catch (JMSException e)
{
//Have to assume our commit failed but do not rollback here as channel closed
- _log.error(e);
+ _log.error("JMSException", e);
e.printStackTrace();
throw new UndeliveredMessageException("Cannot deliver immediate message", e);
}
@@ -93,7 +94,7 @@ public class MonitorPublisher extends Publisher
catch (JMSException e)
{
//Have to assume our commit failed but do not rollback here as channel closed
- _log.error(e);
+ _log.error("JMSException", e);
e.printStackTrace();
throw new UndeliveredMessageException("Cannot deliver immediate message", e);
}
diff --git a/java/client/example/src/main/java/org/apache/qpid/example/publisher/Publisher.java b/java/client/example/src/main/java/org/apache/qpid/example/publisher/Publisher.java
index 2bde4ec35c..87fc543dbe 100644
--- a/java/client/example/src/main/java/org/apache/qpid/example/publisher/Publisher.java
+++ b/java/client/example/src/main/java/org/apache/qpid/example/publisher/Publisher.java
@@ -18,8 +18,6 @@
*/
package org.apache.qpid.example.publisher;
-import org.apache.log4j.Logger;
-
import org.apache.qpid.client.AMQConnectionFactory;
import javax.jms.JMSException;
@@ -33,10 +31,12 @@ import javax.jms.Session;
import javax.naming.InitialContext;
import org.apache.qpid.example.shared.InitialContextHelper;
+import org.slf4j.LoggerFactory;
+import org.slf4j.Logger;
public class Publisher
{
- private static final Logger _log = Logger.getLogger(Publisher.class);
+ private static final Logger _log = LoggerFactory.getLogger(Publisher.class);
protected InitialContextHelper _contextHelper;
@@ -88,7 +88,7 @@ public class Publisher
catch (Exception e)
{
e.printStackTrace();
- _log.error(e);
+ _log.error("Exception", e);
}
}
@@ -113,7 +113,7 @@ public class Publisher
try
{
_session.rollback();
- _log.error(e);
+ _log.error("JMSException", e);
e.printStackTrace();
return false;
}
diff --git a/java/client/example/src/main/java/org/apache/qpid/example/shared/InitialContextHelper.java b/java/client/example/src/main/java/org/apache/qpid/example/shared/InitialContextHelper.java
index 98a2c0d497..1328816602 100644
--- a/java/client/example/src/main/java/org/apache/qpid/example/shared/InitialContextHelper.java
+++ b/java/client/example/src/main/java/org/apache/qpid/example/shared/InitialContextHelper.java
@@ -27,7 +27,8 @@ import java.util.Properties;
import javax.naming.InitialContext;
import javax.naming.NamingException;
-import org.apache.log4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.slf4j.Logger;
/**
* Class that provides helper methods for JNDI
@@ -38,7 +39,7 @@ public class InitialContextHelper
public static final String _defaultPropertiesName = "example.properties";
protected static Properties _fileProperties;
protected static InitialContext _initialContext;
- protected static final Logger _log = Logger.getLogger(InitialContextHelper.class);
+ protected static final Logger _log = LoggerFactory.getLogger(InitialContextHelper.class);
public InitialContextHelper(String propertiesName) throws ContextException
{
diff --git a/java/client/example/src/main/java/org/apache/qpid/example/subscriber/MonitoredSubscriber.java b/java/client/example/src/main/java/org/apache/qpid/example/subscriber/MonitoredSubscriber.java
index 1d2e5e0e66..d43b823a13 100644
--- a/java/client/example/src/main/java/org/apache/qpid/example/subscriber/MonitoredSubscriber.java
+++ b/java/client/example/src/main/java/org/apache/qpid/example/subscriber/MonitoredSubscriber.java
@@ -18,11 +18,11 @@
*/
package org.apache.qpid.example.subscriber;
-import org.apache.log4j.Logger;
import org.apache.qpid.example.shared.Statics;
+import org.slf4j.LoggerFactory;
+import org.slf4j.Logger;
import javax.jms.*;
-
/**
* Subclass of Subscriber which consumes a heartbeat message
*/
@@ -31,7 +31,7 @@ public class MonitoredSubscriber extends Subscriber
{
protected String _monitorDestinationName;
- private static final Logger _logger = Logger.getLogger(MonitoredSubscriber.class);
+ private static final Logger _logger = LoggerFactory.getLogger(MonitoredSubscriber.class);
private static MessageConsumer _monitorConsumer;
diff --git a/java/client/example/src/main/java/org/apache/qpid/example/subscriber/MonitoredSubscriptionWrapper.java b/java/client/example/src/main/java/org/apache/qpid/example/subscriber/MonitoredSubscriptionWrapper.java
index d2f27da052..5e78107182 100644
--- a/java/client/example/src/main/java/org/apache/qpid/example/subscriber/MonitoredSubscriptionWrapper.java
+++ b/java/client/example/src/main/java/org/apache/qpid/example/subscriber/MonitoredSubscriptionWrapper.java
@@ -18,7 +18,6 @@
*/
package org.apache.qpid.example.subscriber;
-import org.apache.log4j.BasicConfigurator;
/**
* Allows you to simply start a monitored subscriber
@@ -32,10 +31,7 @@ public class MonitoredSubscriptionWrapper {
* @param args - no params required
*/
public static void main(String args[])
- {
- //switch on logging
- BasicConfigurator.configure();
-
+ {
_subscriber = new MonitoredSubscriber();
_subscriber.subscribe();
diff --git a/java/client/example/src/main/java/org/apache/qpid/example/subscriber/Subscriber.java b/java/client/example/src/main/java/org/apache/qpid/example/subscriber/Subscriber.java
index d443dca828..f2dd478121 100644
--- a/java/client/example/src/main/java/org/apache/qpid/example/subscriber/Subscriber.java
+++ b/java/client/example/src/main/java/org/apache/qpid/example/subscriber/Subscriber.java
@@ -18,7 +18,6 @@
*/
package org.apache.qpid.example.subscriber;
-import org.apache.log4j.Logger;
import org.apache.qpid.client.AMQConnectionFactory;
import javax.jms.*;
@@ -28,6 +27,8 @@ import javax.jms.Session;
import javax.naming.InitialContext;
import org.apache.qpid.example.shared.InitialContextHelper;
+import org.slf4j.LoggerFactory;
+import org.slf4j.Logger;
/**
* Subscriber which consumes messages from a queue
@@ -35,7 +36,7 @@ import org.apache.qpid.example.shared.InitialContextHelper;
public class Subscriber
{
- private static final Logger _log = Logger.getLogger(Subscriber.class);
+ private static final Logger _log = LoggerFactory.getLogger(Subscriber.class);
protected static Connection _connection;
diff --git a/java/client/example/src/main/java/org/apache/qpid/example/subscriber/SubscriptionWrapper.java b/java/client/example/src/main/java/org/apache/qpid/example/subscriber/SubscriptionWrapper.java
index 32a0ef685c..f8fbf63037 100644
--- a/java/client/example/src/main/java/org/apache/qpid/example/subscriber/SubscriptionWrapper.java
+++ b/java/client/example/src/main/java/org/apache/qpid/example/subscriber/SubscriptionWrapper.java
@@ -18,8 +18,6 @@
*/
package org.apache.qpid.example.subscriber;
-import org.apache.log4j.BasicConfigurator;
-
/**
* Allows you to simply start a subscriber
*/
@@ -33,9 +31,6 @@ public class SubscriptionWrapper {
*/
public static void main(String args[])
{
- //switch on logging
- BasicConfigurator.configure();
-
_subscriber = new Subscriber();
_subscriber.subscribe();