[Messenger] ReceiverInterface updated

Guikingone · javiereguiluz · commit 2c2a51806e8a · 2019-07-04T13:22:10.000+02:00
diff --git a/components/messenger.rst b/components/messenger.rst
@@ -282,23 +282,37 @@ do is to write your own CSV receiver::
             $this->filePath = $filePath;
         }
 
-        public function receive(callable $handler): void
+        public function get(): void
         {
             $ordersFromCsv = $this->serializer->deserialize(file_get_contents($this->filePath), 'csv');
 
             foreach ($ordersFromCsv as $orderFromCsv) {
                 $order = new NewOrder($orderFromCsv['id'], $orderFromCsv['account_id'], $orderFromCsv['amount']);
+                
+                $envelope = new Envelope($order);
 
-                $handler(new Envelope($order));
+                $handler($envelope);
             }
+            
+            return [$envelope];
+        }
+        
+        public function ack(Envelope $envelope): void 
+        {
+            // Add information about the handled message
         }
 
-        public function stop(): void
+        public function reject(Envelope $envelope): void
         {
-            // noop
+            // Reject the message if needed
         }
     }
 
+.. versionadded:: 4.3
+
+    The ``ReceiverInterface`` has been upgraded to act as most libraries 
+    does, be sure to adapt your existing code according to the newly added methods.
+
 Receiver and Sender on the same Bus
 ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
 

Original file line number	Diff line number	Diff line change
`@@ -282,23 +282,37 @@ do is to write your own CSV receiver::`
`282`	`282`	`$this->filePath = $filePath;`
`283`	`283`	`}`
`284`	`284`
`285`		`- public function receive(callable $handler): void`
	`285`	`+ public function get(): void`
`286`	`286`	`{`
`287`	`287`	`$ordersFromCsv = $this->serializer->deserialize(file_get_contents($this->filePath), 'csv');`
`288`	`288`
`289`	`289`	`foreach ($ordersFromCsv as $orderFromCsv) {`
`290`	`290`	`$order = new NewOrder($orderFromCsv['id'], $orderFromCsv['account_id'], $orderFromCsv['amount']);`
	`291`	`+`
	`292`	`+ $envelope = new Envelope($order);`
`291`	`293`
`292`		`- $handler(new Envelope($order));`
	`294`	`+ $handler($envelope);`
`293`	`295`	`}`
	`296`	`+`
	`297`	`+ return [$envelope];`
	`298`	`+ }`
	`299`	`+`
	`300`	`+ public function ack(Envelope $envelope): void`
	`301`	`+ {`
	`302`	`+ // Add information about the handled message`
`294`	`303`	`}`
`295`	`304`
`296`		`- public function stop(): void`
	`305`	`+ public function reject(Envelope $envelope): void`
`297`	`306`	`{`
`298`		`- // noop`
	`307`	`+ // Reject the message if needed`
`299`	`308`	`}`
`300`	`309`	`}`
`301`	`310`
	`311`	`+.. versionadded:: 4.3`
	`312`	`+`
	`313`	+ The ``ReceiverInterface`` has been upgraded to act as most libraries
	`314`	`+ does, be sure to adapt your existing code according to the newly added methods.`
	`315`	`+`
`302`	`316`	`Receiver and Sender on the same Bus`
`303`	`317`	`~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~`
`304`	`318`