@@ 103-114 (lines=12) @@ | ||
100 | } |
|
101 | ||
102 | ||
103 | if (false === $resultData[SmsWorker::P_RESULT_DATA_SUCCESS]) { |
|
104 | ||
105 | if (!$job->isSync()) { |
|
106 | // redirect result for new root gateway class |
|
107 | $gatewayClass = static::getConfig(SmsWorker::GATEWAY_DISPATCH_CLASS); |
|
108 | $job->addDebug(['set_gateway' => $gatewayClass]); |
|
109 | $job->setWorkerClass($gatewayClass)->save(); |
|
110 | throw new ResultException(ResultException::RETRY_GATEWAY_DISPATCH_CLASS); |
|
111 | } |
|
112 | ||
113 | throw new ResultException(ResultException::R_FAILURE, $resultData); |
|
114 | } |
|
115 | ||
116 | throw new ResultException(ResultException::R_SUCCESS, $resultData); |
|
117 | } |
@@ 133-144 (lines=12) @@ | ||
130 | } |
|
131 | ||
132 | ||
133 | if (false === $resultData[SmsWorker::P_RESULT_DATA_SUCCESS]) { |
|
134 | ||
135 | if (!$job->isSync()) { |
|
136 | // redirect result for new root gateway class |
|
137 | $gatewayClass = static::getConfig(SmsWorker::GATEWAY_DISPATCH_CLASS); |
|
138 | $job->addDebug(['set_gateway' => $gatewayClass]); |
|
139 | $job->setWorkerClass($gatewayClass)->save(); |
|
140 | throw new ResultException(ResultException::RETRY_GATEWAY_DISPATCH_CLASS); |
|
141 | } |
|
142 | ||
143 | throw new ResultException(ResultException::R_FAILURE, $resultData); |
|
144 | } |
|
145 | ||
146 | throw new ResultException(ResultException::R_SUCCESS, $resultData); |
|
147 | } |