@Test public void getContext() throws Exception { RpcInvokeContext old = RpcInvokeContext.peekContext(); try { if (old != null) { RpcInvokeContext.removeContext(); } RpcInvokeContext context = RpcInvokeContext.peekContext(); Assert.assertTrue(context == null); context = RpcInvokeContext.getContext(); Assert.assertTrue(context != null); RpcInvokeContext.removeContext(); Assert.assertTrue(RpcInvokeContext.peekContext() == null); context = new RpcInvokeContext(); RpcInvokeContext.setContext(context); Assert.assertTrue(RpcInvokeContext.getContext() != null); Assert.assertEquals(RpcInvokeContext.getContext(), context); RpcInvokeContext.removeContext(); Assert.assertTrue(RpcInvokeContext.peekContext() == null); Assert.assertTrue(context != null); RpcInvokeContext.removeContext(); Assert.assertTrue(RpcInvokeContext.peekContext() == null); } finally { RpcInvokeContext.setContext(old); } }
public static RpcInvokeContext getContext() { RpcInvokeContext context = LOCAL.get(); if (context == null) { context = new RpcInvokeContext(); LOCAL.set(context); } return context; }
RpcInvokeContext { public static RpcInvokeContext getContext() { RpcInvokeContext context = LOCAL.get(); if (context == null) { context = new RpcInvokeContext(); LOCAL.set(context); } return context; } }
RpcInvokeContext { public static RpcInvokeContext getContext() { RpcInvokeContext context = LOCAL.get(); if (context == null) { context = new RpcInvokeContext(); LOCAL.set(context); } return context; }  }
RpcInvokeContext { public static RpcInvokeContext getContext() { RpcInvokeContext context = LOCAL.get(); if (context == null) { context = new RpcInvokeContext(); LOCAL.set(context); } return context; }  static RpcInvokeContext getContext(); static RpcInvokeContext peekContext(); static void removeContext(); static void setContext(RpcInvokeContext context); static boolean isBaggageEnable(); Integer getTimeout(); RpcInvokeContext setTimeout(Integer timeout); void put(String key, Object value); Object get(String key); Object remove(String key); void putRequestBaggage(String key, String value); String getRequestBaggage(String key); String removeRequestBaggage(String key); Map<String, String> getAllRequestBaggage(); void putAllRequestBaggage(Map<String, String> requestBaggage); void putResponseBaggage(String key, String value); String getResponseBaggage(String key); String removeResponseBaggage(String key); Map<String, String> getAllResponseBaggage(); void putAllResponseBaggage(Map<String, String> responseBaggage); String getTargetURL(); RpcInvokeContext setTargetURL(String targetURL); String getTargetGroup(); RpcInvokeContext setTargetGroup(String targetGroup); SofaResponseCallback getResponseCallback(); RpcInvokeContext setResponseCallback(SofaResponseCallback responseCallback); @SuppressWarnings("unchecked") ResponseFuture<T> getFuture(); RpcInvokeContext setFuture(ResponseFuture<?> future); @Override String toString(); }
RpcInvokeContext { public static RpcInvokeContext getContext() { RpcInvokeContext context = LOCAL.get(); if (context == null) { context = new RpcInvokeContext(); LOCAL.set(context); } return context; }  static RpcInvokeContext getContext(); static RpcInvokeContext peekContext(); static void removeContext(); static void setContext(RpcInvokeContext context); static boolean isBaggageEnable(); Integer getTimeout(); RpcInvokeContext setTimeout(Integer timeout); void put(String key, Object value); Object get(String key); Object remove(String key); void putRequestBaggage(String key, String value); String getRequestBaggage(String key); String removeRequestBaggage(String key); Map<String, String> getAllRequestBaggage(); void putAllRequestBaggage(Map<String, String> requestBaggage); void putResponseBaggage(String key, String value); String getResponseBaggage(String key); String removeResponseBaggage(String key); Map<String, String> getAllResponseBaggage(); void putAllResponseBaggage(Map<String, String> responseBaggage); String getTargetURL(); RpcInvokeContext setTargetURL(String targetURL); String getTargetGroup(); RpcInvokeContext setTargetGroup(String targetGroup); SofaResponseCallback getResponseCallback(); RpcInvokeContext setResponseCallback(SofaResponseCallback responseCallback); @SuppressWarnings("unchecked") ResponseFuture<T> getFuture(); RpcInvokeContext setFuture(ResponseFuture<?> future); @Override String toString();  }