Producer::publish() accepts message headers

src/Producer/Producer.php

@@ -54,17 +54,14 @@ public function __construct(
 	}
 
 
-	/**
-	 * @todo Headers
-	 */
-	public function publish(string $message): void
+	public function publish(string $message, array $headers = []): void
 	{
 		if ($this->queue) {
-			$this->publishToQueue($message);
+			$this->publishToQueue($message, $headers);
 		}
 
 		if ($this->exchange) {
-			$this->publishToExchange($message);
+			$this->publishToExchange($message, $headers);
 		}
 	}
 
@@ -80,12 +77,12 @@ private function publishToQueue(string $message, array $headers = []): void
 	}
 
 
-	private function publishToExchange(string $message): void
+	private function publishToExchange(string $message, array $headers = []): void
 	{
 		foreach ($this->exchange->getQueueBindings() as $queueBinding) {
 			$queueBinding->getQueue()->getConnection()->getChannel()->publish(
 				$message,
-				[],
+				$headers,
 				$this->exchange->getName(),
 				$queueBinding->getRoutingKey()
 			);