@Test public void createEntity() { LeaseAcquirerClientService clientService = new LeaseAcquirerClientService(); LeaseAcquirer leaseAcquirer = clientService.create(endpoint, null); leaseAcquirer.close(); verify(endpoint).close(); }
@Override public LeaseAcquirer create(EntityClientEndpoint<LeaseMessage, LeaseResponse> endpoint, LeaseReconnectListener reconnectListener) { return new LeaseAcquirerImpl(endpoint, reconnectListener); }
LeaseAcquirerClientService implements EntityClientService<LeaseAcquirer, Void, LeaseMessage, LeaseResponse, LeaseReconnectListener> { @Override public LeaseAcquirer create(EntityClientEndpoint<LeaseMessage, LeaseResponse> endpoint, LeaseReconnectListener reconnectListener) { return new LeaseAcquirerImpl(endpoint, reconnectListener); } }
LeaseAcquirerClientService implements EntityClientService<LeaseAcquirer, Void, LeaseMessage, LeaseResponse, LeaseReconnectListener> { @Override public LeaseAcquirer create(EntityClientEndpoint<LeaseMessage, LeaseResponse> endpoint, LeaseReconnectListener reconnectListener) { return new LeaseAcquirerImpl(endpoint, reconnectListener); }  }
LeaseAcquirerClientService implements EntityClientService<LeaseAcquirer, Void, LeaseMessage, LeaseResponse, LeaseReconnectListener> { @Override public LeaseAcquirer create(EntityClientEndpoint<LeaseMessage, LeaseResponse> endpoint, LeaseReconnectListener reconnectListener) { return new LeaseAcquirerImpl(endpoint, reconnectListener); }  @Override boolean handlesEntityType(Class<LeaseAcquirer> c); @Override byte[] serializeConfiguration(Void aVoid); @Override Void deserializeConfiguration(byte[] bytes); @Override LeaseAcquirer create(EntityClientEndpoint<LeaseMessage, LeaseResponse> endpoint, LeaseReconnectListener reconnectListener); @Override MessageCodec<LeaseMessage, LeaseResponse> getMessageCodec(); }
LeaseAcquirerClientService implements EntityClientService<LeaseAcquirer, Void, LeaseMessage, LeaseResponse, LeaseReconnectListener> { @Override public LeaseAcquirer create(EntityClientEndpoint<LeaseMessage, LeaseResponse> endpoint, LeaseReconnectListener reconnectListener) { return new LeaseAcquirerImpl(endpoint, reconnectListener); }  @Override boolean handlesEntityType(Class<LeaseAcquirer> c); @Override byte[] serializeConfiguration(Void aVoid); @Override Void deserializeConfiguration(byte[] bytes); @Override LeaseAcquirer create(EntityClientEndpoint<LeaseMessage, LeaseResponse> endpoint, LeaseReconnectListener reconnectListener); @Override MessageCodec<LeaseMessage, LeaseResponse> getMessageCodec();  }