User: user57
Date: 02/02/14 22:15:55
Modified: src/main/org/jboss/test/mdb/bean BMPBean.java
ExQueueBean.java ObjectMessageBean.java
TXTimeOutBean.java
Log:
o replaced most System.out usage with Log4j. should really introduce
some base classes to make this mess more maintainable...
Revision Changes Path
1.2 +6 -4 jbosstest/src/main/org/jboss/test/mdb/bean/BMPBean.java
Index: BMPBean.java
===================================================================
RCS file: /cvsroot/jboss/jbosstest/src/main/org/jboss/test/mdb/bean/BMPBean.java,v
retrieving revision 1.1
retrieving revision 1.2
diff -u -r1.1 -r1.2
--- BMPBean.java 20 Sep 2001 05:22:19 -0000 1.1
+++ BMPBean.java 15 Feb 2002 06:15:54 -0000 1.2
@@ -40,6 +40,8 @@
*/
public class BMPBean implements MessageDrivenBean, MessageListener{
+ org.apache.log4j.Category log =
org.apache.log4j.Category.getInstance(getClass());
+
private MessageDrivenContext ctx = null;
public BMPBean() {
@@ -59,17 +61,17 @@
try {
TransactionManager tm = (TransactionManager)new
InitialContext().lookup("java:/TransactionManager");
Transaction threadTx = tm.suspend();
- System.out.println("DEBUG Tx="+threadTx);
+ log.debug("DEBUG Tx="+threadTx);
- System.out.println("Sleeping for 10 seconds");
+ log.debug("Sleeping for 10 seconds");
try { Thread.currentThread().sleep(1000*10);
} catch ( InterruptedException e ) {}
- System.out.println("Sleep done");
+ log.debug("Sleep done");
if( threadTx != null )
tm.resume(threadTx);
} catch (Exception e) {
- System.out.println("BMPBean Error:"+e);
+ log.debug("BMPBean Error:"+e);
}
}
}
1.3 +4 -3 jbosstest/src/main/org/jboss/test/mdb/bean/ExQueueBean.java
Index: ExQueueBean.java
===================================================================
RCS file:
/cvsroot/jboss/jbosstest/src/main/org/jboss/test/mdb/bean/ExQueueBean.java,v
retrieving revision 1.2
retrieving revision 1.3
diff -u -r1.2 -r1.3
--- ExQueueBean.java 30 Aug 2001 20:50:35 -0000 1.2
+++ ExQueueBean.java 15 Feb 2002 06:15:54 -0000 1.3
@@ -34,6 +34,9 @@
*/
public class ExQueueBean implements MessageDrivenBean, MessageListener{
+
+ org.apache.log4j.Category log =
org.apache.log4j.Category.getInstance(getClass());
+
private MessageDrivenContext ctx = null;
public ExQueueBean() {
@@ -48,10 +51,8 @@
public void ejbRemove() {ctx=null;}
public void onMessage(Message message) {
-
- System.err.println("DEBUG: ExQueueBean rolling back transaction" +
message.toString() );
+ log.debug("ExQueueBean rolling back transaction" + message.toString());
ctx.setRollbackOnly();
-
}
} // MessageBeanImpl
1.2 +2 -0
jbosstest/src/main/org/jboss/test/mdb/bean/ObjectMessageBean.java
Index: ObjectMessageBean.java
===================================================================
RCS file:
/cvsroot/jboss/jbosstest/src/main/org/jboss/test/mdb/bean/ObjectMessageBean.java,v
retrieving revision 1.1
retrieving revision 1.2
diff -u -r1.1 -r1.2
--- ObjectMessageBean.java 21 Feb 2001 05:07:46 -0000 1.1
+++ ObjectMessageBean.java 15 Feb 2002 06:15:54 -0000 1.2
@@ -34,6 +34,8 @@
*/
public class ObjectMessageBean implements MessageDrivenBean, MessageListener{
+ org.apache.log4j.Category log =
org.apache.log4j.Category.getInstance(getClass());
+
private MessageDrivenContext ctx = null;
public ObjectMessageBean() {
1.2 +4 -2 jbosstest/src/main/org/jboss/test/mdb/bean/TXTimeOutBean.java
Index: TXTimeOutBean.java
===================================================================
RCS file:
/cvsroot/jboss/jbosstest/src/main/org/jboss/test/mdb/bean/TXTimeOutBean.java,v
retrieving revision 1.1
retrieving revision 1.2
diff -u -r1.1 -r1.2
--- TXTimeOutBean.java 9 Nov 2001 23:32:36 -0000 1.1
+++ TXTimeOutBean.java 15 Feb 2002 06:15:54 -0000 1.2
@@ -23,6 +23,8 @@
public class TXTimeOutBean implements MessageDrivenBean, MessageListener{
+ org.apache.log4j.Category log =
org.apache.log4j.Category.getInstance(getClass());
+
long PROCESSING_DELAY = 10; // simulate 10 seconds of processing
public void setMessageDrivenContext(MessageDrivenContext ctx) {}
@@ -31,9 +33,9 @@
public void onMessage(Message message) {
try {
- System.out.println("Simulating "+PROCESSING_DELAY+" second(s)
of message processing ");
+ log.debug("Simulating "+PROCESSING_DELAY+" second(s) of
message processing ");
Thread.sleep(PROCESSING_DELAY*1000);
- System.out.println("Message processing simulation done.");
+ log.debug("Message processing simulation done.");
} catch (Throwable ignore) {}
}
}
_______________________________________________
Jboss-development mailing list
[EMAIL PROTECTED]
https://lists.sourceforge.net/lists/listinfo/jboss-development
