import java.util.stream.IntStream;
import static org.junit.Assert.*;
import static org.mockito.Matchers.any;
import static org.mockito.Mockito.*;
@SuppressWarnings("unchecked")
<BUG>public class DeviceNotificationServiceTest extends AbstractSpringKafkaTest {
</BUG>
@Autowired
private DeviceNotificationService notificationService;
@Autowired

import java.util.stream.IntStream;
import static org.junit.Assert.*;
import static org.mockito.Matchers.any;
import static org.mockito.Mockito.*;
@SuppressWarnings("unchecked")
public class DeviceNotificationServiceTest extends AbstractResourceTest {
@Autowired
private DeviceNotificationService notificationService;
@Autowired
