public void executePopPullRequestImmediately(final PopRequest popRequest) {
        try {
            this.messageRequestQueue.put(popRequest);
        } catch (InterruptedException e) {
            logger.error("executePullRequestImmediately pullRequestQueue.put", e);
        }
    }
@Test
    public void testExecutePopPullRequestImmediately() throws IllegalAccessException, InterruptedException {
        PopRequest popRequest = mock(PopRequest.class);
        LinkedBlockingQueue<MessageRequest> messageRequestQueue = mock(LinkedBlockingQueue.class);
        FieldUtils.writeDeclaredField(pullMessageService, "messageRequestQueue", messageRequestQueue, true);
        pullMessageService.executePopPullRequestImmediately(popRequest);
        verify(messageRequestQueue, times(1)).put(any(PopRequest.class));
    }