Receiver option which copies messages to the receiver. This ensures that all receivers receive all incoming messages, no matter how many receivers there are. This is achieved by setting the receiver source distribution mode to :const:`proton.Terminus.DIST_MODE_COPY`.
| 837 | |
| 838 | |
| 839 | class Copy(ReceiverOption): |
| 840 | """ |
| 841 | Receiver option which copies messages to the receiver. This ensures that all |
| 842 | receivers receive all incoming messages, no matter how many receivers there |
| 843 | are. This is achieved by setting the receiver source distribution mode to |
| 844 | :const:`proton.Terminus.DIST_MODE_COPY`. |
| 845 | """ |
| 846 | |
| 847 | def apply(self, receiver: 'Receiver'): |
| 848 | """ |
| 849 | Set message copy semantics on the specified receiver. |
| 850 | |
| 851 | :param receiver: The receiver on which message copy semantics is to be set. |
| 852 | """ |
| 853 | receiver.source.distribution_mode = Terminus.DIST_MODE_COPY |
| 854 | |
| 855 | |
| 856 | def _apply_link_options( |