AgentIndexRunner.java revision 1327
1024N/A * See LICENSE.txt included in this distribution for the specific
1024N/A * file and include the License file at LICENSE.txt.
972N/A return indexerInstance;
972N/A public void preDeregister() {
972N/A public void postDeregister() {
log.log(Level.INFO, "Starting index, update {0} noThreads {1} subfiles {2}", new Object[]{String.valueOf(update), String.valueOf(noThreads), String.valueOf(subFiles.size())});
log.log(Level.WARNING, "Cannot Run indexing without proper configuration file ''{0}''", configfile);
} catch (Exception e) {
lastException = e;
public void disable() {
enabled = false;
public void enable() {
enabled = true;
if (enabled) {
index(false);
if (!waitForFinished) {
} catch (Exception e) {
+ e.getMessage());
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) {