@@ -197,7 +197,7 @@ public void testTopicExchange() throws IOException, ShutdownSignalException,
197197 channel .exchangeBind (e , "e" , e );
198198 }
199199 for (String e : exchanges ) {
200- publishWithMarker (e , e );
200+ publishWithMarker ("e" , e );
201201 }
202202 for (QueueingConsumer c : consumers ) {
203203 consumeNoDuplicates (c );
@@ -210,7 +210,7 @@ public void testTopicExchange() throws IOException, ShutdownSignalException,
210210 channel .exchangeBind (e , "ef" , e );
211211 }
212212 for (String e : exchanges ) {
213- publishWithMarker (e , e );
213+ publishWithMarker ("e" , e );
214214 }
215215 for (QueueingConsumer c : consumers ) {
216216 consumeNoDuplicates (c );
@@ -222,7 +222,7 @@ public void testTopicExchange() throws IOException, ShutdownSignalException,
222222 channel .exchangeUnbind (e , "e" , e );
223223 }
224224 for (String e : exchanges ) {
225- publishWithMarker (e , e );
225+ publishWithMarker ("e" , e );
226226 }
227227 for (QueueingConsumer c : consumers ) {
228228 consumeNoDuplicates (c );
0 commit comments