File tree 3 files changed +11
-11
lines changed
test/src/com/rabbitmq/client/test
3 files changed +11
-11
lines changed Original file line number Diff line number Diff line change 21
21
import com .rabbitmq .client .Connection ;
22
22
import com .rabbitmq .client .ConnectionFactory ;
23
23
import com .rabbitmq .client .test .BrokerTestCase ;
24
+ import com .rabbitmq .tools .Host ;
24
25
25
26
import java .io .IOException ;
26
27
@@ -121,4 +122,12 @@ public void closeConnection() throws IOException {
121
122
}
122
123
super .closeConnection ();
123
124
}
125
+
126
+ protected void stopSecondary () throws IOException {
127
+ Host .executeCommand ("cd ../rabbitmq-test; make stop-secondary-app" );
128
+ }
129
+
130
+ protected void startSecondary () throws IOException {
131
+ Host .executeCommand ("cd ../rabbitmq-test; make start-secondary-app" );
132
+ }
124
133
}
Original file line number Diff line number Diff line change 21
21
22
22
import com .rabbitmq .client .GetResponse ;
23
23
import com .rabbitmq .client .MessageProperties ;
24
- import com .rabbitmq .tools .Host ;
25
24
26
25
public class DurableOnTransient extends ClusteredTestBase
27
26
{
@@ -62,14 +61,6 @@ public void testBindDurableToTransient()
62
61
assertNotNull (basicGet ());
63
62
}
64
63
65
- private void stopSecondary () throws IOException {
66
- Host .executeCommand ("cd ../rabbitmq-test; make stop-secondary-app" );
67
- }
68
-
69
- private void startSecondary () throws IOException {
70
- Host .executeCommand ("cd ../rabbitmq-test; make start-secondary-app" );
71
- }
72
-
73
64
public void testSemiDurableBindingRemoval () throws IOException {
74
65
if (clusteredConnection != null ) {
75
66
declareTransientTopicExchange ("x" );
Original file line number Diff line number Diff line change @@ -34,12 +34,12 @@ public class AbsentQueue extends ClusteredTestBase {
34
34
@ Override protected void setUp () throws IOException {
35
35
super .setUp ();
36
36
if (clusteredConnection != null )
37
- Host . executeCommand ( "cd ../rabbitmq-test; make stop-secondary-app" );
37
+ stopSecondary ( );
38
38
}
39
39
40
40
@ Override protected void tearDown () throws IOException {
41
41
if (clusteredConnection != null )
42
- Host . executeCommand ( "cd ../rabbitmq-test; make start-secondary-app" );
42
+ startSecondary ( );
43
43
super .tearDown ();
44
44
}
45
45
You can’t perform that action at this time.
0 commit comments