[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);
|