@@ -143,13 +143,21 @@ public void onFailure(Throwable error, String content) {
143
143
protected void sendSuccessMessage (int statusCode , Header [] headers , String responseBody ) {
144
144
sendMessage (obtainMessage (SUCCESS_MESSAGE , new Object []{new Integer (statusCode ),headers , responseBody }));
145
145
}
146
-
146
+
147
147
protected void sendFailureMessage (Throwable e , String responseBody ) {
148
- sendMessage (obtainMessage (FAILURE_MESSAGE , new Object []{e , responseBody }));
148
+ sendMessage (obtainMessage (FAILURE_MESSAGE , new Object []{e , null , responseBody }));
149
149
}
150
-
150
+
151
+ protected void sendFailureMessage (Throwable e , Header [] headers , String responseBody ) {
152
+ sendMessage (obtainMessage (FAILURE_MESSAGE , new Object []{e , headers , responseBody }));
153
+ }
154
+
155
+ protected void sendFailureMessage (Throwable e , Header [] headers , byte [] responseBody ) {
156
+ sendMessage (obtainMessage (FAILURE_MESSAGE , new Object []{e , headers , responseBody }));
157
+ }
158
+
151
159
protected void sendFailureMessage (Throwable e , byte [] responseBody ) {
152
- sendMessage (obtainMessage (FAILURE_MESSAGE , new Object []{e , responseBody }));
160
+ sendMessage (obtainMessage (FAILURE_MESSAGE , new Object []{e , null , responseBody }));
153
161
}
154
162
155
163
protected void sendStartMessage () {
@@ -169,7 +177,7 @@ protected void handleSuccessMessage(int statusCode, Header[] headers, String res
169
177
onSuccess (statusCode , headers , responseBody );
170
178
}
171
179
172
- protected void handleFailureMessage (Throwable e , String responseBody ) {
180
+ protected void handleFailureMessage (Throwable e , Header [] headers , String responseBody ) {
173
181
onFailure (e , responseBody );
174
182
}
175
183
@@ -186,7 +194,7 @@ protected void handleMessage(Message msg) {
186
194
break ;
187
195
case FAILURE_MESSAGE :
188
196
response = (Object [])msg .obj ;
189
- handleFailureMessage ((Throwable )response [0 ], (String ) response [1 ]);
197
+ handleFailureMessage ((Throwable )response [0 ], (Header []) response [1 ], ( String ) response [ 2 ]);
190
198
break ;
191
199
case START_MESSAGE :
192
200
onStart ();
@@ -229,13 +237,15 @@ void sendResponseMessage(HttpResponse response) {
229
237
responseBody = EntityUtils .toString (entity , "UTF-8" );
230
238
}
231
239
} catch (IOException e ) {
232
- sendFailureMessage (e , (String ) null );
240
+ sendFailureMessage (e , response . getAllHeaders (), (String ) null );
233
241
}
234
242
235
243
if (status .getStatusCode () >= 300 ) {
236
- sendFailureMessage (new HttpResponseException (status .getStatusCode (), status .getReasonPhrase ()), responseBody );
244
+ sendFailureMessage (new HttpResponseException (
245
+ status .getStatusCode (), status .getReasonPhrase ()),
246
+ response .getAllHeaders (), responseBody );
237
247
} else {
238
- sendSuccessMessage (status .getStatusCode (),response .getAllHeaders (), responseBody );
248
+ sendSuccessMessage (status .getStatusCode (), response .getAllHeaders (), responseBody );
239
249
}
240
250
}
241
251
}
0 commit comments