if (!ow.getOwner().equals(getCluster().getClusterIdentifier())) {
if (!ow.getOwner().equals(getClusterIdentifier())) {
  public synchronized void execute() {    if (oplanCoupons.hasChanged()) {      Collection adds = oplanCoupons.getAddedCollection();      if (adds != null) {	for (Iterator addIterator = adds.iterator(); addIterator.hasNext();) {	  OplanCoupon ow = (OplanCoupon) addIterator.next();	  // We shouldn't run the plugin in the same cluster where	  // the oplan is published, but if we do, just ignore the coupon	  if (!ow.getOwner().equals(getCluster().getClusterIdentifier())) {	    requestOplan(ow);	  }	}      }      // Don't be clever about changes for now, just get the whole thing again.      Collection changes = oplanCoupons.getChangedCollection();      if (changes != null) {	for (Iterator changeIterator = changes.iterator(); changeIterator.hasNext();) {	  OplanCoupon ow = (OplanCoupon) changeIterator.next();	  if (!ow.getOwner().equals(getCluster().getClusterIdentifier())) {	    requestOplan(ow);	  }	}      }      Collection deletes = oplanCoupons.getRemovedCollection();      if (deletes != null) {	for (Iterator delIterator = deletes.iterator(); delIterator.hasNext();) {	  OplanCoupon ow = (OplanCoupon) delIterator.next();	  if (!ow.getOwner().equals(getCluster().getClusterIdentifier())) {	    removeOplan(ow);	  }	}      }    }  }