diff --git a/cat-consumer/src/main/java/com/dianping/cat/consumer/RealtimeConsumer.java b/cat-consumer/src/main/java/com/dianping/cat/consumer/RealtimeConsumer.java
index 884173efd9af477f487588638b7422849746cd37..3f202871bae68a46cc100e43b8f959554bd7655a 100644
--- a/cat-consumer/src/main/java/com/dianping/cat/consumer/RealtimeConsumer.java
+++ b/cat-consumer/src/main/java/com/dianping/cat/consumer/RealtimeConsumer.java
@@ -182,6 +182,7 @@ public class RealtimeConsumer extends ContainerHolder implements MessageConsumer
 				MessageQueue queue = lookup(MessageQueue.class);
 				PeriodTask task = new PeriodTask(m_factory, analyzer, queue, startTime);
 
+				task.enableLogging(m_logger);
 				m_tasks.add(task);
 			}
 		}
diff --git a/cat-consumer/src/main/java/com/dianping/cat/consumer/transaction/TransactionAnalyzer.java b/cat-consumer/src/main/java/com/dianping/cat/consumer/transaction/TransactionAnalyzer.java
index 586eb16ee260e07bf4a1c83288579480eaccfd2a..bfbe333623e53e0a0d4414d6298461ea795d749f 100644
--- a/cat-consumer/src/main/java/com/dianping/cat/consumer/transaction/TransactionAnalyzer.java
+++ b/cat-consumer/src/main/java/com/dianping/cat/consumer/transaction/TransactionAnalyzer.java
@@ -266,7 +266,6 @@ public class TransactionAnalyzer extends AbstractMessageAnalyzer<TransactionRepo
 				String ip = NetworkInterfaceManager.INSTANCE.getLocalHostAddress();
 
 				for (TransactionReport report : m_reports.values()) {
-
 					Report r = m_reportDao.createLocal();
 					String xml = builder.buildXml(report);
 					String domain = report.getDomain();
diff --git a/pom.xml b/pom.xml
index 5a5da57adefcb197cf962e301c94d4e35808aeb5..701791d1cec898f249518b5df8e0e0a4abd5d76a 100644
--- a/pom.xml
+++ b/pom.xml
@@ -69,7 +69,7 @@
 			<dependency>
 				<groupId>com.site.dal</groupId>
 				<artifactId>dal-jdbc</artifactId>
-				<version>1.0.2</version>
+				<version>1.0.3</version>
 			</dependency>
 			<dependency>
 				<groupId>com.site.app</groupId>