AgentIndexRunner.java revision 520
* See LICENSE.txt included in this distribution for the specific
* file and include the License file at LICENSE.txt.
private boolean enabled;
return indexerInstance;
return name;
public void preDeregister() {
public void postDeregister() {
public void run() {
log.info("Starting index, update " + update + " noThreads " + noThreads + " subfiles " + subFiles.size());
} catch (Exception e) {
lastException = e;
public void disable() {
enabled = false;
public void enable() {
enabled = true;
if (!enabled) {
index(false);
if (!waitForFinished) {
} catch (Exception e) {
private void sendNotifications() {
public long lastIndexTimeFinished() {
return lastIndexFinish;
public long lastIndexTimeStarted() {
return lastIndexStart;
public long lastIndexTimeUsed() {
return lastIndexUsedTime;
return lastException;
public void addNotificationListener(NotificationListener notiflistener, NotificationFilter notfilt, Object obj) throws IllegalArgumentException {
synchronized (notifListeners) {
public void removeNotificationListener(NotificationListener notiflistener) throws ListenerNotFoundException {
boolean removed = false;
synchronized (notifListeners) {
removed = true;
if (!removed) {
public void removeNotificationListener(NotificationListener notiflistener, NotificationFilter filt, Object obj) throws ListenerNotFoundException {
boolean removed = false;
synchronized (notifListeners) {
removed = true;
if (!removed) {
String[] supptypes = {NOTIFICATIONACTIONTYPE, NOTIFICATIONINFOLONGTYPE, NOTIFICATIONINFOSTRINGTYPE};
descr);
return info;
sequenceNo++;
synchronized (notifListeners) {
ex);