@@ -74,25 +74,25 @@ public function testItRetrieveTheFirstAvailableMessage()
74
74
'body ' => '{"message": "Hi handled"} ' ,
75
75
'headers ' => json_encode (['type ' => DummyMessage::class]),
76
76
'queue_name ' => 'default ' ,
77
- 'created_at ' => $ this ->formatDateTime (new \DateTimeImmutable ('2019-03-15 12:00:00 ' )),
78
- 'available_at ' => $ this ->formatDateTime (new \DateTimeImmutable ('2019-03-15 12:00:00 ' )),
79
- 'delivered_at ' => $ this ->formatDateTime (new \DateTimeImmutable ()),
77
+ 'created_at ' => $ this ->formatDateTime (new \DateTimeImmutable ('2019-03-15 12:00:00 ' , new \ DateTimeZone ( ' UTC ' ) )),
78
+ 'available_at ' => $ this ->formatDateTime (new \DateTimeImmutable ('2019-03-15 12:00:00 ' , new \ DateTimeZone ( ' UTC ' ) )),
79
+ 'delivered_at ' => $ this ->formatDateTime (new \DateTimeImmutable (' now ' , new \ DateTimeZone ( ' UTC ' ) )),
80
80
]);
81
81
// one available later
82
82
$ this ->driverConnection ->insert ('messenger_messages ' , [
83
83
'body ' => '{"message": "Hi delayed"} ' ,
84
84
'headers ' => json_encode (['type ' => DummyMessage::class]),
85
85
'queue_name ' => 'default ' ,
86
- 'created_at ' => $ this ->formatDateTime (new \DateTimeImmutable ('2019-03-15 12:00:00 ' )),
87
- 'available_at ' => $ this ->formatDateTime (new \DateTimeImmutable ('2019-03-15 13:00:00 ' )),
86
+ 'created_at ' => $ this ->formatDateTime (new \DateTimeImmutable ('2019-03-15 12:00:00 ' , new \ DateTimeZone ( ' UTC ' ) )),
87
+ 'available_at ' => $ this ->formatDateTime (new \DateTimeImmutable ('2019-03-15 13:00:00 ' , new \ DateTimeZone ( ' UTC ' ) )),
88
88
]);
89
89
// one available
90
90
$ this ->driverConnection ->insert ('messenger_messages ' , [
91
91
'body ' => '{"message": "Hi available"} ' ,
92
92
'headers ' => json_encode (['type ' => DummyMessage::class]),
93
93
'queue_name ' => 'default ' ,
94
- 'created_at ' => $ this ->formatDateTime (new \DateTimeImmutable ('2019-03-15 12:00:00 ' )),
95
- 'available_at ' => $ this ->formatDateTime (new \DateTimeImmutable ('2019-03-15 12:30:00 ' )),
94
+ 'created_at ' => $ this ->formatDateTime (new \DateTimeImmutable ('2019-03-15 12:00:00 ' , new \ DateTimeZone ( ' UTC ' ) )),
95
+ 'available_at ' => $ this ->formatDateTime (new \DateTimeImmutable ('2019-03-15 12:30:00 ' , new \ DateTimeZone ( ' UTC ' ) )),
96
96
]);
97
97
98
98
$ encoded = $ this ->connection ->get ();
@@ -108,33 +108,33 @@ public function testItCountMessages()
108
108
'body ' => '{"message": "Hi handled"} ' ,
109
109
'headers ' => json_encode (['type ' => DummyMessage::class]),
110
110
'queue_name ' => 'default ' ,
111
- 'created_a
10000
t ' => $ this ->formatDateTime (new \DateTimeImmutable ('2019-03-15 12:00:00 ' )),
112
- 'available_at ' => $ this ->formatDateTime (new \DateTimeImmutable ('2019-03-15 12:00:00 ' )),
113
- 'delivered_at ' => $ this ->formatDateTime (new \DateTimeImmutable ()),
111
+ 'created_at ' => $ this ->formatDateTime (new \DateTimeImmutable ('2019-03-15 12:00:00 ' , new \ DateTimeZone ( ' UTC ' ) )),
112
+ 'available_at ' => $ this ->formatDateTime (new \DateTimeImmutable ('2019-03-15 12:00:00 ' , new \ DateTimeZone ( ' UTC ' ) )),
113
+ 'delivered_at ' => $ this ->formatDateTime (new \DateTimeImmutable (' now ' , new \ DateTimeZone ( ' UTC ' ) )),
114
114
]);
115
115
// one available later
116
116
$ this ->driverConnection ->insert ('messenger_messages ' , [
117
117
'body ' => '{"message": "Hi delayed"} ' ,
118
118
'headers ' => json_encode (['type ' => DummyMessage::class]),
119
119
'queue_name ' => 'default ' ,
120
- 'created_at ' => $ this ->formatDateTime (new \DateTimeImmutable ('2019-03-15 12:00:00 ' )),
121
- 'available_at ' => $ this ->formatDateTime (( new \DateTimeImmutable ())-> modify ( '+1 minute ' )),
120
+ 'created_at ' => $ this ->formatDateTime (new \DateTimeImmutable ('2019-03-15 12:00:00 ' , new \ DateTimeZone ( ' UTC ' ) )),
121
+ 'available_at ' => $ this ->formatDateTime (new \DateTimeImmutable ('+1 minute ' , new \ DateTimeZone ( ' UTC ' ) )),
122
122
]);
123
123
// one available
124
124
$ this ->driverConnection ->insert ('messenger_messages ' , [
125
125
'body ' => '{"message": "Hi available"} ' ,
126
126
'headers ' => json_encode (['type ' => DummyMessage::class]),
127
127
'queue_name ' => 'default ' ,
128
- 'created_at ' => $ this ->formatDateTime (new \DateTimeImmutable ('2019-03-15 12:00:00 ' )),
129
- 'available_at ' => $ this ->formatDateTime (new \DateTimeImmutable ('2019-03-15 12:30:00 ' )),
128
+ 'created_at ' => $ this ->formatDateTime (new \DateTimeImmutable ('2019-03-15 12:00:00 ' , new \ DateTimeZone ( ' UTC ' ) )),
129
+ 'available_at ' => $ this ->formatDateTime (new \DateTimeImmutable ('2019-03-15 12:30:00 ' , new \ DateTimeZone ( ' UTC ' ) )),
130
130
]);
131
131
// another available
132
132
$ this ->driverConnection ->insert ('messenger_messages ' , [
133
133
'body ' => '{"message": "Hi available"} ' ,
134
134
'headers ' => json_encode (['type ' => DummyMessage::class]),
135
135
'queue_name ' => 'default ' ,
136
- 'created_at ' => $ this ->formatDateTime (new \DateTimeImmutable ('2019-03-15 12:00:00 ' )),
137
- 'available_at ' => $ this ->formatDateTime (new \DateTimeImmutable ('2019-03-15 12:30:00 ' )),
136
+ 'created_at ' => $ this ->formatDateTime (new \DateTimeImmutable ('2019-03-15 12:00:00 ' , new \ DateTimeZone ( ' UTC ' ) )),
137
+ 'available_at ' => $ this ->formatDateTime (new \DateTimeImmutable ('2019-03-15 12:30:00 ' , new \ DateTimeZone ( ' UTC ' ) )),
138
138
]);
139
139
140
140
$ this ->assertSame (2 , $ this ->connection ->getMessageCount ());
@@ -148,16 +148,16 @@ public function testItRetrieveTheMessageThatIsOlderThanRedeliverTimeout()
148
148
'body ' => '{"message": "Hi requeued"} ' ,
149
149
'headers ' => json_encode (['type ' => DummyMessage::class]),
150
150
'queue_name ' => 'default ' ,
151
- 'created_at ' => $ this ->formatDateTime (new \DateTimeImmutable ('2019-03-15 12:00:00 ' )),
152
- 'available_at ' => $ this ->formatDateTime (new \DateTimeImmutable ('2019-03-15 12:00:00 ' )),
151
+ 'created_at ' => $ this ->formatDateTime (new \DateTimeImmutable ('2019-03-15 12:00:00 ' , new \ DateTimeZone ( ' UTC ' ) )),
152
+ 'available_at ' => $ this ->formatDateTime (new \DateTimeImmutable ('2019-03-15 12:00:00 ' , new \ DateTimeZone ( ' UTC ' ) )),
153
153
'delivered_at ' => $ this ->formatDateTime ($ twoHoursAgo ),
154
154
]);
155
155
$ this ->driverConnection ->insert ('messenger_messages ' , [
156
156
'body ' => '{"message": "Hi available"} ' ,
157
157
'headers ' => json_encode (['type ' => DummyMessage::class]),
158
158
'queue_name ' => 'default ' ,
159
- 'created_at ' => $ this ->formatDateTime (new \DateTimeImmutable ('2019-03-15 12:00:00 ' )),
160
- 'available_at ' => $ this ->formatDateTime (new \DateTimeImmutable ('2019-03-15 12:30:00 ' )),
159
+ 'created_at ' => $ this ->formatDateTime (new \DateTimeImmutable ('2019-03-15 12:00:00 ' , new \ DateTimeZone ( ' UTC ' ) )),
160
+ 'available_at ' => $ this ->formatDateTime (new \DateTimeImmutable ('2019-03-15 12:30:00 ' , new \ DateTimeZone ( ' UTC ' ) )),
161
161
]);
162
162
163
163
$ next = $ this ->connection ->get ();
0 commit comments