summaryrefslogtreecommitdiff
path: root/java/demo/Ice/async/Consumer.java
diff options
context:
space:
mode:
authorDwayne Boone <dwayne@zeroc.com>2006-11-20 18:56:45 +0000
committerDwayne Boone <dwayne@zeroc.com>2006-11-20 18:56:45 +0000
commitf2e8145bedb5464d4b755b5efd9348721532cafc (patch)
tree3e4aa8c0a1952a24cca4378a808e8e5795e329d4 /java/demo/Ice/async/Consumer.java
parentant tasks check the ice.dir property that may be set in the XML (diff)
downloadice-f2e8145bedb5464d4b755b5efd9348721532cafc.tar.bz2
ice-f2e8145bedb5464d4b755b5efd9348721532cafc.tar.xz
ice-f2e8145bedb5464d4b755b5efd9348721532cafc.zip
Added break
Diffstat (limited to 'java/demo/Ice/async/Consumer.java')
-rw-r--r--java/demo/Ice/async/Consumer.java9
1 files changed, 4 insertions, 5 deletions
diff --git a/java/demo/Ice/async/Consumer.java b/java/demo/Ice/async/Consumer.java
index 2d441b241d2..288742dfbc1 100644
--- a/java/demo/Ice/async/Consumer.java
+++ b/java/demo/Ice/async/Consumer.java
@@ -17,7 +17,7 @@ public class Consumer extends Ice.Application
{
_id = id;
- synchronized(_requestMutex)
+ synchronized(_requests)
{
_requests.add(id);
}
@@ -25,7 +25,7 @@ public class Consumer extends Ice.Application
public void ice_response(String message)
{
- synchronized(_requestMutex)
+ synchronized(_requests)
{
_requests.remove(_id);
}
@@ -35,7 +35,7 @@ public class Consumer extends Ice.Application
public void ice_exception(Ice.LocalException ex)
{
- synchronized(_requestMutex)
+ synchronized(_requests)
{
_requests.remove(_id);
}
@@ -129,7 +129,7 @@ public class Consumer extends Ice.Application
}
while(!line.equals("x"));
- synchronized(_requestMutex)
+ synchronized(_requests)
{
if(_requests.size() != 0)
{
@@ -155,6 +155,5 @@ public class Consumer extends Ice.Application
System.exit(status);
}
- private java.lang.Object _requestMutex = new java.lang.Object();
private java.util.HashSet _requests = new java.util.HashSet();
}