@@ -60,7 +60,7 @@ protected AMQConnection createConnection(ConnectionParams params, FrameHandler f
60
60
}
61
61
62
62
@ Override
63
- protected synchronized FrameHandlerFactory createFrameHandlerFactory () throws IOException {
63
+ protected synchronized FrameHandlerFactory createFrameHandlerFactory () {
64
64
return mock (FrameHandlerFactory .class );
65
65
}
66
66
};
@@ -87,6 +87,11 @@ protected AMQConnection createConnection(ConnectionParams params, FrameHandler f
87
87
createCalled .set (true );
88
88
return connection ;
89
89
}
90
+
91
+ @ Override
92
+ protected synchronized FrameHandlerFactory createFrameHandlerFactory () {
93
+ return mock (FrameHandlerFactory .class );
94
+ }
90
95
};
91
96
connectionFactory .setCredentialsProvider (provider );
92
97
connectionFactory .setAutomaticRecoveryEnabled (false );
@@ -114,7 +119,14 @@ protected AddressResolver createAddressResolver(List<Address> addresses) {
114
119
addressResolver .set (super .createAddressResolver (addresses ));
115
120
return addressResolver .get ();
116
121
}
122
+
123
+ @ Override
124
+ protected synchronized FrameHandlerFactory createFrameHandlerFactory () {
125
+ return mock (FrameHandlerFactory .class );
126
+ }
117
127
};
128
+ // connection recovery makes the creation path more complex
129
+ connectionFactory .setAutomaticRecoveryEnabled (false );
118
130
119
131
doNothing ().when (connection ).start ();
120
132
connectionFactory .newConnection ();
@@ -138,7 +150,14 @@ protected AddressResolver createAddressResolver(List<Address> addresses) {
138
150
addressResolver .set (super .createAddressResolver (addresses ));
139
151
return addressResolver .get ();
140
152
}
153
+
154
+ @ Override
155
+ protected synchronized FrameHandlerFactory createFrameHandlerFactory () {
156
+ return mock (FrameHandlerFactory .class );
157
+ }
141
158
};
159
+ // connection recovery makes the creation path more complex
160
+ connectionFactory .setAutomaticRecoveryEnabled (false );
142
161
143
162
doNothing ().when (connection ).start ();
144
163
connectionFactory .useSslProtocol ();
0 commit comments