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