apache/cloudstack
1
0
Fork 0
mirror of https://github.com/apache/cloudstack.git synced 2025-10-26 08:42:29 +01:00
Code Issues Packages Projects Releases Wiki Activity

Changed tabs to space

Browse Source
This commit is contained in:
Alex Huang 2013-08-01 09:48:23 -07:00
parent 0b1f97d048
commit dd0536f9d3
1 changed files with 52 additions and 52 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

104
framework/ipc/src/org/apache/cloudstack/framework/messagebus/MessageDetector.java
View File

@ -19,57 +19,57 @@
package org.apache.cloudstack.framework.messagebus;
public class MessageDetector implements MessageSubscriber {
private MessageBus _messageBus;
private String[] _subjects;
private volatile boolean _signalled = false;
public MessageDetector() {
_messageBus = null;
_subjects = null;
}
public boolean waitAny(long timeoutInMiliseconds) {
_signalled = false;
synchronized(this) {
try {
wait(timeoutInMiliseconds);
} catch (InterruptedException e) {
}
}
return _signalled;
}
public void open(MessageBus messageBus, String[] subjects) {
assert(messageBus != null);
assert(subjects != null);
_messageBus = messageBus;
_subjects = subjects;
if(subjects != null) {
for(String subject : subjects) {
messageBus.subscribe(subject, this);
}
}
}
public void close() {
if(_subjects != null) {
assert(_messageBus != null);
for(String subject : _subjects) {
_messageBus.unsubscribe(subject, this);
}
}
}
@Override
public void onPublishMessage(String senderAddress, String subject, Object args) {
synchronized(this) {
_signalled = true;
notifyAll();
}
}
private MessageBus _messageBus;
private String[] _subjects;
private volatile boolean _signalled = false;
public MessageDetector() {
_messageBus = null;
_subjects = null;
}
public boolean waitAny(long timeoutInMiliseconds) {
_signalled = false;
synchronized (this) {
try {
wait(timeoutInMiliseconds);
} catch (InterruptedException e) {
}
}
return _signalled;
}
public void open(MessageBus messageBus, String[] subjects) {
assert (messageBus != null);
assert (subjects != null);
_messageBus = messageBus;
_subjects = subjects;
if (subjects != null) {
for (String subject : subjects) {
messageBus.subscribe(subject, this);
}
}
}
public void close() {
if (_subjects != null) {
assert (_messageBus != null);
for (String subject : _subjects) {
_messageBus.unsubscribe(subject, this);
}
}
}
@Override
public void onPublishMessage(String senderAddress, String subject, Object args) {
synchronized (this) {
_signalled = true;
notifyAll();
}
}
}