[Beepcore-java-commits] CVS: beepcore-java/src/org/beepcore/beep/lib MessageQueue.java,1.4,1.5
Status: Beta
Brought to you by:
huston
From: Huston F. <hu...@us...> - 2002-10-05 15:31:22
|
Update of /cvsroot/beepcore-java/beepcore-java/src/org/beepcore/beep/lib In directory usw-pr-cvs1:/tmp/cvs-serv7461/src/org/beepcore/beep/lib Modified Files: MessageQueue.java Log Message: changed to use commons-logging Index: MessageQueue.java =================================================================== RCS file: /cvsroot/beepcore-java/beepcore-java/src/org/beepcore/beep/lib/MessageQueue.java,v retrieving revision 1.4 retrieving revision 1.5 diff -C2 -r1.4 -r1.5 *** MessageQueue.java 8 Nov 2001 05:51:34 -0000 1.4 --- MessageQueue.java 5 Oct 2002 15:31:19 -0000 1.5 *************** *** 3,6 **** --- 3,7 ---- * * Copyright (c) 2001 Invisible Worlds, Inc. All rights reserved. + * Copyright (c) 2002 Huston Franklin. All rights reserved. * * The contents of this file are subject to the Blocks Public License (the *************** *** 20,26 **** import java.util.LinkedList; import org.beepcore.beep.core.Message; import org.beepcore.beep.core.MessageListener; - import org.beepcore.beep.util.Log; --- 21,29 ---- import java.util.LinkedList; + import org.apache.commons.logging.Log; + import org.apache.commons.logging.LogFactory; + import org.beepcore.beep.core.Message; import org.beepcore.beep.core.MessageListener; *************** *** 41,44 **** --- 44,49 ---- public class MessageQueue implements MessageListener { + private Log log = LogFactory.getLog(this.getClass()); + private LinkedList queue = new LinkedList(); *************** *** 48,52 **** public Message getNextMessage() throws InterruptedException { ! Log.logEntry(Log.SEV_DEBUG_VERBOSE, "Entry"); synchronized (this) { if (queue.size() == 0) { --- 53,57 ---- public Message getNextMessage() throws InterruptedException { ! log.trace("getNextMessage: entry"); synchronized (this) { if (queue.size() == 0) { *************** *** 59,63 **** public void receiveMSG(Message message) { ! Log.logEntry(Log.SEV_DEBUG_VERBOSE, "Entry"); synchronized (this) { queue.addLast(message); --- 64,68 ---- public void receiveMSG(Message message) { ! log.trace("receiveMSG: entry"); synchronized (this) { queue.addLast(message); |