|
|
@ -804,7 +804,7 @@ public final class plasmaCrawlStacker {
|
|
|
|
private stackCrawlMessage theMsg;
|
|
|
|
private stackCrawlMessage theMsg;
|
|
|
|
|
|
|
|
|
|
|
|
public Worker(ThreadGroup theThreadGroup) {
|
|
|
|
public Worker(ThreadGroup theThreadGroup) {
|
|
|
|
super(theThreadGroup,"stackCrawlThread");
|
|
|
|
super(theThreadGroup,"stackCrawlThread_created");
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
public void setStopped(boolean stopped) {
|
|
|
|
public void setStopped(boolean stopped) {
|
|
|
@ -878,6 +878,7 @@ public final class plasmaCrawlStacker {
|
|
|
|
|
|
|
|
|
|
|
|
private void execute() {
|
|
|
|
private void execute() {
|
|
|
|
try {
|
|
|
|
try {
|
|
|
|
|
|
|
|
this.setName(plasmaCrawlWorker.threadBaseName + "_" + this.theMsg.url);
|
|
|
|
String rejectReason = dequeue(this.theMsg);
|
|
|
|
String rejectReason = dequeue(this.theMsg);
|
|
|
|
|
|
|
|
|
|
|
|
if (rejectReason != null) {
|
|
|
|
if (rejectReason != null) {
|
|
|
|