File tree Expand file tree Collapse file tree 1 file changed +6
-7
lines changed
test/src/com/rabbitmq/client/test/server Expand file tree Collapse file tree 1 file changed +6
-7
lines changed Original file line number Diff line number Diff line change 44
55public class PersisterRestart6 extends RestartBase {
66
7- private static final String utf8 = "UTF-8" ;
87 private static final String q = "Restart6" ;
98
109 public void testRestart () throws IOException , InterruptedException {
1110 declareDurableQueue (q );
12- basicPublishPersistent ("a" .getBytes (utf8 ), q );
13- basicPublishPersistent ("b" .getBytes (utf8 ), q );
14- basicPublishPersistent ("c" .getBytes (utf8 ), q );
11+ basicPublishPersistent ("a" .getBytes (), q );
12+ basicPublishPersistent ("b" .getBytes (), q );
13+ basicPublishPersistent ("c" .getBytes (), q );
1514 forceSnapshot ();
1615 restart ();
17- assertTrue (new String (basicGet (q ).getBody (), utf8 ).equals ("a" ));
16+ assertTrue (new String (basicGet (q ).getBody ()).equals ("a" ));
1817 forceSnapshot ();
1918 restart ();
2019 restart ();
21- assertTrue (new String (basicGet (q ).getBody (), utf8 ).equals ("b" ));
22- assertTrue (new String (basicGet (q ).getBody (), utf8 ).equals ("c" ));
20+ assertTrue (new String (basicGet (q ).getBody ()).equals ("b" ));
21+ assertTrue (new String (basicGet (q ).getBody ()).equals ("c" ));
2322 deleteQueue (q );
2423 }
2524
You can’t perform that action at this time.
0 commit comments