File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -20,7 +20,7 @@ public function test_post_is_marked_as_published()
20
20
21
21
// Then, tells Kafka what messages the consumer should receive:
22
22
\Junges\Kafka\Facades\Kafka::shouldReceiveMessages([
23
- new ConsumedMessage(
23
+ new \Junges\Kafka\Message\ ConsumedMessage(
24
24
topicName: 'mark-post-as-published-topic',
25
25
partition: 0,
26
26
headers: [],
@@ -33,8 +33,8 @@ public function test_post_is_marked_as_published()
33
33
34
34
// Now, instantiate your consumer and start consuming messages. It will consume only the messages
35
35
// specified in `shouldReceiveMessages` method:
36
- $consumer = Kafka::consumer(['mark-post-as-published-topic'])
37
- ->withHandler(function (KafkaConsumerMessage $message) use (& $posts) {
36
+ $consumer = \Junges\Kafka\Facades\ Kafka::consumer(['mark-post-as-published-topic'])
37
+ ->withHandler(function (\Junges\Kafka\Contracts\ConsumerMessage $message) use (& $posts) {
38
38
$post = Post::find($message->getBody()['post_id']);
39
39
40
40
$post->update(['published_at' => now()->format("Y-m-d H:i:s")]);
You can’t perform that action at this time.
0 commit comments