PowerMockito错误

Question

需要快速帮助。我试图写一个测试类，并得到以下错误 “无法解析方法.thenreturn（org.apache.kafka.clients.producer）

@Test 
public void testPublishData_Success() throws java.lang.Exception { 
    when(GetPropValues.getPropValue(PublisherConstants.ATMID)).thenReturn("ATM"); 
    when(GetPropValues.getPropValue(PublisherConstants.DATA_SOURCE)).thenReturn("PCE"); 

    ReadAndWriteFiles mockFiles = Mockito.mock(ReadAndWriteFiles.class); 
    PowerMockito.whenNew(ReadAndWriteFiles.class).withNoArguments().thenReturn(mockFiles); 
    Mockito.when(mockFiles.getAllFiles()).thenReturn("someValue"); 

    KafkaProducer mockProducer = Mockito.mock(KafkaProducer.class); 
    PowerMockito.whenNew(KafkaProducer.class).withAnyArguments().thenReturn(mockProducer); 

    producer.publishData(null, "Test", "Data1"); 
} 

Powermockito是罚款，返回ReadAndWriteFiles.class对象，但它。抛出一个错误KafkaProducer.class在线

PowerMockito.whenNew(KafkaProducer.class).withAnyArguments().thenReturn(mockProducer); 

是否有任何其他的方式来进行这项工作各地的任何建议，可以理解

注：？KafkaProducer.class是不是一个自定义类但它的内部来自apa车火花卡夫卡库

主要代码是按以下

KafkaProducer<String, String> producer = new KafkaProducer<String, String>(props); 
      InputData inputMessage; 
      try { 
       inputMessage = populateData(timeStamp, dataCategory, data, atmId, topic); 
       ReadAndWriteFiles readerWriter = new ReadAndWriteFiles(); 
       File[] directory = readerWriter.getAllFiles(); 
       if (directory != null && directory.length > 0) { 
        if (connectionSet && !publishingData) { 
         sendDataFromFiles(producer, directory); 
         publishingData = false; 
        } 
       } else { 
        producer.send(keyedMsg, new KafkaResponseHandler(inputMessage)); 
       } 

      } catch (IOException e) { 

      } 

Answer 1

我认为错误是

KafkaProducer mockProducer = Mockito.mock(KafkaProducer.class); 
PowerMockito.whenNew(ReadAndWriteFiles.class).withAnyArguments().thenReturn(mockProducer) 

我想返回的值应该是ReadAndWriteFiles类不是KafkaProducer

一个模拟

ReadAndWriteFiles readMock = Mockito.mock(ReadAndWriteFiles.class) 
PowerMockito.whenNew(ReadAndWriteFiles.class).withAnyArguments().thenReturn(readMock) 

Mockito.when(readMock.getAllFiles()).thenReturn(anArrayOfFiles); 

4819的签名方法如下

OngoingStubbing<T> [More ...] thenReturn(T value); 

所以，你正在使用，以返回ReadAndWriteFiles你shouls返回相同的类