Commit 8de13b9

committed

Don't send attributes if it's empty

1 parent 46929e0 commit 8de13b9Copy full SHA for 8de13b9

File tree

-4

lines changed

-4

lines changed

Lines changed: 8 additions & 4 deletions

Original file line number	Diff line number	Diff line change
`@@ -37,10 +37,14 @@ public function send(Destination $destination, Message $message): void`
`37`	`37`
`38`	`38`	`/** @var Topic $topic */`
`39`	`39`	`$topic = $this->context->getClient()->topic($destination->getTopicName());`
`40`		`- $topic->publish([`
`41`		`- 'data' => json_encode($message),`
`42`		`- 'attributes' => $message->getAttributes(),`
`43`		`- ]);`
	`40`	`+`
	`41`	`+ $params = ['data' => json_encode($message)];`
	`42`	`+`
	`43`	`+ if (count($message->getAttributes()) > 0) {`
	`44`	`+ $params['attributes'] = $message->getAttributes();`
	`45`	`+ }`
	`46`	`+`
	`47`	`+ $topic->publish($params);`
`44`	`48`	`}`
`45`	`49`
`46`	`50`	`public function setDeliveryDelay(?int $deliveryDelay = null): Producer`

Comments

(0)