| | |
| | | ServerState startState; |
| | | ServerState currentState; |
| | | ServerState stopState; |
| | | long domainLatestTrimDate; |
| | | |
| | | /** |
| | | * {@inheritDoc} |
| | |
| | | { |
| | | // Here comes a new message !!! |
| | | // non blocking |
| | | UpdateMsg newMsg = mh.getnextMessage(false); |
| | | UpdateMsg newMsg; |
| | | do { |
| | | newMsg = mh.getnextMessage(false); |
| | | // older than latest domain trimdate ? |
| | | } while ((newMsg!=null) && |
| | | (newMsg.getChangeNumber().getTime() < domainLatestTrimDate)); |
| | | |
| | | if (debugEnabled()) |
| | | TRACER.debugInfo(" In ECLServerHandler, for " + mh.getServiceId() + |
| | |
| | | DomainContext newDomainCtxt = new DomainContext(); |
| | | newDomainCtxt.active = true; |
| | | newDomainCtxt.rsd = rsd; |
| | | newDomainCtxt.domainLatestTrimDate = rsd.getLatestDomainTrimDate(); |
| | | |
| | | // Assign the start state for the domain |
| | | if (isPersistent == |