@Test
    public void testPickupFromResponse() {
        SofaResponse sofaResponse = new SofaResponse();
        RpcInvokeContext context = RpcInvokeContext.getContext();
        context.putResponseBaggage(KEY, VALUE);
        sofaResponse.addResponseProp(RemotingConstants.RPC_RESPONSE_BAGGAGE + ".key", VALUE);
        sofaResponse.addResponseProp(RemotingConstants.RPC_RESPONSE_BAGGAGE + ".key2", null);
        BaggageResolver.pickupFromResponse(context, sofaResponse);
        assertEquals(VALUE, RpcInvokeContext.getContext().getAllResponseBaggage().get(KEY));
        assertEquals(null, RpcInvokeContext.getContext().getAllResponseBaggage().get("key2"));
        assertEquals(1, RpcInvokeContext.getContext().getAllResponseBaggage().size());
        assertEquals(SafeConcurrentHashMap.class, RpcInvokeContext.getContext()
            .getAllResponseBaggage().getClass());
    }
@author <a href=mailto:orezsilence@163.com>zhangchengxi</a>
core/api/src/test/java/com/alipay/sofa/rpc/context/BaggageResolverTest.java