new String(getQueueMeta.getQueueName()) + ": " + e.getMessage());
return null; // TODO execute() must be able to return an error
}
}
@Override
<BUG>synchronized</BUG>
public void execute(ClearFabric clearFabric) {
<BUG>try {
Log.debug("Received " + clearFabric);
TClearFabric tClearFabric = wrap(clearFabric);
Log.debug("Sending " + tClearFabric);</BUG>
client.clearFabric(tClearFabric);

new String(getQueueMeta.getQueueName()) + ": " + e.getMessage());
return null; // TODO execute() must be able to return an error
}
}
@Override
public void execute(ClearFabric clearFabric) {
try {
if (Log.isDebugEnabled())
Log.debug("Received " + clearFabric);
TClearFabric tClearFabric = wrap(clearFabric);
if (Log.isDebugEnabled())
Log.debug("Sending " + tClearFabric);
client.clearFabric(tClearFabric);
