videlalvaro /
php-amqplib
| @@ 1101-1104 (lines=4) @@ | ||
| 1098 | $pkt |
|
| 1099 | ); |
|
| 1100 | ||
| 1101 | if ($this->next_delivery_tag > 0) { |
|
| 1102 | $this->published_messages[$this->next_delivery_tag] = $msg; |
|
| 1103 | $this->next_delivery_tag = bcadd($this->next_delivery_tag, '1', 0); |
|
| 1104 | } |
|
| 1105 | } |
|
| 1106 | ||
| 1107 | /** |
|
| @@ 1161-1164 (lines=4) @@ | ||
| 1158 | $pkt |
|
| 1159 | ); |
|
| 1160 | ||
| 1161 | if ($this->next_delivery_tag > 0) { |
|
| 1162 | $this->published_messages[$this->next_delivery_tag] = $msg; |
|
| 1163 | $this->next_delivery_tag = bcadd($this->next_delivery_tag, '1', 0); |
|
| 1164 | } |
|
| 1165 | } |
|
| 1166 | ||
| 1167 | //call write here |
|
