/****************************************************************************** * Copyright (C) 2012 Heng Sin Low * * Copyright (C) 2012 Trek Global * * This program is free software; you can redistribute it and/or modify it * * under the terms version 2 of the GNU General Public License as published * * by the Free Software Foundation. This program is distributed in the hope * * that it will be useful, but WITHOUT ANY WARRANTY; without even the implied * * warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. * * See the GNU General Public License for more details. * * You should have received a copy of the GNU General Public License along * * with this program; if not, write to the Free Software Foundation, Inc., * * 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA. * *****************************************************************************/ package org.compiere.util; import java.io.Serializable; import java.util.concurrent.Callable; /** * Callable to reset distributed cache nodes * @author hengsin */ public class ResetCacheCallable implements Callable, Serializable { /** * generated serial id */ private static final long serialVersionUID = 6669645804211785491L; private String tableName; private Integer Record_ID; private String key; /** * @param tableName * @param key */ public ResetCacheCallable(String tableName, String key) { this.tableName = tableName; this.key = key; } /** * @param tableName * @param Record_ID */ public ResetCacheCallable(String tableName, int Record_ID) { this.tableName = tableName; this.Record_ID = Record_ID; } /** * Reset cache of local cache nodes */ @Override public Integer call() throws Exception { return Record_ID != null ? CacheMgt.get().resetLocalCache(tableName, Record_ID) : CacheMgt.get().resetLocalCache(tableName, key); } }