Skip to content

Commit

Permalink
wip
Browse files Browse the repository at this point in the history
  • Loading branch information
heyjorgedev committed Jul 13, 2024
1 parent c5d4faf commit 0cebfd0
Show file tree
Hide file tree
Showing 3 changed files with 13 additions and 6 deletions.
9 changes: 8 additions & 1 deletion README.md
Original file line number Diff line number Diff line change
Expand Up @@ -47,7 +47,14 @@ $message = $client->publish(
])
]);

echo $message->id;
// to know if the request was successful:
echo $message->isSuccessful()

// to get the message
echo $message->getData();

// to get the message id
echo $message->getData()->id;
```

## Testing
Expand Down
6 changes: 3 additions & 3 deletions src/Client.php
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,7 @@
use HeyJorgeDev\QStash\Resources\MessageResource;
use HeyJorgeDev\QStash\Resources\QueueResource;
use HeyJorgeDev\QStash\Resources\ScheduleResource;
use HeyJorgeDev\QStash\ValueObjects\Message;
use HeyJorgeDev\QStash\Responses\MessagePublishResponse;
use HeyJorgeDev\QStash\ValueObjects\MessageToPublish;

class Client implements ClientInterface
Expand All @@ -32,8 +32,8 @@ public function messages(): MessageInterface
return new MessageResource($this->transporter);
}

public function publish(MessageToPublish $messageToPublish): Message
public function publish(MessageToPublish $messageToPublish): MessagePublishResponse
{
return $this->messages()->publish($messageToPublish)->getData();
return $this->messages()->publish($messageToPublish);
}
}
4 changes: 2 additions & 2 deletions src/Contracts/ClientInterface.php
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@
use HeyJorgeDev\QStash\Contracts\Resources\MessageInterface;
use HeyJorgeDev\QStash\Contracts\Resources\QueueInterface;
use HeyJorgeDev\QStash\Contracts\Resources\ScheduleInterface;
use HeyJorgeDev\QStash\ValueObjects\Message;
use HeyJorgeDev\QStash\Responses\MessagePublishResponse;
use HeyJorgeDev\QStash\ValueObjects\MessageToPublish;

interface ClientInterface
Expand All @@ -16,5 +16,5 @@ public function schedules(): ScheduleInterface;

public function messages(): MessageInterface;

public function publish(MessageToPublish $messageToPublish): Message;
public function publish(MessageToPublish $messageToPublish): MessagePublishResponse;
}

0 comments on commit 0cebfd0

Please sign in to comment.