@@ -62,7 +62,7 @@ protected AMQConnection createConnection(ConnectionParams params, FrameHandler f
6262 }
6363
6464 @ Override
65- protected synchronized FrameHandlerFactory createFrameHandlerFactory () throws IOException {
65+ protected synchronized FrameHandlerFactory createFrameHandlerFactory () {
6666 return mock (FrameHandlerFactory .class );
6767 }
6868 };
@@ -89,6 +89,11 @@ protected AMQConnection createConnection(ConnectionParams params, FrameHandler f
8989 createCalled .set (true );
9090 return connection ;
9191 }
92+
93+ @ Override
94+ protected synchronized FrameHandlerFactory createFrameHandlerFactory () {
95+ return mock (FrameHandlerFactory .class );
96+ }
9297 };
9398 connectionFactory .setCredentialsProvider (provider );
9499 connectionFactory .setAutomaticRecoveryEnabled (false );
@@ -116,7 +121,14 @@ protected AddressResolver createAddressResolver(List<Address> addresses) {
116121 addressResolver .set (super .createAddressResolver (addresses ));
117122 return addressResolver .get ();
118123 }
124+
125+ @ Override
126+ protected synchronized FrameHandlerFactory createFrameHandlerFactory () {
127+ return mock (FrameHandlerFactory .class );
128+ }
119129 };
130+ // connection recovery makes the creation path more complex
131+ connectionFactory .setAutomaticRecoveryEnabled (false );
120132
121133 doNothing ().when (connection ).start ();
122134 connectionFactory .newConnection ();
@@ -140,7 +152,14 @@ protected AddressResolver createAddressResolver(List<Address> addresses) {
140152 addressResolver .set (super .createAddressResolver (addresses ));
141153 return addressResolver .get ();
142154 }
155+
156+ @ Override
157+ protected synchronized FrameHandlerFactory createFrameHandlerFactory () {
158+ return mock (FrameHandlerFactory .class );
159+ }
143160 };
161+ // connection recovery makes the creation path more complex
162+ connectionFactory .setAutomaticRecoveryEnabled (false );
144163
145164 doNothing ().when (connection ).start ();
146165 connectionFactory .useSslProtocol ();
0 commit comments