TepCommandHelper { public boolean isInCache(Uint64 dpnId, String ipAddress, String transportZone) throws TepException { boolean exists = false; final VtepsKey vtepkey = new VtepsKey(dpnId); IpAddress ipAddressObj = IpAddressBuilder.getDefaultInstance(ipAddress); Vteps vtepCli = new VtepsBuilder().setDpnId(dpnId).setIpAddress(ipAddressObj).withKey(vtepkey).build(); if (transportZonesHashMap.containsKey(transportZone)) { List<Vteps> vtepListTemp = transportZonesHashMap.get(transportZone); if (vtepListTemp.contains(vtepCli)) { exists = true; vtepListTemp.remove(vtepCli); if (vtepListTemp.size() == 0) { transportZonesHashMap.remove(transportZone); } } else { handleError("Vtep has not been configured"); } } return exists; } @Inject  TepCommandHelper(final DataBroker dataBroker, final ItmConfig itmConfig,
                            final UnprocessedTunnelsStateCache unprocessedTunnelsStateCache); @PostConstruct void start(); @PreDestroy void close(); @SuppressWarnings("checkstyle:IllegalCatch") void createLocalCache(Uint64 dpnId, String ipAddress,
                                 String transportZone); TransportZone getTransportZone(String transportZoneName); TransportZones getAllTransportZones(); boolean checkTepPerTzPerDpn(String tzone, Uint64 dpnId); @SuppressWarnings("checkstyle:IllegalCatch") void buildTeps(); List<String> showTeps(boolean monitorEnabled, int monitorInterval); @SuppressWarnings("checkstyle:RegexpSinglelineJava") void showCache(String cacheName); @SuppressWarnings("checkstyle:IllegalCatch") void deleteVtep(Uint64 dpnId, String ipAddress,
                           String transportZone); @SuppressWarnings("checkstyle:IllegalCatch") void deleteOnCommit(); @SuppressWarnings("checkstyle:RegexpSinglelineJava") void showState(Collection<StateTunnelList> tunnelLists, boolean tunnelMonitorEnabled); void showBridges(Map<Uint64, OvsdbBridgeRef> dpnIdBridgeRefMap); boolean isInCache(Uint64 dpnId, String ipAddress,
                             String transportZone); void configureTunnelType(String transportZoneName, String tunnelType); void configureTunnelMonitorParams(boolean monitorEnabled, String monitorProtocol); void configureTunnelMonitorInterval(int interval); void handleError(String errorMessage); @SuppressWarnings("checkstyle:RegexpSinglelineJava") void showOfPorts(Collection<OfTep> ofTeps);  }
@Test public void testIsInCache() { try { tepCommandHelper.createLocalCache(dpId1, tepIp1, transportZone1); tepCommandHelper.isInCache(dpId1, tepIp1 ,transportZone1); } catch (TepException e) { LOG.error(e.getMessage()); } verify(mockReadTx).read(LogicalDatastoreType.CONFIGURATION,transportZoneIdentifier); }