@@ -103,15 +103,15 @@ public void testSqsMessageHandler() {
103
103
verify (this .amazonSqs )
104
104
.sendMessageAsync (sendMessageRequestArgumentCaptor .capture (), any (AsyncHandler .class ));
105
105
assertThat (sendMessageRequestArgumentCaptor .getValue ().getQueueUrl ())
106
- .isEqualTo ("http ://queue-url.com/foo" );
106
+ .isEqualTo ("https ://queue-url.com/foo" );
107
107
108
108
message = MessageBuilder .withPayload ("message" ).setHeader (AwsHeaders .QUEUE , "bar" ).build ();
109
109
this .sqsSendChannel .send (message );
110
110
verify (this .amazonSqs , times (2 ))
111
111
.sendMessageAsync (sendMessageRequestArgumentCaptor .capture (), any (AsyncHandler .class ));
112
112
113
113
assertThat (sendMessageRequestArgumentCaptor .getValue ().getQueueUrl ())
114
- .isEqualTo ("http ://queue-url.com/bar" );
114
+ .isEqualTo ("https ://queue-url.com/bar" );
115
115
116
116
SpelExpressionParser spelExpressionParser = new SpelExpressionParser ();
117
117
Expression expression = spelExpressionParser .parseExpression ("headers.foo" );
@@ -123,7 +123,7 @@ public void testSqsMessageHandler() {
123
123
124
124
SendMessageRequest sendMessageRequestArgumentCaptorValue = sendMessageRequestArgumentCaptor .getValue ();
125
125
assertThat (sendMessageRequestArgumentCaptorValue .getQueueUrl ())
126
- .isEqualTo ("http ://queue-url.com/baz" );
126
+ .isEqualTo ("https ://queue-url.com/baz" );
127
127
128
128
Map <String , MessageAttributeValue > messageAttributes =
129
129
sendMessageRequestArgumentCaptorValue .getMessageAttributes ();
@@ -152,7 +152,7 @@ public void testSqsMessageHandlerWithAutoQueueCreate() {
152
152
verify (this .amazonSqs )
153
153
.sendMessageAsync (sendMessageRequestArgumentCaptor .capture (), any (AsyncHandler .class ));
154
154
assertThat (sendMessageRequestArgumentCaptor .getValue ().getQueueUrl ())
155
- .isEqualTo ("http ://queue-url.com/foo" );
155
+ .isEqualTo ("https ://queue-url.com/foo" );
156
156
}
157
157
158
158
@ Configuration
@@ -166,7 +166,7 @@ public AmazonSQSAsync amazonSqs() {
166
166
willAnswer (invocation -> {
167
167
GetQueueUrlRequest getQueueUrlRequest = (GetQueueUrlRequest ) invocation .getArguments ()[0 ];
168
168
GetQueueUrlResult queueUrl = new GetQueueUrlResult ();
169
- queueUrl .setQueueUrl ("http ://queue-url.com/" + getQueueUrlRequest .getQueueName ());
169
+ queueUrl .setQueueUrl ("https ://queue-url.com/" + getQueueUrlRequest .getQueueName ());
170
170
return queueUrl ;
171
171
})
172
172
.given (amazonSqs )
@@ -175,7 +175,7 @@ public AmazonSQSAsync amazonSqs() {
175
175
willAnswer (invocation -> {
176
176
CreateQueueRequest createQueueRequest = (CreateQueueRequest ) invocation .getArguments ()[0 ];
177
177
CreateQueueResult queueUrl = new CreateQueueResult ();
178
- queueUrl .setQueueUrl ("http ://queue-url.com/" + createQueueRequest .getQueueName ());
178
+ queueUrl .setQueueUrl ("https ://queue-url.com/" + createQueueRequest .getQueueName ());
179
179
return queueUrl ;
180
180
})
181
181
.given (amazonSqs )
0 commit comments