message.setMoreReplies(Boolean.FALSE);
message.setTransactionId(emulatedTxId);
- message.setMeterConfigStats(new ArrayList<MeterConfigStats>());
+ message.setMeterConfigStats(new ArrayList<>());
for (MultipartReply mpReply : result) {
MultipartReplyMeterConfigCase caseBody = (MultipartReplyMeterConfigCase) mpReply.getMultipartReplyBody();
MultipartReplyMeterConfig replyBody = caseBody.getMultipartReplyMeterConfig();
notification.setMoreReplies(Boolean.FALSE);
notification.setTransactionId(emulatedTxId);
- notification.setGroupDescStats(new ArrayList<GroupDescStats>());
+ notification.setGroupDescStats(new ArrayList<>());
final VersionConvertorData data = new VersionConvertorData(getVersion());
for (MultipartReply mpReply : result) {
notification.setMoreReplies(Boolean.FALSE);
notification.setTransactionId(emulatedTxId);
- notification.setGroupStats(new ArrayList<GroupStats>());
+ notification.setGroupStats(new ArrayList<>());
for (MultipartReply mpReply : mpReplyList) {
MultipartReplyGroupCase caseBody = (MultipartReplyGroupCase) mpReply.getMultipartReplyBody();
notification.setMoreReplies(Boolean.FALSE);
notification.setTransactionId(emulatedTxId);
- notification.setMeterStats(new ArrayList<MeterStats>());
+ notification.setMeterStats(new ArrayList<>());
for (MultipartReply mpReply : mpReplyList) {
MultipartReplyMeterCase caseBody = (MultipartReplyMeterCase) mpReply.getMultipartReplyBody();
MultipartReplyMeter replyBody = caseBody.getMultipartReplyMeter();
notification.setTransactionId(emulatedTxId);
notification
- .setNodeConnectorStatisticsAndPortNumberMap(new ArrayList<NodeConnectorStatisticsAndPortNumberMap>());
+ .setNodeConnectorStatisticsAndPortNumberMap(new ArrayList<>());
for (MultipartReply mpReply : mpReplyList) {
MultipartReplyPortStatsCase caseBody = (MultipartReplyPortStatsCase) mpReply.getMultipartReplyBody();
notification.setMoreReplies(Boolean.FALSE);
notification.setTransactionId(emulatedTxId);
- notification.setQueueIdAndStatisticsMap(new ArrayList<QueueIdAndStatisticsMap>());
+ notification.setQueueIdAndStatisticsMap(new ArrayList<>());
for (MultipartReply mpReply : mpReplyList) {
MultipartReplyQueueCase caseBody = (MultipartReplyQueueCase) mpReply.getMultipartReplyBody();
when(mockedDeviceContext.getDeviceState()).thenReturn(mockedDeviceState);
final ConvertorManager convertorManager = ConvertorManagerFactory.createDefaultManager();
- final StatisticsContextImpl<MultipartReply> statisticsContext = new StatisticsContextImpl<MultipartReply>(
- mockedDeviceContext ,convertorManager,
+ final StatisticsContextImpl<MultipartReply> statisticsContext = new StatisticsContextImpl<>(
+ mockedDeviceContext, convertorManager,
MultipartWriterProviderFactory.createDefaultProvider(mockedDeviceContext),
true, false, 3000, 50000);
}
private void initStatisticsContext() {
- statisticsContext = new StatisticsContextImpl<MultipartReply>(
+ statisticsContext = new StatisticsContextImpl<>(
mockedDeviceContext, convertorManager,
MultipartWriterProviderFactory.createDefaultProvider(mockedDeviceContext),
true,
*/
@Test
public void testClose() throws Exception {
- final StatisticsContextImpl<MultipartReply> statisticsContext = new StatisticsContextImpl<MultipartReply>(
+ final StatisticsContextImpl<MultipartReply> statisticsContext = new StatisticsContextImpl<>(
mockedDeviceContext, convertorManager,
MultipartWriterProviderFactory.createDefaultProvider(mockedDeviceContext),
true, false, 3000, 50000);