@Test
public void testInterceptorAbort() throws Exception {

    final TTransport transport = new FlushableMemoryBuffer(4096);
    final com.meituan.firefly.testfirefly.TestService testService = thrift.create(com.meituan.firefly.testfirefly.TestService.class, new Thrift.SimpleTProtocolFactory() {
        @Override
        public TProtocol get() {
            return new TBinaryProtocol(transport);
        }
    }, new Interceptor() {
        @Override
        public Object intercept(Method method, Object[] args, TProtocol protocol, int seqId, Processor processor) throws Throwable {
            return null;
        }
    });
    NotifyCheck notifyCheck = new NotifyCheck(100);
    com.meituan.firefly.testthrift.TestService.Processor<Iface> processor = new com.meituan.firefly.testthrift.TestService.Processor<Iface>(notifyCheck);
    testService.notify(100);
    try {
        processor.process(new TBinaryProtocol(transport), new TBinaryProtocol(transport));
        Assert.assertFalse(notifyCheck.notified);
    } catch (TException e) {
    }
    Assertions.assertThat(notifyCheck.notified).isFalse();
}