private Record getRemoveWatchesRequest(int opCode, WatcherType watcherType, final String serverPath) { Record request = null; switch (opCode) { case ZooDefs.OpCode.checkWatches: CheckWatchesRequest chkReq = new CheckWatchesRequest(); chkReq.setPath(serverPath); chkReq.setType(watcherType.getIntValue()); request = chkReq; break; case ZooDefs.OpCode.removeWatches: RemoveWatchesRequest rmReq = new RemoveWatchesRequest(); rmReq.setPath(serverPath); rmReq.setType(watcherType.getIntValue()); request = rmReq; break; default: LOG.warn("unknown type " + opCode); break; } return request; }
public IRemoveWatchesRequest() { this(new RemoveWatchesRequest()); }
public IRemoveWatchesRequest(String path, int type) { this(new RemoveWatchesRequest(path, type)); }
public IRemoveWatchesRequest(RemoveWatchesRequest record) { super(record); }