Java 类com.android.volley.RequestQueue 实例源码
项目:IelloAndroidApp
文件:HelperRete.java
/**
* Effettua una web request sincrona tramite Volley API, restituendo in risposta
* l'oggetto JSON scaricato.
*/
public static JSONObject volleySyncRequest(Context c, String url) {
// configurazione della webRequest
RequestFuture<JSONObject> future = RequestFuture.newFuture();
JsonObjectRequest request = new JsonObjectRequest(url, null, future, future);
RequestQueue requestQueue = Volley.newRequestQueue(c);
requestQueue.add(request);
// esecuzione sincrona della webRequest
try {
// limita la richiesta bloccante a un massimo di 10 secondi, quindi restituisci
// la risposta.
return future.get(10, TimeUnit.SECONDS);
} catch (InterruptedException | TimeoutException | ExecutionException e) {
e.printStackTrace();
}
return null;
}
项目:Library-Token-Automation
文件:Submit.java
private void getData(String rollnumber) {
String url = DATA_URL+rollnumber;
loading = ProgressDialog.show(this,"Please wait...","Fetching...",false,false);
StringRequest stringRequest = new StringRequest(url, new Response.Listener<String>() {
@Override
public void onResponse(String response) {
loading.dismiss();
showJSON(response);
}
},
new Response.ErrorListener() {
@Override
public void onErrorResponse(VolleyError error) {
Toast.makeText(Submit.this,error.getMessage().toString(),Toast.LENGTH_LONG).show();
}
});
RequestQueue requestQueue = Volley.newRequestQueue(this);
requestQueue.add(stringRequest);
}
项目:IelloAndroidAdminApp
文件:HelperRete.java
/**
* Effettua una web request sincrona tramite Volley API, restituendo in risposta
* l'oggetto JSON scaricato.
*/
static JSONObject volleySyncRequest(Context c, String url) {
// configurazione della webRequest
RequestFuture<JSONObject> future = RequestFuture.newFuture();
JsonObjectRequest request = new JsonObjectRequest(url, null, future, future);
RequestQueue requestQueue = Volley.newRequestQueue(c);
requestQueue.add(request);
// esecuzione sincrona della webRequest
try {
// limita la richiesta bloccante a un massimo di 10 secondi, quindi restituisci
// la risposta.
return future.get(10, TimeUnit.SECONDS);
} catch (InterruptedException | TimeoutException | ExecutionException e) {
e.printStackTrace();
}
return null;
}
项目:TrackIt-Android
文件:SearchActivity.java
private void loadSearchSuggestions(final String query) {
String showName = query.replaceAll("\\s", "+");
RequestQueue requestQueue = VolleySingleton.getInstance().getRequestQueue();
JsonArrayRequest req = new JsonArrayRequest(
API.TV_MAZE_SEARCH + showName,
new Response.Listener<JSONArray>() {
@Override
public void onResponse(JSONArray response) {
List<SearchSuggestions> searchSuggestions = new ArrayList<>();
JSONObject object;
try {
for (int j = 0; j < response.length() && searchSuggestions.size() < 5; j++) {
object = response.getJSONObject(j).getJSONObject("show");
SearchSuggestions suggestion = new SearchSuggestions(object.getString("name"));
if (!searchSuggestions.contains(suggestion)) {
searchSuggestions.add(suggestion);
}
}
} catch (JSONException e) {
//Log.e("JSON exception", e.getMessage());
}
if (searchView.isSearchBarFocused()) {
searchView.swapSuggestions(searchSuggestions);
}
searchView.hideProgress();
}
},
new Response.ErrorListener() {
@Override
public void onErrorResponse(VolleyError error) {
searchView.hideProgress();
}
});
req.setRetryPolicy(new DefaultRetryPolicy(
5000, DefaultRetryPolicy.DEFAULT_MAX_RETRIES,
DefaultRetryPolicy.DEFAULT_BACKOFF_MULT));
requestQueue.add(req);
}
项目:android-volley-file-upload
文件:MyApplication.java
public RequestQueue getRequestQueue() {
if (mRequestQueue == null) {
mRequestQueue = Volley.newRequestQueue(getApplicationContext());
}
return mRequestQueue;
}
项目:Goalie_Android
文件:BaseTest.java
private RequestQueue newVolleyRequestQueueForTest(final Context context) {
File cacheDir = new File(context.getCacheDir(), "cache/volley");
Network network = new BasicNetwork(new HurlStack());
ResponseDelivery responseDelivery = new ExecutorDelivery(Executors.newSingleThreadExecutor());
RequestQueue queue = new RequestQueue(new DiskBasedCache(cacheDir), network, 4, responseDelivery);
queue.start();
return queue;
}
项目:Nearby
文件:CustomApplication.java
public RequestQueue getRequestQueue() {
if (mRequestQueue == null) {
mRequestQueue = Volley.newRequestQueue(getApplicationContext());
}
return mRequestQueue;
}
项目:Codeforces
文件:ImageLoaderTest.java
@Test
public void publicMethods() throws Exception {
// Catch API breaking changes.
ImageLoader.getImageListener(null, -1, -1);
mImageLoader.setBatchedResponseDelay(1000);
assertNotNull(ImageLoader.class.getConstructor(RequestQueue.class,
ImageLoader.ImageCache.class));
assertNotNull(ImageLoader.class.getMethod("getImageListener", ImageView.class,
int.class, int.class));
assertNotNull(ImageLoader.class.getMethod("isCached", String.class, int.class, int.class));
assertNotNull(ImageLoader.class.getMethod("isCached", String.class, int.class, int.class,
ImageView.ScaleType.class));
assertNotNull(ImageLoader.class.getMethod("get", String.class,
ImageLoader.ImageListener.class));
assertNotNull(ImageLoader.class.getMethod("get", String.class,
ImageLoader.ImageListener.class, int.class, int.class));
assertNotNull(ImageLoader.class.getMethod("get", String.class,
ImageLoader.ImageListener.class, int.class, int.class, ImageView.ScaleType.class));
assertNotNull(ImageLoader.class.getMethod("setBatchedResponseDelay", int.class));
assertNotNull(ImageLoader.ImageListener.class.getMethod("onResponse",
ImageLoader.ImageContainer.class, boolean.class));
}
项目:GitHub
文件:Volley.java
/**
* Creates a default instance of the worker pool and calls {@link RequestQueue#start()} on it.
*
* @param context A {@link Context} to use for creating the cache dir.
* @param stack An {@link HttpStack} to use for the network, or null for default.
* @return A started {@link RequestQueue} instance.
*/
public static RequestQueue newRequestQueue(Context context, HttpStack stack) {
File cacheDir = new File(context.getCacheDir(), DEFAULT_CACHE_DIR);
String userAgent = "volley/0";
try {
String packageName = context.getPackageName();
PackageInfo info = context.getPackageManager().getPackageInfo(packageName, 0);
userAgent = packageName + "/" + info.versionCode;
} catch (NameNotFoundException e) {
}
if (stack == null) {
if (Build.VERSION.SDK_INT >= 9) {
stack = new HurlStack();
} else {
// Prior to Gingerbread, HttpUrlConnection was unreliable.
// See: http://android-developers.blogspot.com/2011/09/androids-http-clients.html
stack = new HttpClientStack(AndroidHttpClient.newInstance(userAgent));
}
}
Network network = new BasicNetwork(stack);
RequestQueue queue = new RequestQueue(new DiskBasedCache(cacheDir), network);
queue.start();
return queue;
}
项目:GitHub
文件:VolleyUrlLoader.java
private static RequestQueue getInternalQueue(Context context) {
if (internalQueue == null) {
synchronized (Factory.class) {
if (internalQueue == null) {
internalQueue = Volley.newRequestQueue(context);
}
}
}
return internalQueue;
}
项目:GeekZone
文件:BaseRequestQueue.java
/**
* Creates a normal network request instance of the worker pool and calls
* which is based on OkHttpClient
* {@link com.android.volley.RequestQueue#start()} on it.
*/
public static RequestQueue newOkHttpRequestQueue(Context context) {
return newRequestQueue(context,
false,
new OkHttpStack(BaseSSLSocketFactory.getInstance("TLS")),
DEFAULT_NETWORK_THREAD_POOL_SIZE);
}
项目:FlyHttp
文件:VolleyControllerSingleton.java
public RequestQueue getRequestQueue() {
if (mRequestQueue == null) {
// getApplicationContext() is key, it keeps you from leaking the
// Activity or BroadcastReceiver if someone passes one in.
mRequestQueue = Volley.newRequestQueue(mCtx.getApplicationContext());
}
return mRequestQueue;
}
项目:GitHub
文件:VolleyUrlLoader.java
private static RequestQueue getInternalQueue(Context context) {
if (internalQueue == null) {
synchronized (Factory.class) {
if (internalQueue == null) {
internalQueue = Volley.newRequestQueue(context);
}
}
}
return internalQueue;
}
项目:Wings2K16
文件:AppController.java
public RequestQueue getRequestQueue() {
if (mRequestQueue == null) {
mRequestQueue = Volley.newRequestQueue(getApplicationContext());
}
return mRequestQueue;
}
项目:ShotsNewsApp
文件:MySingleton.java
public RequestQueue getRequestQueue()
{
if(requestQueue==null)
{
requestQueue= Volley.newRequestQueue(mContext);
}
return requestQueue;
}
项目:security-config
文件:RemoteDataSource.java
public RemoteDataSource(String url) {
mUrl = url;
// TODO: context should be Application context + this should be a singleton
// mRequestQueue = Volley.newRequestQueue(context.getApplicationContext());
mRequestQueue = new RequestQueue(new NoCache(), new BasicNetwork(new HurlStack()));
//TODO: disable volley cache
mRequestQueue.start();
}
项目:ShotsNewsApp
文件:TestLoginActivity.java
void getImage() //profile pic
{
ImageRequest request = new ImageRequest("http://ec2-52-14-50-89.us-east-2.compute.amazonaws.com/static/userdata/"+email+"/thumb.png", ///"+email+" in btw userdata/ /thumb.png
new Response.Listener<Bitmap>() {
@Override
public void onResponse(Bitmap bitmap) {
pro=bitmap;
ByteArrayOutputStream baos=new ByteArrayOutputStream();
bitmap.compress(Bitmap.CompressFormat.PNG,100, baos);
byte [] b=baos.toByteArray();
String temp= Base64.encodeToString(b, Base64.DEFAULT);
SharedPreferences.Editor editor=sharedPreferences.edit();
editor.putString("profile_pic",temp);
editor.commit();
// Log.e("mytag","Saved propic"+pro);
//count++;
}
}, 0, 0, null,
new Response.ErrorListener() {
public void onErrorResponse(VolleyError error) {
// mImageView.setImageResource(R.drawable.image_load_error);
Log.e("Home_Acitivity","No img found");
//count++;
}
});
// MySingleton.getMyInstance(getApplicationContext()).addToReqQue(request);
RequestQueue queue= Volley.newRequestQueue(TestLoginActivity.this);
queue.add(request);
}
项目:WeatherPlus
文件:AppController.java
public void cancelPendingRequests(final Object tag) {
if (mRequestQueue != null && tag != null) {
mRequestQueue.cancelAll(new RequestQueue.RequestFilter() {
@Override
public boolean apply(Request<?> request) {
return request.getTag().equals(tag);
}
});
}
}
项目:Blockly
文件:LuaActivity.java
/**
* 用于保存XML文件的网络请求
*/
public void andrUpload(){
RequestQueue requestQueue = MyApplication.getRequestQueue();
sharedPreferences = MyApplication.getSharedPreferences();
userId = sharedPreferences.getString("email","");
token = sharedPreferences.getString("token","");
JSONObject jsonObject = new JSONObject();
String fileName = dialogMsg+"_"+getWorkspaceSavePath();
try{
jsonObject.put("fileName",fileName);
jsonObject.put("fileString",AbstractBlocklyActivity.xmltostring);//AbstractBlocklyActivity.xmltostring
jsonObject.put("fileId",0);//这里应该通过一个方法来判断id的值,先暂时写成这样
jsonObject.put("userId",userId);
jsonObject.put("token",token);
}catch (JSONException e){
e.printStackTrace();
}
Log.d("AndrUpload_JsonObj",jsonObject.toString());
JsonObjectRequest jsonObjectRequest = new JsonObjectRequest(Request.Method.POST, url_upload, jsonObject, new Response.Listener<JSONObject>() {
@Override
public void onResponse(JSONObject response) {
uploadReceive uploadReceive = new uploadReceive();
uploadReceive.setStatus(response.optString("status"));
uploadReceive.setErrMsg(response.optString("errMsg"));
Log.d("AndrUpload_Response",response.toString());
judge_upload(uploadReceive.getStatus(),uploadReceive.getErrMsg());
}
}, new Response.ErrorListener() {
@Override
public void onErrorResponse(VolleyError error) {
Log.e("AndrUpload_Error",error.toString(),error);
}
});
requestQueue.add(jsonObjectRequest);
}
项目:BookED
文件:VolleySingleton.java
public RequestQueue getRequestQueue() {
if (mRequestQueue == null) {
// getApplicationContext() is key, it keeps you from leaking the
// Activity or BroadcastReceiver if someone passes one in.
mRequestQueue = Volley.newRequestQueue(mCtx.getApplicationContext());
}
return mRequestQueue;
}
项目:CompassDemo
文件:RegisterActivity.java
private void registerUser() {
Random rand = new Random();
int number = (100000 + rand.nextInt(899999));
final String userid = Integer.toString(number);
final String email = editTextEmail.getText().toString().trim();
final String password = editTextPassword.getText().toString().trim();
final String confirmpassword = editTextConfirmPassword.getText().toString().trim();
StringRequest stringRequest = new StringRequest(Request.Method.POST, UserPref.getRegisterURL(),
new Response.Listener<String>() {
@Override
public void onResponse(String response) {
Toast.makeText(RegisterActivity.this,response,Toast.LENGTH_LONG).show();
Intent intent = new Intent(RegisterActivity.this, MainActivity.class);
startActivity(intent);
finish();
}
},
new Response.ErrorListener() {
@Override
public void onErrorResponse(VolleyError error) {
Toast.makeText(RegisterActivity.this,error.toString(),Toast.LENGTH_LONG).show();
}
}){
@Override
protected Map<String, String> getParams() {
Map<String, String> params = new HashMap<>();
params.put(KEY_USERID, userid);
params.put(KEY_EMAIL, email);
params.put(KEY_PASSWORD, password);
return params;
}
};
RequestQueue requestQueue = Volley.newRequestQueue(this);
requestQueue.add(stringRequest);
}
项目:CompassDemo
文件:UploadLoanImagesActivity.java
private void setloanamount() {
final SharedPreferences sharedPreferences = getSharedPreferences(UserPref.getSharedPrefName(), Context.MODE_PRIVATE);
final String useramount = editTextSendAmount.getText().toString().trim();
final String loanid = sharedPreferences.getString(UserPref.getSearchedloanidSharedPref(), "Not Available");
StringRequest stringRequest = new StringRequest(Request.Method.POST, UserPref.getSetloanUrl(),
new Response.Listener<String>() {
@Override
public void onResponse(String response) {
Toast.makeText(UploadLoanImagesActivity.this,response,Toast.LENGTH_LONG).show();
finish();
}
},
new Response.ErrorListener() {
@Override
public void onErrorResponse(VolleyError error) {
Toast.makeText(UploadLoanImagesActivity.this,error.toString(),Toast.LENGTH_LONG).show();
}
}){
@Override
protected Map<String, String> getParams() {
Map<String, String> params = new HashMap<>();
params.put(KEY_AMOUNT, useramount);
params.put(KEY_LOANID, loanid);
return params;
}
};
RequestQueue requestQueue = Volley.newRequestQueue(this);
requestQueue.add(stringRequest);
}
项目:mybotproject-Android
文件:AppController.java
public RequestQueue getRequestQueue() {
if (mRequestQueue == null) {
mRequestQueue = Volley.newRequestQueue(getApplicationContext());
}
return mRequestQueue;
}
项目:Blockly
文件:LuaActivity.java
/**
* 用于更新XML文件的网络请求
*/
public void andrUpdate(String returnedFileName,String returnedFileId){
RequestQueue requestQueue = MyApplication.getRequestQueue();
sharedPreferences = MyApplication.getSharedPreferences();
userId = sharedPreferences.getString("email","");
token = sharedPreferences.getString("token","");
JSONObject jsonObject = new JSONObject();
String fileName = dialogMsg+"_"+getWorkspaceSavePath();
try{
jsonObject.put("fileName",returnedFileName);
jsonObject.put("fileString",AbstractBlocklyActivity.xmltostring);//AbstractBlocklyActivity.xmltostring
jsonObject.put("fileId",returnedFileId);//这里应该通过一个方法来判断id的值,先暂时写成这样
jsonObject.put("userId",userId);
jsonObject.put("token",token);
}catch (JSONException e){
e.printStackTrace();
}
Log.d("AndrUpdate_JsonObj",jsonObject.toString());
JsonObjectRequest jsonObjectRequest = new JsonObjectRequest(Request.Method.POST, url_upload, jsonObject, new Response.Listener<JSONObject>() {
@Override
public void onResponse(JSONObject response) {
uploadReceive uploadReceive = new uploadReceive();
uploadReceive.setStatus(response.optString("status"));
uploadReceive.setErrMsg(response.optString("errMsg"));
Log.d("AndrUpdate_Response",response.toString());
judge_upload(uploadReceive.getStatus(),uploadReceive.getErrMsg());
}
}, new Response.ErrorListener() {
@Override
public void onErrorResponse(VolleyError error) {
Log.e("AndrUpdate_Error",error.toString(),error);
}
});
requestQueue.add(jsonObjectRequest);
}
项目:GeekZone
文件:BaseRequestQueue.java
/**
* Creates a normal network request instance of the worker pool and calls
* which is based on OkHttpClient
* {@link com.android.volley.RequestQueue#start()} on it.
*/
public static RequestQueue newOkHttpRequestQueueWithoutSSL(Context context) {
return newRequestQueue(context,
false,
new OkHttpStack(),
DEFAULT_NETWORK_THREAD_POOL_SIZE);
}
项目:FancyTab
文件:VolleySingleton.java
private RequestQueue getRequestQueue() {
if (mRequestQueue == null) {
cookieManager = new CookieManager();
CookieHandler.setDefault(cookieManager);
mRequestQueue = Volley.newRequestQueue(mCtx.getApplicationContext());
}
return mRequestQueue;
}
项目:android-perftracking
文件:RuntimeContentProvider.java
@Override
public boolean onCreate() {
Context context = getContext();
if (context == null) {
return false;
}
if (!AppPerformanceConfig.enabled) {
return false; // Return when instrumentation is disabled
}
RequestQueue queue = new RequestQueue(new NoCache(), new BasicNetwork(new HurlStack()));
queue.start();
BatteryInfoStore batteryInfoStore = new BatteryInfoStore(context);
String subscriptionKey = Util.getSubscriptionKey(context);
String configUrlPrefix = Util
.getMeta(context, "com.rakuten.tech.mobile.perf.ConfigurationUrlPrefix");
String relayAppId = Util.getRelayAppId(context);
ConfigStore configStore = new ConfigStore(context, queue, relayAppId, subscriptionKey,
configUrlPrefix);
// Read last config from cache
Config config = createConfig(context, configStore.getObservable().getCachedValue(), relayAppId);
if (config != null) {
String locationUrlPrefix = Util
.getMeta(context, "com.rakuten.tech.mobile.perf.LocationUrlPrefix");
LocationStore locationStore = new LocationStore(context, queue, subscriptionKey,
locationUrlPrefix);
// Initialise Tracking Manager
TrackingManager.initialize(context, config, locationStore.getObservable(),
batteryInfoStore.getObservable());
Metric.start("_launch");
}
return false;
}
项目:android-perftracking
文件:LocationStore.java
LocationStore(@NonNull Context context, @NonNull RequestQueue requestQueue,
@Nullable String subscriptionKey, @Nullable String urlPrefix) {
this.prefs = context.getSharedPreferences(PREFS, Context.MODE_PRIVATE);
this.requestQueue = requestQueue;
this.subscriptionKey = subscriptionKey;
this.urlPrefix = urlPrefix;
this.handler = new Handler(Looper.getMainLooper());
getObservable().publish(readLocationFromCache());
loadLocationFromApi();
handler.postDelayed(periodicLocationCheck, TIME_INTERVAL);
}
项目:android-perftracking
文件:ConfigStore.java
ConfigStore(@NonNull Context context, @NonNull RequestQueue requestQueue,
@NonNull String relayAppId, @Nullable String subscriptionKey, @Nullable String urlPrefix) {
this.packageManager = context.getPackageManager();
this.packageName = context.getPackageName();
this.appId = relayAppId;
this.res = context.getResources();
this.prefs = context.getSharedPreferences(PREFS, Context.MODE_PRIVATE);
this.requestQueue = requestQueue;
this.subscriptionKey = subscriptionKey;
this.urlPrefix = urlPrefix;
getObservable().publish(readConfigFromCache());
handler = new Handler(Looper.getMainLooper());
loadConfigurationFromApi();
handler.postDelayed(periodicCheck, TIME_INTERVAL);
}
项目:eBread
文件:VolleyRequest.java
private RequestQueue getRequestQueue() {
if (mContext == null) { return null; }
if (mRequestQueue == null) {
// getApplicationContext() is key, it keeps you from leaking the
// Activity or BroadcastReceiver if someone passes one in.
mRequestQueue = Volley.newRequestQueue(mContext.getApplicationContext());
}
return mRequestQueue;
}
项目:FrappeSyncAdapter
文件:FrappeNoteApi.java
public RequestQueue getRequestQueue() {
// lazy initialize the request queue, the queue instance will be
// created when it is accessed for the first time
if (mRequestQueue == null) {
mRequestQueue = Volley.newRequestQueue(mContext);
}
return mRequestQueue;
}
项目:FrappeSyncAdapter
文件:FrappeNoteApi.java
public RequestQueue getSerialRequestQueue() {
if (mSerialRequestQueue == null) {
mSerialRequestQueue = prepareSerialRequestQueue(mContext);
mSerialRequestQueue.start();
}
return mSerialRequestQueue;
}
项目:ShotsNewsApp
文件:SplashScreenActivity.java
void getImage() //profile pic
{
ImageRequest request = new ImageRequest("http://ec2-52-14-50-89.us-east-2.compute.amazonaws.com/static/userdata/"+name+"/thumb.png", ///"+email+" in btw userdata/ /thumb.png
new Response.Listener<Bitmap>() {
@Override
public void onResponse(Bitmap bitmap) {
pro=bitmap;
ByteArrayOutputStream baos=new ByteArrayOutputStream();
bitmap.compress(Bitmap.CompressFormat.PNG,100, baos);
byte [] b=baos.toByteArray();
String temp= Base64.encodeToString(b, Base64.DEFAULT);
SharedPreferences.Editor editor=sharedPreferences.edit();
editor.putString("profile_pic",temp);
editor.commit();
Log.e("mytag","Saved propic"+pro);
//count++;
}
}, 0, 0, null,
new Response.ErrorListener() {
public void onErrorResponse(VolleyError error) {
// mImageView.setImageResource(R.drawable.image_load_error);
Log.e("Home_Acitivity","No img found");
//count++;
}
});
// MySingleton.getMyInstance(getApplicationContext()).addToReqQue(request);
RequestQueue queue= Volley.newRequestQueue(getApplicationContext());
queue.add(request);
}
项目:FrappeSyncAdapter
文件:FrappeToDoApi.java
public RequestQueue getRequestQueue() {
// lazy initialize the request queue, the queue instance will be
// created when it is accessed for the first time
if (mRequestQueue == null) {
mRequestQueue = Volley.newRequestQueue(mContext);
}
return mRequestQueue;
}
项目:Blockly
文件:LuaActivity.java
/**
* 用户请求文件列表的网络通信
*/
public void fileListRequest(){
String userId = sharedPreferences.getString("email","");
String token = sharedPreferences.getString("token","");
RequestQueue requestQueue = MyApplication.getRequestQueue();
JSONObject jsonObject = new JSONObject();
try {
jsonObject.put("userId",userId);
jsonObject.put("token",token);
Log.d("fileListRequest_JsonObj",jsonObject.toString());
}catch (JSONException e){
e.printStackTrace();
}
JsonObjectRequest jsonObjectRequest = new JsonObjectRequest(Request.Method.POST, url_filelistrequest, jsonObject, new Response.Listener<JSONObject>() {
@Override
public void onResponse(JSONObject response) {
getListReceive getListReceive = new getListReceive();
getListReceive.setStatus(response.optString("status"));
getListReceive.setErrMsg(response.optString("errMsg"));
getListReceive.setJsonObject(response.optJSONObject("jsonStrArray"));
Log.d("getFileList_Response",response.toString());
judge_fileListRequest(getListReceive.getStatus(),getListReceive.getErrMsg(),getListReceive.getJsonObject());
}
}, new Response.ErrorListener() {
@Override
public void onErrorResponse(VolleyError error) {
Log.e("fileListRequest_Error",error.toString(),error);
}
});
requestQueue.add(jsonObjectRequest);
}
项目:CoolClock
文件:NetworkService.java
private RequestQueue getRequestQueue() {
if (mRequestQueue == null) {
mRequestQueue =
Volley.newRequestQueue(ClockApplication.getContext());
}
return mRequestQueue;
}
项目:GeekZone
文件:BaseRequestQueue.java
/**
* Creates a normal network request instance of the worker pool and calls
* {@link com.android.volley.RequestQueue#start()} on it.
*/
public static RequestQueue newNormalRequestQueue(Context context, String hostName) {
return newRequestQueue(context,
false,
new BaseStack(null, BaseSSLSocketFactory.getInstance("TLS"), hostName),
DEFAULT_NETWORK_THREAD_POOL_SIZE);
}
项目:super-volley
文件:SuperVolley.java
SuperVolley(RequestQueue requestQueue, okhttp3.HttpUrl baseUrl,
List<Converter.Factory> converterFactories, List<CallAdapter.Factory> adapterFactories,
Executor callbackExecutor, boolean validateEagerly) {
this.baseUrl = baseUrl;
this.converterFactories = unmodifiableList(converterFactories); // Defensive copy at call site.
this.adapterFactories = unmodifiableList(adapterFactories); // Defensive copy at call site.
this.callbackExecutor = callbackExecutor;
this.validateEagerly = validateEagerly;
this.requestQueue = requestQueue;
this.requestQueue.start();
}
项目:chat-sdk-android-push-firebase
文件:VolleyUtils.java
public static RequestQueue getRequestQueue() {
if (mRequestQueue != null) {
return mRequestQueue;
} else {
throw new IllegalStateException("RequestQueue not initialized");
}
}
项目:Codeforces
文件:Volley.java
/**
* Creates a default instance of the worker pool and calls {@link RequestQueue#start()} on it.
*
* @param context A {@link Context} to use for creating the cache dir.
* @param stack An {@link HttpStack} to use for the network, or null for default.
* @return A started {@link RequestQueue} instance.
*/
public static RequestQueue newRequestQueue(Context context, HttpStack stack) {
File cacheDir = new File(context.getCacheDir(), DEFAULT_CACHE_DIR);
String userAgent = "volley/0";
try {
String packageName = context.getPackageName();
PackageInfo info = context.getPackageManager().getPackageInfo(packageName, 0);
userAgent = packageName + "/" + info.versionCode;
} catch (NameNotFoundException e) {
}
if (stack == null) {
if (Build.VERSION.SDK_INT >= 9) {
stack = new HurlStack();
} else {
// Prior to Gingerbread, HttpUrlConnection was unreliable.
// See: http://android-developers.blogspot.com/2011/09/androids-http-clients.html
stack = new HttpClientStack(AndroidHttpClient.newInstance(userAgent));
}
}
Network network = new BasicNetwork(stack);
RequestQueue queue = new RequestQueue(new DiskBasedCache(cacheDir), network);
queue.start();
return queue;
}