import org.opendaylight.yang.gen.v1.urn.opendaylight.group.service.rev130918.SalGroupService;
import org.opendaylight.yang.gen.v1.urn.opendaylight.group.service.rev130918.UpdateGroupInputBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.group.service.rev130918.group.update.UpdatedGroupBuilder;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.group.types.rev131018.GroupId;
import org.opendaylight.yang.gen.v1.urn.opendaylight.group.types.rev131018.GroupTypes;
import org.opendaylight.yang.gen.v1.urn.opendaylight.group.types.rev131018.group.Buckets;
import org.opendaylight.yang.gen.v1.urn.opendaylight.group.types.rev131018.group.buckets.Bucket;
UpdateGroupInputBuilder groupData = new UpdateGroupInputBuilder();
updateGroupBuilder = new UpdatedGroupBuilder();
+ updateGroupBuilder.setGroupId(new GroupId(groupUpdateDataObject.getId()));
updateGroupBuilder.fieldsFrom(groupUpdateDataObject);
groupData.setUpdatedGroup(updateGroupBuilder.build());
groupService.updateGroup(groupData.build());
AddGroupInputBuilder groupData = new AddGroupInputBuilder();
groupData.setBuckets(groupAddDataObject.getBuckets());
groupData.setContainerName(groupAddDataObject.getContainerName());
- groupData.setGroupId(groupAddDataObject.getGroupId());
+ groupData.setGroupId(new GroupId(groupAddDataObject.getId()));
groupData.setGroupType(groupAddDataObject.getGroupType());
groupData.setNode(groupAddDataObject.getNode());
groupService.addGroup(groupData.build());
RemoveGroupInputBuilder groupData = new RemoveGroupInputBuilder();
groupData.setBuckets(groupRemoveDataObject.getBuckets());
groupData.setContainerName(groupRemoveDataObject.getContainerName());
- groupData.setGroupId(groupRemoveDataObject.getGroupId());
+ groupData.setGroupId(new GroupId(groupRemoveDataObject.getId()));
groupData.setGroupType(groupRemoveDataObject.getGroupType());
groupData.setNode(groupRemoveDataObject.getNode());
groupService.removeGroup(groupData.build());
for (Entry<InstanceIdentifier<?>, Group> entry : transaction.updates.entrySet()) {
- if (!updateGroup(entry.getKey(), entry.getValue()).isSuccess()) {
+ if (!addGroup(entry.getKey(), entry.getValue()).isSuccess()) {
transaction.updates.remove(entry.getKey());
return Rpcs.getRpcResult(false, null, Collections.<RpcError>emptySet());
}
if (null != meterKey && validateMeter(meterUpdateDataObject, FRMUtil.operation.UPDATE).isSuccess()) { UpdateMeterInputBuilder updateMeterInputBuilder = new UpdateMeterInputBuilder();
updateMeterBuilder = new UpdatedMeterBuilder();
updateMeterBuilder.fieldsFrom(meterUpdateDataObject);
+ updateMeterBuilder.setMeterId(new MeterId(meterUpdateDataObject.getId()));
+
updateMeterInputBuilder.setUpdatedMeter(updateMeterBuilder.build());
meterService.updateMeter(updateMeterInputBuilder.build());
} else {
meterBuilder.setNode(meterRemoveDataObject.getNode());
meterBuilder.setFlags(meterRemoveDataObject.getFlags());
meterBuilder.setMeterBandHeaders(meterRemoveDataObject.getMeterBandHeaders());
- meterBuilder.setMeterId(meterRemoveDataObject.getMeterId());
+ meterBuilder.setMeterId(new MeterId(meterRemoveDataObject.getId()));
meterBuilder.setNode(meterRemoveDataObject.getNode());
meterService.removeMeter(meterBuilder.build());
} else {