Fix redirect
This commit is contained in:
parent
2463fd7261
commit
84ba71475d
|
@ -50,14 +50,16 @@ trait CallHandler
|
||||||
foreach ($message_ids as $message_id) {
|
foreach ($message_ids as $message_id) {
|
||||||
if (isset($this->outgoing_messages[$message_id]['body'])) {
|
if (isset($this->outgoing_messages[$message_id]['body'])) {
|
||||||
if ($datacenter) {
|
if ($datacenter) {
|
||||||
|
unset($this->outgoing_messages[$message_id]['msg_id']);
|
||||||
|
unset($this->outgoing_messages[$message_id]['seqno']);
|
||||||
Tools::call($this->API->datacenter->waitGetConnection($datacenter))->onResolve(function ($e, $r) use ($message_id) {
|
Tools::call($this->API->datacenter->waitGetConnection($datacenter))->onResolve(function ($e, $r) use ($message_id) {
|
||||||
Tools::callFork($r->sendMessage($this->outgoing_messages[$message_id], false));
|
Tools::callFork($r->sendMessage($this->outgoing_messages[$message_id], false));
|
||||||
});
|
});
|
||||||
|
$this->ackOutgoingMessageId($message_id);
|
||||||
|
$this->gotResponseForOutgoingMessageId($message_id);
|
||||||
} else {
|
} else {
|
||||||
Tools::callFork($this->sendMessage($this->outgoing_messages[$message_id], false));
|
Tools::callFork($this->sendMessage($this->outgoing_messages[$message_id], false));
|
||||||
}
|
}
|
||||||
//$this->ackOutgoingMessageId($message_id);
|
|
||||||
//$this->gotResponseForOutgoingMessageId($message_id);
|
|
||||||
} else {
|
} else {
|
||||||
$this->logger->logger('Could not resend '.(isset($this->outgoing_messages[$message_id]['_']) ? $this->outgoing_messages[$message_id]['_'] : $message_id));
|
$this->logger->logger('Could not resend '.(isset($this->outgoing_messages[$message_id]['_']) ? $this->outgoing_messages[$message_id]['_'] : $message_id));
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue
Block a user