- public void testMountPoint() {
-
- testContext.getBindingDataBroker().readOperationalData(NODE_INSTANCE_ID_BA);
-
- MountProvisionInstance domMountPoint = domMountPointService.createMountPoint(NODE_INSTANCE_ID_BI);
- assertNotNull(domMountPoint);
- MountProviderInstance bindingMountPoint = bindingMountPointService.getMountPoint(NODE_INSTANCE_ID_BA);
- assertNotNull(bindingMountPoint);
-
- final BigInteger packetCount = BigInteger.valueOf(500L);
-
-
- DataReader<org.opendaylight.yangtools.yang.data.api.InstanceIdentifier, CompositeNode> simpleReader = new DataReader<org.opendaylight.yangtools.yang.data.api.InstanceIdentifier, CompositeNode>() {
-
- @Override
- public CompositeNode readConfigurationData(org.opendaylight.yangtools.yang.data.api.InstanceIdentifier arg0) {
- return null;
- }
-
-
- @Override
- public CompositeNode readOperationalData(org.opendaylight.yangtools.yang.data.api.InstanceIdentifier arg0) {
- if (arg0.equals(GROUP_STATISTICS_ID_BI)) {
- ImmutableCompositeNode data = ImmutableCompositeNode
- .builder()
- .setQName(AUGMENTED_GROUP_STATISTICS)
- .addLeaf(QName.create(AUGMENTED_GROUP_STATISTICS, "packet-count"), packetCount) //
- .toInstance();
-
- return data;
+ public void testMountPoint() throws ReadFailedException, TimeoutException {
+ final Integer attrIntValue = 500;
+ domMountPointService.createMountPoint(TLL_INSTANCE_ID_BI)
+ .addService(DOMDataBroker.class, new DOMDataBroker() {
+
+ @Override
+ public ListenerRegistration<DOMDataChangeListener> registerDataChangeListener(
+ final LogicalDatastoreType store, final YangInstanceIdentifier path,
+ final DOMDataChangeListener listener, final DataChangeScope triggeringScope) {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public DOMDataWriteTransaction newWriteOnlyTransaction() {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public DOMDataReadWriteTransaction newReadWriteTransaction() {
+ return new DOMDataReadWriteTransaction() {
+
+ @Override
+ public CheckedFuture<Optional<NormalizedNode<?, ?>>, ReadFailedException> read(
+ final LogicalDatastoreType store, final YangInstanceIdentifier path) {
+ if (store == LogicalDatastoreType.OPERATIONAL && path.getLastPathArgument()
+ .equals(GROUP_STATISTICS_ID_BI.getLastPathArgument())) {
+
+ final ContainerNode data = Builders.containerBuilder()
+ .withNodeIdentifier(new NodeIdentifier(AUG_CONT))
+ .withChild(ImmutableNodes.leafNode(QName.create(AUG_CONT, "attr-int"),
+ attrIntValue))
+ .build();
+
+ return Futures.immediateCheckedFuture(Optional.<NormalizedNode<?,?>>of(data));
+ }
+ return Futures.immediateFailedCheckedFuture(new ReadFailedException(TLL_NAME,
+ new Exception()));
+ }
+
+ @Override
+ public CheckedFuture<Boolean, ReadFailedException> exists(final LogicalDatastoreType store,
+ final YangInstanceIdentifier path) {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public Object getIdentifier() {
+ return this;
+ }
+
+ @Override
+ public boolean cancel() {
+ return false;
+ }
+
+ @Override
+ public void delete(final LogicalDatastoreType store, final YangInstanceIdentifier path) {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public void merge(final LogicalDatastoreType store, final YangInstanceIdentifier path,
+ final NormalizedNode<?, ?> data) {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public void put(final LogicalDatastoreType store, final YangInstanceIdentifier path,
+ final NormalizedNode<?, ?> data) {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
+ public CheckedFuture<Void, TransactionCommitFailedException> submit() {
+ throw new UnsupportedOperationException();
+ }
+
+ };