Commit 8495deb

committed

Don't send attributes if it's empty

1 parent 46929e0 commit 8495debCopy full SHA for 8495deb

File tree

-5

lines changed

-5

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`

Lines changed: 0 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -35,7 +35,6 @@ public function testShouldSendMessage()`
`35`	`35`	`->method('publish')`
`36`	`36`	`->with($this->identicalTo([`
`37`	`37`	`'data' => '{"body":"","properties":[],"headers":[]}',`
`38`		`- 'attributes' => [],`
`39`	`38`	`])`
`40`	`39`	`);`
`41`	`40`

Comments

(0)