diff --git a/.gitignore b/.gitignore
new file mode 100644
index 0000000..f1b77db
--- /dev/null
+++ b/.gitignore
@@ -0,0 +1,17 @@
+.gradle
+.idea
+**/build/
+**/target/
+**/out/
+
+# Ignore Gradle GUI config
+gradle-app.setting
+
+# Avoid ignoring Gradle wrapper jar file (.jar files are usually ignored)
+!gradle-wrapper.jar
+
+*.iml
+
+*.log
+
+*.toDelete
\ No newline at end of file
diff --git a/HEADER b/HEADER
new file mode 100644
index 0000000..90705e0
--- /dev/null
+++ b/HEADER
@@ -0,0 +1,16 @@
+Licensed to the Apache Software Foundation (ASF) under one
+or more contributor license agreements.  See the NOTICE file
+distributed with this work for additional information
+regarding copyright ownership.  The ASF licenses this file
+to you under the Apache License, Version 2.0 (the
+"License"); you may not use this file except in compliance
+with the License.  You may obtain a copy of the License at
+
+  http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing,
+software distributed under the License is distributed on an
+"AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+KIND, either express or implied.  See the License for the
+specific language governing permissions and limitations
+under the License.
\ No newline at end of file
diff --git a/LICENSE b/LICENSE
new file mode 100644
index 0000000..8dada3e
--- /dev/null
+++ b/LICENSE
@@ -0,0 +1,201 @@
+                                 Apache License
+                           Version 2.0, January 2004
+                        http://www.apache.org/licenses/
+
+   TERMS AND CONDITIONS FOR USE, REPRODUCTION, AND DISTRIBUTION
+
+   1. Definitions.
+
+      "License" shall mean the terms and conditions for use, reproduction,
+      and distribution as defined by Sections 1 through 9 of this document.
+
+      "Licensor" shall mean the copyright owner or entity authorized by
+      the copyright owner that is granting the License.
+
+      "Legal Entity" shall mean the union of the acting entity and all
+      other entities that control, are controlled by, or are under common
+      control with that entity. For the purposes of this definition,
+      "control" means (i) the power, direct or indirect, to cause the
+      direction or management of such entity, whether by contract or
+      otherwise, or (ii) ownership of fifty percent (50%) or more of the
+      outstanding shares, or (iii) beneficial ownership of such entity.
+
+      "You" (or "Your") shall mean an individual or Legal Entity
+      exercising permissions granted by this License.
+
+      "Source" form shall mean the preferred form for making modifications,
+      including but not limited to software source code, documentation
+      source, and configuration files.
+
+      "Object" form shall mean any form resulting from mechanical
+      transformation or translation of a Source form, including but
+      not limited to compiled object code, generated documentation,
+      and conversions to other media types.
+
+      "Work" shall mean the work of authorship, whether in Source or
+      Object form, made available under the License, as indicated by a
+      copyright notice that is included in or attached to the work
+      (an example is provided in the Appendix below).
+
+      "Derivative Works" shall mean any work, whether in Source or Object
+      form, that is based on (or derived from) the Work and for which the
+      editorial revisions, annotations, elaborations, or other modifications
+      represent, as a whole, an original work of authorship. For the purposes
+      of this License, Derivative Works shall not include works that remain
+      separable from, or merely link (or bind by name) to the interfaces of,
+      the Work and Derivative Works thereof.
+
+      "Contribution" shall mean any work of authorship, including
+      the original version of the Work and any modifications or additions
+      to that Work or Derivative Works thereof, that is intentionally
+      submitted to Licensor for inclusion in the Work by the copyright owner
+      or by an individual or Legal Entity authorized to submit on behalf of
+      the copyright owner. For the purposes of this definition, "submitted"
+      means any form of electronic, verbal, or written communication sent
+      to the Licensor or its representatives, including but not limited to
+      communication on electronic mailing lists, source code control systems,
+      and issue tracking systems that are managed by, or on behalf of, the
+      Licensor for the purpose of discussing and improving the Work, but
+      excluding communication that is conspicuously marked or otherwise
+      designated in writing by the copyright owner as "Not a Contribution."
+
+      "Contributor" shall mean Licensor and any individual or Legal Entity
+      on behalf of whom a Contribution has been received by Licensor and
+      subsequently incorporated within the Work.
+
+   2. Grant of Copyright License. Subject to the terms and conditions of
+      this License, each Contributor hereby grants to You a perpetual,
+      worldwide, non-exclusive, no-charge, royalty-free, irrevocable
+      copyright license to reproduce, prepare Derivative Works of,
+      publicly display, publicly perform, sublicense, and distribute the
+      Work and such Derivative Works in Source or Object form.
+
+   3. Grant of Patent License. Subject to the terms and conditions of
+      this License, each Contributor hereby grants to You a perpetual,
+      worldwide, non-exclusive, no-charge, royalty-free, irrevocable
+      (except as stated in this section) patent license to make, have made,
+      use, offer to sell, sell, import, and otherwise transfer the Work,
+      where such license applies only to those patent claims licensable
+      by such Contributor that are necessarily infringed by their
+      Contribution(s) alone or by combination of their Contribution(s)
+      with the Work to which such Contribution(s) was submitted. If You
+      institute patent litigation against any entity (including a
+      cross-claim or counterclaim in a lawsuit) alleging that the Work
+      or a Contribution incorporated within the Work constitutes direct
+      or contributory patent infringement, then any patent licenses
+      granted to You under this License for that Work shall terminate
+      as of the date such litigation is filed.
+
+   4. Redistribution. You may reproduce and distribute copies of the
+      Work or Derivative Works thereof in any medium, with or without
+      modifications, and in Source or Object form, provided that You
+      meet the following conditions:
+
+      (a) You must give any other recipients of the Work or
+          Derivative Works a copy of this License; and
+
+      (b) You must cause any modified files to carry prominent notices
+          stating that You changed the files; and
+
+      (c) You must retain, in the Source form of any Derivative Works
+          that You distribute, all copyright, patent, trademark, and
+          attribution notices from the Source form of the Work,
+          excluding those notices that do not pertain to any part of
+          the Derivative Works; and
+
+      (d) If the Work includes a "NOTICE" text file as part of its
+          distribution, then any Derivative Works that You distribute must
+          include a readable copy of the attribution notices contained
+          within such NOTICE file, excluding those notices that do not
+          pertain to any part of the Derivative Works, in at least one
+          of the following places: within a NOTICE text file distributed
+          as part of the Derivative Works; within the Source form or
+          documentation, if provided along with the Derivative Works; or,
+          within a display generated by the Derivative Works, if and
+          wherever such third-party notices normally appear. The contents
+          of the NOTICE file are for informational purposes only and
+          do not modify the License. You may add Your own attribution
+          notices within Derivative Works that You distribute, alongside
+          or as an addendum to the NOTICE text from the Work, provided
+          that such additional attribution notices cannot be construed
+          as modifying the License.
+
+      You may add Your own copyright statement to Your modifications and
+      may provide additional or different license terms and conditions
+      for use, reproduction, or distribution of Your modifications, or
+      for any such Derivative Works as a whole, provided Your use,
+      reproduction, and distribution of the Work otherwise complies with
+      the conditions stated in this License.
+
+   5. Submission of Contributions. Unless You explicitly state otherwise,
+      any Contribution intentionally submitted for inclusion in the Work
+      by You to the Licensor shall be under the terms and conditions of
+      this License, without any additional terms or conditions.
+      Notwithstanding the above, nothing herein shall supersede or modify
+      the terms of any separate license agreement you may have executed
+      with Licensor regarding such Contributions.
+
+   6. Trademarks. This License does not grant permission to use the trade
+      names, trademarks, service marks, or product names of the Licensor,
+      except as required for reasonable and customary use in describing the
+      origin of the Work and reproducing the content of the NOTICE file.
+
+   7. Disclaimer of Warranty. Unless required by applicable law or
+      agreed to in writing, Licensor provides the Work (and each
+      Contributor provides its Contributions) on an "AS IS" BASIS,
+      WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
+      implied, including, without limitation, any warranties or conditions
+      of TITLE, NON-INFRINGEMENT, MERCHANTABILITY, or FITNESS FOR A
+      PARTICULAR PURPOSE. You are solely responsible for determining the
+      appropriateness of using or redistributing the Work and assume any
+      risks associated with Your exercise of permissions under this License.
+
+   8. Limitation of Liability. In no event and under no legal theory,
+      whether in tort (including negligence), contract, or otherwise,
+      unless required by applicable law (such as deliberate and grossly
+      negligent acts) or agreed to in writing, shall any Contributor be
+      liable to You for damages, including any direct, indirect, special,
+      incidental, or consequential damages of any character arising as a
+      result of this License or out of the use or inability to use the
+      Work (including but not limited to damages for loss of goodwill,
+      work stoppage, computer failure or malfunction, or any and all
+      other commercial damages or losses), even if such Contributor
+      has been advised of the possibility of such damages.
+
+   9. Accepting Warranty or Additional Liability. While redistributing
+      the Work or Derivative Works thereof, You may choose to offer,
+      and charge a fee for, acceptance of support, warranty, indemnity,
+      or other liability obligations and/or rights consistent with this
+      License. However, in accepting such obligations, You may act only
+      on Your own behalf and on Your sole responsibility, not on behalf
+      of any other Contributor, and only if You agree to indemnify,
+      defend, and hold each Contributor harmless for any liability
+      incurred by, or claims asserted against, such Contributor by reason
+      of your accepting any such warranty or additional liability.
+
+   END OF TERMS AND CONDITIONS
+
+   APPENDIX: How to apply the Apache License to your work.
+
+      To apply the Apache License to your work, attach the following
+      boilerplate notice, with the fields enclosed by brackets "{}"
+      replaced with your own identifying information. (Don't include
+      the brackets!)  The text should be enclosed in the appropriate
+      comment syntax for the file format. We also recommend that a
+      file or class name and description of purpose be included on the
+      same "printed page" as the copyright notice for easier
+      identification within third-party archives.
+
+   Copyright {yyyy} {name of copyright owner}
+
+   Licensed under the Apache License, Version 2.0 (the "License");
+   you may not use this file except in compliance with the License.
+   You may obtain a copy of the License at
+
+       http://www.apache.org/licenses/LICENSE-2.0
+
+   Unless required by applicable law or agreed to in writing, software
+   distributed under the License is distributed on an "AS IS" BASIS,
+   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+   See the License for the specific language governing permissions and
+   limitations under the License.
diff --git a/NOTICE.txt b/NOTICE.txt
new file mode 100644
index 0000000..822eedb
--- /dev/null
+++ b/NOTICE.txt
@@ -0,0 +1,5 @@
+Apache Fineract CN Provisioner
+Copyright [2017-2018] The Apache Software Foundation
+
+This product includes software developed at
+The Apache Software Foundation (http://www.apache.org/).
\ No newline at end of file
diff --git a/README.md b/README.md
index 07a4dd0..93c01b6 100644
--- a/README.md
+++ b/README.md
@@ -1 +1,26 @@
-fineract-cn-interoperation
+# Apache Fineract CN Provisioner
+
+This service provisions services for tenants of an Apache Fineract CN installation.
+
+## Abstract
+Apache Fineract CN is an application framework for digital financial services, a system to support nationwide and cross-national financial transactions and help to level and speed the creation of an inclusive, interconnected digital economy for every nation in the world.
+
+## Versioning
+The version numbers follow the [Semantic Versioning](http://semver.org/) scheme.
+
+In addition to MAJOR.MINOR.PATCH the following postfixes are used to indicate the development state.
+
+* BUILD-SNAPSHOT - A release currently in development.
+* M - A _milestone_ release include specific sets of functions and are released as soon as the functionality is complete.
+* RC - A _release candidate_ is a version with potential to be a final product, considered _code complete_.
+* RELEASE - indicates that this release is the best available version and is recommended for all usage.
+
+The versioning layout is {MAJOR}.{MINOR}.{PATCH}-{INDICATOR}[.{PATCH}]. Only milestones and release candidates can  have patch versions. Some examples:
+
+1.2.3-BUILD-SNAPSHOT
+1.3.5-M.1
+1.5.7-RC.2
+2.0.0-RELEASE
+
+## License
+See [LICENSE](LICENSE) file.
diff --git a/api/build.gradle b/api/build.gradle
new file mode 100644
index 0000000..883c7ca
--- /dev/null
+++ b/api/build.gradle
@@ -0,0 +1,54 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+buildscript {
+    repositories {
+        jcenter()
+    }
+
+    dependencies {
+        classpath 'io.spring.gradle:dependency-management-plugin:0.6.0.RELEASE'
+    }
+}
+
+plugins {
+    id "com.github.hierynomus.license" version "0.13.1"
+    id("org.nosphere.apache.rat") version "0.3.1"
+}
+
+apply from: '../shared.gradle'
+
+dependencies {
+    compile(
+            [group: 'org.springframework.cloud', name: 'spring-cloud-starter-feign'],
+            [group: 'org.apache.fineract.cn', name: 'api', version: versions.frameworkapi],
+            [group: 'org.hibernate', name: 'hibernate-validator', version: versions.validator],
+            [group: 'org.hibernate', name: 'hibernate-validator-annotation-processor', version: versions.validator],
+            [group: 'org.apache.fineract.cn.deposit-account-management', name: 'api', version: versions.frameworkdeposit]
+    )
+}
+
+publishing {
+    publications {
+        api(MavenPublication) {
+            from components.java
+            groupId project.group
+            artifactId project.name
+            version project.version
+        }
+    }
+}
diff --git a/api/settings.gradle b/api/settings.gradle
new file mode 100644
index 0000000..491f745
--- /dev/null
+++ b/api/settings.gradle
@@ -0,0 +1,18 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+rootProject.name = 'api'
\ No newline at end of file
diff --git a/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/EventConstants.java b/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/EventConstants.java
new file mode 100644
index 0000000..d2d3faf
--- /dev/null
+++ b/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/EventConstants.java
@@ -0,0 +1,31 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.fineract.cn.interoperation.api.v1;
+
+@SuppressWarnings("unused")
+public interface EventConstants {
+
+  String DESTINATION = "interoperation-v1";
+  String SELECTOR_NAME = "action";
+
+  String OPERATION_HEADER = "operation";
+  String INITIALIZE = "initialize";
+  String SELECTOR_INITIALIZE = OPERATION_HEADER + " = '" + INITIALIZE + "'";
+
+}
diff --git a/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/PermittableGroupIds.java b/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/PermittableGroupIds.java
new file mode 100644
index 0000000..bfee891
--- /dev/null
+++ b/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/PermittableGroupIds.java
@@ -0,0 +1,29 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.fineract.cn.interoperation.api.v1;
+
+/**
+ * @author Myrle Krantz
+ */
+@SuppressWarnings("unused")
+public interface PermittableGroupIds {
+
+  String INTEROPERATION_SINGLE = "interoperation__v1__single";
+  String INTEROPERATION_BULK = "interoperation__v1__bulk";
+}
diff --git a/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/client/InteroperationManager.java b/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/client/InteroperationManager.java
new file mode 100644
index 0000000..0692273
--- /dev/null
+++ b/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/client/InteroperationManager.java
@@ -0,0 +1,39 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.fineract.cn.interoperation.api.v1.client;
+
+import org.apache.fineract.cn.api.util.CustomFeignClientsConfiguration;
+import org.springframework.cloud.netflix.feign.FeignClient;
+import org.springframework.http.MediaType;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
+
+@SuppressWarnings("unused")
+@FeignClient(value = "interoperation-v1", path = "/interoperation/v1", configuration = CustomFeignClientsConfiguration.class)
+public interface InteroperationManager {
+
+    @RequestMapping(
+            value = "/health",
+            method = RequestMethod.GET,
+            consumes = MediaType.ALL_VALUE,
+            produces = MediaType.APPLICATION_JSON_VALUE
+    )
+    void fetchActions();
+
+}
diff --git a/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/InteropActionState.java b/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/InteropActionState.java
new file mode 100644
index 0000000..4bb4001
--- /dev/null
+++ b/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/InteropActionState.java
@@ -0,0 +1,24 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.fineract.cn.interoperation.api.v1.domain;
+
+public enum InteropActionState {
+    ACCEPTED,
+    REJECTED
+}
diff --git a/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/InteropActionType.java b/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/InteropActionType.java
new file mode 100644
index 0000000..7e72a73
--- /dev/null
+++ b/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/InteropActionType.java
@@ -0,0 +1,31 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.fineract.cn.interoperation.api.v1.domain;
+
+public enum InteropActionType {
+
+    REQUEST,
+    QUOTE,
+    PREPARE,
+    COMMIT,
+    ABORT,
+    ;
+
+    public static InteropActionType[] VALUES = values();
+}
diff --git a/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/InteropAmountType.java b/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/InteropAmountType.java
new file mode 100644
index 0000000..02dafe4
--- /dev/null
+++ b/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/InteropAmountType.java
@@ -0,0 +1,25 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.fineract.cn.interoperation.api.v1.domain;
+
+public enum InteropAmountType {
+
+    SEND,
+    RECEIVE
+}
diff --git a/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/InteropIdentifierType.java b/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/InteropIdentifierType.java
new file mode 100644
index 0000000..08780f4
--- /dev/null
+++ b/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/InteropIdentifierType.java
@@ -0,0 +1,31 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.fineract.cn.interoperation.api.v1.domain;
+
+public enum InteropIdentifierType {
+
+    MSISDN,
+    EMAIL,
+    PERSONAL_ID,
+    BUSINESS,
+    DEVICE,
+    ACCOUNT_ID,
+    IBAN,
+    ALIAS
+}
diff --git a/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/InteropInitiatorType.java b/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/InteropInitiatorType.java
new file mode 100644
index 0000000..376a571
--- /dev/null
+++ b/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/InteropInitiatorType.java
@@ -0,0 +1,27 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.fineract.cn.interoperation.api.v1.domain;
+
+public enum InteropInitiatorType {
+
+    CONSUMER,
+    AGENT,
+    BUSINESS,
+    DEVICE
+}
diff --git a/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/InteropState.java b/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/InteropState.java
new file mode 100644
index 0000000..3cc7505
--- /dev/null
+++ b/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/InteropState.java
@@ -0,0 +1,49 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.fineract.cn.interoperation.api.v1.domain;
+
+public enum InteropState {
+
+    REQUESTED,
+    QUOTED,
+    PREPARED,
+    COMMITTED,
+    ABORTED,
+    ;
+
+    public static InteropState[] VALUES = values();
+
+
+    public static InteropState forAction(InteropActionType action) {
+        switch (action) {
+            case REQUEST:
+                return REQUESTED;
+            case QUOTE:
+                return QUOTED;
+            case PREPARE:
+                return PREPARED;
+            case COMMIT:
+                return COMMITTED;
+            case ABORT:
+                return ABORTED;
+            default:
+                return null; // TODO fail
+        }
+    }
+}
diff --git a/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/InteropStateMachine.java b/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/InteropStateMachine.java
new file mode 100644
index 0000000..e5bc409
--- /dev/null
+++ b/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/InteropStateMachine.java
@@ -0,0 +1,57 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.fineract.cn.interoperation.api.v1.domain;
+
+import org.apache.fineract.cn.lang.ServiceException;
+
+import javax.validation.constraints.NotNull;
+
+public class InteropStateMachine {
+
+    private InteropStateMachine() {
+
+    }
+
+    /**
+     * Executes the given transition from one status to another when the given transition (actualEvent + action) is valid.
+     *
+     * @param currentState actual {@link InteropState}
+     * @param action        the {@link InteropActionType}
+     * @return the new {@link InteropState} for the tag if the given transition is valid
+     *
+     */
+    public static InteropState handleTransition(InteropState currentState, @NotNull InteropActionType action) {
+        InteropState transitionState = getTransitionState(currentState, action);
+        if (transitionState == null) {
+            throw new ServiceException("State transition is not valid: ({0}) and action: ({1})", currentState, action);
+        }
+        return transitionState;
+    }
+
+    public static boolean isValidAction(InteropState currentState, @NotNull InteropActionType action) {
+        if (currentState == null || action == InteropActionType.ABORT)
+            return true;
+        InteropState transitionState = getTransitionState(currentState, action);
+        return transitionState != null && transitionState.ordinal() > currentState.ordinal();
+    }
+
+    private static InteropState getTransitionState(InteropState currentState, @NotNull InteropActionType action) {
+        return InteropState.forAction(action);
+    }
+}
diff --git a/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/InteropTransactionRole.java b/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/InteropTransactionRole.java
new file mode 100644
index 0000000..2a0b800
--- /dev/null
+++ b/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/InteropTransactionRole.java
@@ -0,0 +1,34 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.fineract.cn.interoperation.api.v1.domain;
+
+public enum InteropTransactionRole {
+
+    PAYER,
+    PAYEE,
+    ;
+
+    public boolean isWithdraw() {
+        return this == PAYER;
+    }
+
+    public TransactionType getTransactionType() {
+        return this == PAYER ? TransactionType.CURRENCY_WITHDRAWAL : TransactionType.CURRENCY_DEPOSIT;
+    }
+}
diff --git a/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/InteropTransactionScenario.java b/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/InteropTransactionScenario.java
new file mode 100644
index 0000000..de5b776
--- /dev/null
+++ b/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/InteropTransactionScenario.java
@@ -0,0 +1,28 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.fineract.cn.interoperation.api.v1.domain;
+
+public enum InteropTransactionScenario {
+
+    DEPOSIT,
+    WITHDRAWAL,
+    TRANSFER,
+    PAYMENT,
+    REFUND
+}
diff --git a/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/InteropTransferActionType.java b/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/InteropTransferActionType.java
new file mode 100644
index 0000000..3f48ecb
--- /dev/null
+++ b/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/InteropTransferActionType.java
@@ -0,0 +1,26 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.fineract.cn.interoperation.api.v1.domain;
+
+public enum InteropTransferActionType {
+
+    PREPARE,
+    CREATE,
+    ;
+}
diff --git a/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/TransactionType.java b/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/TransactionType.java
new file mode 100644
index 0000000..3ecf30e
--- /dev/null
+++ b/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/TransactionType.java
@@ -0,0 +1,106 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.fineract.cn.interoperation.api.v1.domain;
+
+/**
+ * @code org.apache.fineract.cn.accounting.service.internal.repository.AccountEntryEntity.type
+ */
+public enum TransactionType {
+
+    ACCOUNT_OPENING("ACCO"),
+    ACCOUNT_CLOSING("ACCC"),
+    ACCOUNT_TRANSFER("ACCT"),
+
+    ACH_CREDIT("ACDT"),
+    ACH_DEBIT("ADBT"),
+    ACH_ADJUSTMENTS("ADJT"),
+    ACH_PREAUTHORISED("APAC"),
+    ACH_RETURN("ARET"),
+    ACH_REVERSAL("AREV"),
+    ACH_SETTLEMENT("ASET"),
+    ACH_TRANSACTION("ATXN"),
+
+    ARP_DEBIT("ARPD"),
+    CURRENCY_DEPOSIT("FCDP"),
+    CURRENCY_WITHDRAWAL("FCWD"),
+
+    BRANCH_TRANSFER("BACT"),
+    BRANCH_DEPOSIT("BCDP"),
+    BRANCH_WITHDRAWAL("BCWD"),
+
+    CASH_DEPOSIT("CDPT"),
+    CASH_WITHDRAWAL("CWDL"),
+    CASH_LETTER("CASH"),
+
+    CHEQUE("CCHQ"),
+    BRANCH_CHEQUE("BCHQ"),
+    CERTIFIED_CHEQUE("CCCH"),
+    CROSSED_CHEQUE("CRCQ"),
+    CHEQUE_REVERSAL("CQRV"),
+    CHEQUE_OPEN("OPCQ"),
+    CHEQUE_ORDER("ORCQ"),
+
+    CHARGES_PAYMENT("CHRG"),
+    FEES_PAYMENT("FEES"),
+    TAXES_PAYMENT("TAXE"),
+    PRINCIPAL_PAYMENT("PPAY"),
+    INTEREST_PAYMENT("INTR"),
+
+    DIRECTDEBIT_PAYMENT("PMDD"),
+    DIRECTDEBIT_PREAUTHORISED("PADD"),
+    BRANCH_DIRECTDEBIT("BBDD"),
+
+    SMARTCARD_PAYMENT("SMRT"),
+    POINTOFSALE_CREDITCARD("POSC"),
+    POINTOFSALE_DEBITCARD("POSD"),
+    POINTOFSALE_PAYMENT("POSP"),
+
+    DOMESTIC_CREDIT("DMCT"),
+    INTRACOMPANY_TRANSFER("ICCT"),
+
+    MIXED_DEPOSIT("MIXD"),
+    MISCELLANEOUS_DEPOSIT("MSCD"),
+    OTHER("OTHR"),
+
+    CONTROLLED_DISBURSEMENT("CDIS"),
+    CONTROLLED_DISBURSEMENT2("DSBR"),
+    CREDIT_ADJUSTMENT("CAJT"),
+    DEBIT_ADJUSTMENT("DAJT"),
+    EXCHANGERATE_ADJUSTMENT("ERTA"),
+    YID_ADJUSTMENT("YTDA"),
+    REIMBURSEMENT("RIMB"),
+    DRAWDOWN("DDWN"),
+
+    ERROR_NOTAVAILABLE("NTAV"),
+    ERROR_POSTING("PSTE"),
+    ERROR_CANCELLATION("RCDD"),
+    ERROR_CANCELLATION2("RPCR"),
+    ERROR_ZEROBALANCE("ZABA"),
+    ;
+
+    private final String code;
+
+    TransactionType(String code) {
+        this.code = code;
+    }
+
+    public String getCode() {
+        return code;
+    }
+}
diff --git a/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/data/ExtensionData.java b/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/data/ExtensionData.java
new file mode 100644
index 0000000..7cd7e3f
--- /dev/null
+++ b/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/data/ExtensionData.java
@@ -0,0 +1,58 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.fineract.cn.interoperation.api.v1.domain.data;
+
+import org.hibernate.validator.constraints.Length;
+
+import javax.validation.constraints.NotNull;
+
+public class ExtensionData {
+
+    @NotNull
+    @Length(min = 1, max = 128)
+    private String key;
+
+    @NotNull
+    @Length(min = 1, max = 128)
+    private String value;
+
+    protected ExtensionData() {
+    }
+
+    public ExtensionData(@NotNull String key, @NotNull String value) {
+        this.key = key;
+        this.value = value;
+    }
+
+    public String getKey() {
+        return key;
+    }
+
+    public String getValue() {
+        return value;
+    }
+
+    protected void setKey(String key) {
+        this.key = key;
+    }
+
+    protected void setValue(String value) {
+        this.value = value;
+    }
+}
diff --git a/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/data/GeoCodeData.java b/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/data/GeoCodeData.java
new file mode 100644
index 0000000..ca862db
--- /dev/null
+++ b/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/data/GeoCodeData.java
@@ -0,0 +1,57 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.fineract.cn.interoperation.api.v1.domain.data;
+
+import javax.validation.constraints.NotNull;
+import javax.validation.constraints.Pattern;
+
+public class GeoCodeData {
+
+    @NotNull
+    @Pattern(regexp = "^(\\+|-)?(?:90(?:(?:\\.0{1,6})?)|(?:[0-9]|[1-8][0-9])(?:(?:\\.[0-9]{1,6})?))$")
+    private String latitude;
+
+    @NotNull
+    @Pattern(regexp = "^(\\+|-)?(?:180(?:(?:\\.0{1,6})?)|(?:[0-9]|[1-9][0-9]|1[0-7][0-9])(?:(?:\\.[0-9]{1,6})?))$")
+    private String longitude;
+
+    protected GeoCodeData() {
+    }
+
+    public GeoCodeData(String latitude, String longitude) {
+        this.latitude = latitude;
+        this.longitude = longitude;
+    }
+
+    public String getLatitude() {
+        return latitude;
+    }
+
+    public String getLongitude() {
+        return longitude;
+    }
+
+    protected void setLatitude(String latitude) {
+        this.latitude = latitude;
+    }
+
+    protected void setLongitude(String longitude) {
+        this.longitude = longitude;
+    }
+}
diff --git a/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/data/InteropIdentifierCommand.java b/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/data/InteropIdentifierCommand.java
new file mode 100644
index 0000000..ed66827
--- /dev/null
+++ b/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/data/InteropIdentifierCommand.java
@@ -0,0 +1,61 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.fineract.cn.interoperation.api.v1.domain.data;
+
+import org.apache.fineract.cn.interoperation.api.v1.domain.InteropIdentifierType;
+import org.hibernate.validator.constraints.Length;
+import org.hibernate.validator.constraints.NotEmpty;
+
+import javax.validation.constraints.NotNull;
+
+public class InteropIdentifierCommand extends InteropIdentifierData {
+
+    @NotNull
+    private InteropIdentifierType idType;
+    @NotEmpty
+    @Length(max = 128)
+    private String idValue;
+    @Length(max = 128)
+    private String subIdOrType;
+
+
+    protected InteropIdentifierCommand() {
+    }
+
+    public InteropIdentifierCommand(@NotNull InteropIdentifierData requestData, @NotNull InteropIdentifierType idType, @NotNull String idValue, String subIdOrType) {
+        super(requestData.getAccountId());
+        this.idType = idType;
+        this.idValue = idValue;
+        this.subIdOrType = subIdOrType;
+    }
+
+    @NotNull
+    public InteropIdentifierType getIdType() {
+        return idType;
+    }
+
+    @NotNull
+    public String getIdValue() {
+        return idValue;
+    }
+
+    public String getSubIdOrType() {
+        return subIdOrType;
+    }
+}
diff --git a/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/data/InteropIdentifierData.java b/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/data/InteropIdentifierData.java
new file mode 100644
index 0000000..1872135
--- /dev/null
+++ b/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/data/InteropIdentifierData.java
@@ -0,0 +1,48 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.fineract.cn.interoperation.api.v1.domain.data;
+
+import org.hibernate.validator.constraints.Length;
+import org.hibernate.validator.constraints.NotEmpty;
+
+import javax.validation.constraints.NotNull;
+
+public class InteropIdentifierData {
+
+    @NotEmpty
+    @Length(max = 32)
+    private String accountId;
+
+
+    protected InteropIdentifierData() {
+    }
+
+    public InteropIdentifierData(@NotNull String accountId) {
+        this.accountId = accountId;
+    }
+
+    @NotNull
+    public String getAccountId() {
+        return accountId;
+    }
+
+    protected void setAccountId(String accountId) {
+        this.accountId = accountId;
+    }
+}
diff --git a/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/data/InteropIdentifierDeleteCommand.java b/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/data/InteropIdentifierDeleteCommand.java
new file mode 100644
index 0000000..a98294f
--- /dev/null
+++ b/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/data/InteropIdentifierDeleteCommand.java
@@ -0,0 +1,59 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.fineract.cn.interoperation.api.v1.domain.data;
+
+import org.apache.fineract.cn.interoperation.api.v1.domain.InteropIdentifierType;
+import org.hibernate.validator.constraints.Length;
+import org.hibernate.validator.constraints.NotEmpty;
+
+import javax.validation.constraints.NotNull;
+
+public class InteropIdentifierDeleteCommand {
+
+    @NotNull
+    private InteropIdentifierType idType;
+    @NotEmpty
+    @Length(max = 128)
+    private String idValue;
+    @Length(max = 128)
+    private String subIdOrType;
+
+
+    protected InteropIdentifierDeleteCommand() {
+    }
+
+    public InteropIdentifierDeleteCommand(@NotNull InteropIdentifierType idType, @NotNull String idValue, String subIdOrType) {
+        this.idType = idType;
+        this.idValue = idValue;
+        this.subIdOrType = subIdOrType;
+    }
+
+    @NotNull
+    public InteropIdentifierType getIdType() {
+        return idType;
+    }
+
+    @NotNull
+    public String getIdValue() {
+        return idValue;
+    }
+
+    public String getSubIdOrType() {
+        return subIdOrType;
+    }}
diff --git a/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/data/InteropQuoteRequestData.java b/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/data/InteropQuoteRequestData.java
new file mode 100644
index 0000000..4eaa853
--- /dev/null
+++ b/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/data/InteropQuoteRequestData.java
@@ -0,0 +1,117 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.fineract.cn.interoperation.api.v1.domain.data;
+
+import org.apache.fineract.cn.deposit.api.v1.definition.domain.Currency;
+import org.apache.fineract.cn.interoperation.api.v1.domain.InteropActionType;
+import org.apache.fineract.cn.interoperation.api.v1.domain.InteropAmountType;
+import org.apache.fineract.cn.interoperation.api.v1.domain.InteropTransactionRole;
+
+import javax.validation.Valid;
+import javax.validation.constraints.NotNull;
+import javax.validation.constraints.Pattern;
+import java.beans.Transient;
+import java.time.LocalDateTime;
+import java.util.List;
+
+
+public class InteropQuoteRequestData extends InteropRequestData {
+
+    @NotNull
+    @Pattern(regexp = "^[0-9a-f]{8}-[0-9a-f]{4}-[1-5][0-9a-f]{3}-[89ab][0-9a-f]{3}-[0-9a-f]{12}$")
+    private String quoteCode;
+
+    @NotNull
+    private InteropAmountType amountType;
+
+    @Valid
+    private MoneyData fees; // only for disclosed Payer fees on the Payee side
+
+    private InteropQuoteRequestData() {
+        super();
+    }
+
+    public InteropQuoteRequestData(@NotNull String transactionCode, String requestCode, @NotNull String accountId, @NotNull MoneyData amount,
+                                   @NotNull InteropTransactionRole transactionRole, @NotNull InteropTransactionTypeData transactionType,
+                                   String note, GeoCodeData geoCode, LocalDateTime expiration, List<ExtensionData> extensionList,
+                                   @NotNull String quoteCode, @NotNull InteropAmountType amountType, MoneyData fees) {
+        super(transactionCode, requestCode, accountId, amount, transactionRole, transactionType, note, geoCode, expiration, extensionList);
+        this.quoteCode = quoteCode;
+        this.amountType = amountType;
+        this.fees = fees;
+    }
+
+    public InteropQuoteRequestData(@NotNull String transactionCode, @NotNull String accountId, @NotNull InteropAmountType amountType,
+                                   @NotNull MoneyData amount, @NotNull InteropTransactionRole transactionRole, @NotNull InteropTransactionTypeData transactionType,
+                                   @NotNull String quoteCode) {
+        this(transactionCode, null, accountId, amount, transactionRole, transactionType, null, null, null, null, quoteCode,
+                amountType, null);
+    }
+
+    private InteropQuoteRequestData(@NotNull InteropRequestData other, @NotNull String quoteCode, @NotNull InteropAmountType amountType,
+                                    MoneyData fees) {
+        this(other.getTransactionCode(), other.getRequestCode(), other.getAccountId(), other.getAmount(), other.getTransactionRole(),
+                other.getTransactionType(), other.getNote(), other.getGeoCode(), other.getExpiration(), other.getExtensionList(),
+                quoteCode, amountType, fees);
+    }
+
+    public String getQuoteCode() {
+        return quoteCode;
+    }
+
+    public InteropAmountType getAmountType() {
+        return amountType;
+    }
+
+    public MoneyData getFees() {
+        return fees;
+    }
+
+    public void normalizeAmounts(@NotNull Currency currency) {
+        super.normalizeAmounts(currency);
+        if (fees != null)
+            fees.normalizeAmount(currency);
+    }
+
+    protected void setQuoteCode(String quoteCode) {
+        this.quoteCode = quoteCode;
+    }
+
+    protected void setAmountType(InteropAmountType amountType) {
+        this.amountType = amountType;
+    }
+
+    protected void setFees(MoneyData fees) {
+        this.fees = fees;
+    }
+
+    @NotNull
+    @Transient
+    @Override
+    public InteropActionType getActionType() {
+        return InteropActionType.QUOTE;
+    }
+
+    @Transient
+    @NotNull
+    @Override
+    public String getIdentifier() {
+        return quoteCode;
+    }
+}
diff --git a/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/data/InteropQuoteResponseData.java b/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/data/InteropQuoteResponseData.java
new file mode 100644
index 0000000..f572b8d
--- /dev/null
+++ b/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/data/InteropQuoteResponseData.java
@@ -0,0 +1,69 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.fineract.cn.interoperation.api.v1.domain.data;
+
+import org.apache.fineract.cn.interoperation.api.v1.domain.InteropActionState;
+
+import javax.validation.constraints.NotNull;
+import java.time.LocalDateTime;
+import java.util.List;
+
+public class InteropQuoteResponseData extends InteropResponseData {
+
+    @NotNull
+    private final String quoteCode;
+
+    private MoneyData fspFee;
+
+    private MoneyData fspCommission;
+
+    private InteropQuoteResponseData(@NotNull String transactionCode, @NotNull InteropActionState state, LocalDateTime expiration, List<ExtensionData> extensionList, @NotNull String quoteCode,
+                                     MoneyData fspFee, MoneyData fspCommission) {
+        super(transactionCode, state, expiration, extensionList);
+        this.quoteCode = quoteCode;
+        this.fspFee = fspFee;
+        this.fspCommission = fspCommission;
+    }
+
+    public static InteropQuoteResponseData build(@NotNull String transactionCode, @NotNull InteropActionState state, LocalDateTime expiration, List<ExtensionData> extensionList,
+                                                 @NotNull String quoteCode, MoneyData fspFee, MoneyData fspCommission) {
+        return new InteropQuoteResponseData(transactionCode, state, expiration, extensionList, quoteCode, fspFee, fspCommission);
+    }
+
+    public static InteropQuoteResponseData build(@NotNull String transactionCode, @NotNull InteropActionState state, LocalDateTime expiration, @NotNull String quoteCode,
+                                                 MoneyData fspFee, MoneyData fspCommission) {
+        return build(transactionCode, state, expiration, null, quoteCode, fspFee, fspCommission);
+    }
+
+    public String getQuoteCode() {
+        return quoteCode;
+    }
+
+    public MoneyData getFspFee() {
+        return fspFee;
+    }
+
+    public MoneyData getFspCommission() {
+        return fspCommission;
+    }
+
+    public void setFspCommission(MoneyData fspCommission) {
+        this.fspCommission = fspCommission;
+    }
+}
diff --git a/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/data/InteropRequestData.java b/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/data/InteropRequestData.java
new file mode 100644
index 0000000..c8a5444
--- /dev/null
+++ b/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/data/InteropRequestData.java
@@ -0,0 +1,195 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.fineract.cn.interoperation.api.v1.domain.data;
+
+import org.apache.fineract.cn.deposit.api.v1.definition.domain.Currency;
+import org.apache.fineract.cn.interoperation.api.v1.domain.InteropActionType;
+import org.apache.fineract.cn.interoperation.api.v1.domain.InteropTransactionRole;
+import org.hibernate.validator.constraints.Length;
+import org.hibernate.validator.constraints.NotEmpty;
+
+import javax.validation.Valid;
+import javax.validation.constraints.NotNull;
+import javax.validation.constraints.Pattern;
+import javax.validation.constraints.Size;
+import java.beans.Transient;
+import java.time.LocalDate;
+import java.time.LocalDateTime;
+import java.util.List;
+
+public abstract class InteropRequestData {
+
+    public static final String IDENTIFIER_SEPARATOR = "_";
+
+    @NotNull
+    @Pattern(regexp = "^[0-9a-f]{8}-[0-9a-f]{4}-[1-5][0-9a-f]{3}-[89ab][0-9a-f]{3}-[0-9a-f]{12}$")
+    private String transactionCode;
+
+    @Pattern(regexp = "^[0-9a-f]{8}-[0-9a-f]{4}-[1-5][0-9a-f]{3}-[89ab][0-9a-f]{3}-[0-9a-f]{12}$")
+    private String requestCode;
+
+    @NotEmpty
+    @Length(max = 32)
+    private String accountId;
+
+    @NotNull
+    @Valid
+    private MoneyData amount;
+
+    @NotNull
+    private InteropTransactionRole transactionRole;
+
+    @Valid
+    private InteropTransactionTypeData transactionType;
+
+    @Length(max = 128)
+    private String note;
+
+    @Valid
+    private GeoCodeData geoCode;
+
+    private LocalDateTime expiration;
+
+    @Size(max = 16)
+    @Valid
+    private List<ExtensionData> extensionList;
+
+    protected InteropRequestData() {
+    }
+
+    protected InteropRequestData(@NotNull String transactionCode, String requestCode, @NotNull String accountId, @NotNull MoneyData amount,
+                                 @NotNull InteropTransactionRole transactionRole, InteropTransactionTypeData transactionType, String note,
+                                 GeoCodeData geoCode, LocalDateTime expiration, List<ExtensionData> extensionList) {
+        this.transactionCode = transactionCode;
+        this.requestCode = requestCode;
+        this.accountId = accountId;
+        this.amount = amount;
+        this.transactionType = transactionType;
+        this.transactionRole = transactionRole;
+        this.note = note;
+        this.geoCode = geoCode;
+        this.expiration = expiration;
+        this.extensionList = extensionList;
+    }
+
+    protected InteropRequestData(@NotNull String transactionCode, @NotNull String accountId, @NotNull MoneyData amount, @NotNull InteropTransactionRole transactionRole) {
+        this(transactionCode, null, accountId, amount, transactionRole, null, null, null, null, null);
+    }
+
+    @NotNull
+    public String getTransactionCode() {
+        return transactionCode;
+    }
+
+    public String getRequestCode() {
+        return requestCode;
+    }
+
+    @NotNull
+    public String getAccountId() {
+        return accountId;
+    }
+
+    @NotNull
+    public MoneyData getAmount() {
+        return amount;
+    }
+
+    public InteropTransactionTypeData getTransactionType() {
+        return transactionType;
+    }
+
+    @NotNull
+    public InteropTransactionRole getTransactionRole() {
+        return transactionRole;
+    }
+
+    public String getNote() {
+        return note;
+    }
+
+    public void setNote(String note) {
+        this.note = note;
+    }
+
+    public GeoCodeData getGeoCode() {
+        return geoCode;
+    }
+
+    public void setGeoCode(GeoCodeData geoCode) {
+        this.geoCode = geoCode;
+    }
+
+    public LocalDateTime getExpiration() {
+        return expiration;
+    }
+
+    public LocalDate getExpirationLocalDate() {
+        return expiration == null ? null : expiration.toLocalDate();
+    }
+
+    public void setExpiration(LocalDateTime expiration) {
+        this.expiration = expiration;
+    }
+
+    public List<ExtensionData> getExtensionList() {
+        return extensionList;
+    }
+
+    public void setExtensionList(List<ExtensionData> extensionList) {
+        this.extensionList = extensionList;
+    }
+
+    public void normalizeAmounts(@NotNull Currency currency) {
+        amount.normalizeAmount(currency);
+    }
+
+    protected void setTransactionCode(String transactionCode) {
+        this.transactionCode = transactionCode;
+    }
+
+    protected void setRequestCode(String requestCode) {
+        this.requestCode = requestCode;
+    }
+
+    protected void setAccountId(String accountId) {
+        this.accountId = accountId;
+    }
+
+    protected void setAmount(MoneyData amount) {
+        this.amount = amount;
+    }
+
+    protected void setTransactionRole(InteropTransactionRole transactionRole) {
+        this.transactionRole = transactionRole;
+    }
+
+    protected void setTransactionType(InteropTransactionTypeData transactionType) {
+        this.transactionType = transactionType;
+    }
+
+    @Transient
+    public abstract InteropActionType getActionType();
+
+    @Transient
+    @NotNull
+    public String getIdentifier() {
+        return transactionCode;
+    }
+}
diff --git a/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/data/InteropResponseData.java b/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/data/InteropResponseData.java
new file mode 100644
index 0000000..d8f7cfd
--- /dev/null
+++ b/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/data/InteropResponseData.java
@@ -0,0 +1,77 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.fineract.cn.interoperation.api.v1.domain.data;
+
+import org.apache.fineract.cn.interoperation.api.v1.domain.InteropActionState;
+
+import javax.validation.constraints.NotNull;
+import java.beans.Transient;
+import java.time.LocalDateTime;
+import java.time.format.DateTimeFormatter;
+import java.util.List;
+
+public abstract class InteropResponseData {
+
+    @NotNull
+    private final String transactionCode;
+
+    @NotNull
+    private final InteropActionState state;
+
+    private final String expiration;
+
+    private final List<ExtensionData> extensionList;
+
+
+    protected InteropResponseData(@NotNull String transactionCode, @NotNull InteropActionState state, LocalDateTime expiration, List<ExtensionData> extensionList) {
+        this.transactionCode = transactionCode;
+        this.state = state;
+        this.expiration = format(expiration);
+        this.extensionList = extensionList;
+    }
+
+    public String getTransactionCode() {
+        return transactionCode;
+    }
+
+    public InteropActionState getState() {
+        return state;
+    }
+
+    public String getExpiration() {
+        return expiration;
+    }
+
+    @Transient
+    public LocalDateTime getExpirationDate() {
+        return parse(expiration);
+    }
+
+    public List<ExtensionData> getExtensionList() {
+        return extensionList;
+    }
+
+    protected static LocalDateTime parse(String date) {
+        return date == null ? null : LocalDateTime.parse(date, DateTimeFormatter.ISO_DATE_TIME);
+    }
+
+    protected static String format(LocalDateTime date) {
+        return date == null ? null : date.format(DateTimeFormatter.ISO_DATE_TIME);
+    }
+}
diff --git a/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/data/InteropTransactionRequestData.java b/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/data/InteropTransactionRequestData.java
new file mode 100644
index 0000000..b150abb
--- /dev/null
+++ b/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/data/InteropTransactionRequestData.java
@@ -0,0 +1,64 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.fineract.cn.interoperation.api.v1.domain.data;
+
+import org.apache.fineract.cn.interoperation.api.v1.domain.InteropActionType;
+import org.apache.fineract.cn.interoperation.api.v1.domain.InteropTransactionRole;
+
+import javax.validation.constraints.NotNull;
+import java.beans.Transient;
+import java.time.LocalDateTime;
+import java.util.List;
+
+public class InteropTransactionRequestData extends InteropRequestData {
+
+    protected InteropTransactionRequestData() {
+        super();
+    }
+
+    public InteropTransactionRequestData(@NotNull String transactionCode, @NotNull String requestCode, @NotNull String accountId,
+                                         @NotNull MoneyData amount, @NotNull InteropTransactionTypeData transactionType, String note,
+                                         GeoCodeData geoCode, LocalDateTime expiration, List<ExtensionData> extensionList) {
+        super(transactionCode, requestCode, accountId, amount, InteropTransactionRole.PAYER, transactionType, note, geoCode, expiration, extensionList);
+    }
+
+    public InteropTransactionRequestData(@NotNull String transactionCode, @NotNull String requestCode, @NotNull String accountId,
+                                         @NotNull MoneyData amount, @NotNull InteropTransactionTypeData transactionType) {
+        this(transactionCode, requestCode, accountId, amount, transactionType, null, null, null, null);
+    }
+
+    private InteropTransactionRequestData(InteropRequestData other) {
+        this(other.getTransactionCode(), other.getRequestCode(), other.getAccountId(), other.getAmount(), other.getTransactionType(),
+                other.getNote(), other.getGeoCode(), other.getExpiration(), other.getExtensionList());
+    }
+
+    @NotNull
+    @Transient
+    @Override
+    public InteropActionType getActionType() {
+        return InteropActionType.REQUEST;
+    }
+
+    @Transient
+    @NotNull
+    @Override
+    public String getIdentifier() {
+        return getRequestCode();
+    }
+}
diff --git a/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/data/InteropTransactionRequestResponseData.java b/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/data/InteropTransactionRequestResponseData.java
new file mode 100644
index 0000000..9ea80ca
--- /dev/null
+++ b/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/data/InteropTransactionRequestResponseData.java
@@ -0,0 +1,54 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.fineract.cn.interoperation.api.v1.domain.data;
+
+import org.apache.fineract.cn.interoperation.api.v1.domain.InteropActionState;
+
+import javax.validation.constraints.NotNull;
+import javax.validation.constraints.Pattern;
+import java.time.LocalDateTime;
+import java.util.List;
+
+public class InteropTransactionRequestResponseData extends InteropResponseData {
+
+    @NotNull
+    @Pattern(regexp = "^[0-9a-f]{8}-[0-9a-f]{4}-[1-5][0-9a-f]{3}-[89ab][0-9a-f]{3}-[0-9a-f]{12}$")
+    private final String requestCode;
+
+    private InteropTransactionRequestResponseData(@NotNull String transactionCode, @NotNull InteropActionState state, LocalDateTime expiration, List<ExtensionData> extensionList,
+                                                  @NotNull String requestCode) {
+        super(transactionCode, state, expiration, extensionList);
+        this.requestCode = requestCode;
+    }
+
+    public static InteropTransactionRequestResponseData build(@NotNull String transactionCode, @NotNull InteropActionState state,
+                                                              LocalDateTime expiration, List<ExtensionData> extensionList,
+                                                              @NotNull String requestCode) {
+        return new InteropTransactionRequestResponseData(transactionCode, state, expiration, extensionList, requestCode);
+    }
+
+    public static InteropTransactionRequestResponseData build(@NotNull String transactionCode, @NotNull InteropActionState state,
+                                                              LocalDateTime expiration, @NotNull String requestCode) {
+        return build(transactionCode, state, expiration, null, requestCode);
+    }
+
+    public String getRequestCode() {
+        return requestCode;
+    }
+}
diff --git a/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/data/InteropTransactionTypeData.java b/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/data/InteropTransactionTypeData.java
new file mode 100644
index 0000000..19047b5
--- /dev/null
+++ b/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/data/InteropTransactionTypeData.java
@@ -0,0 +1,83 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.fineract.cn.interoperation.api.v1.domain.data;
+
+import org.apache.fineract.cn.interoperation.api.v1.domain.InteropInitiatorType;
+import org.apache.fineract.cn.interoperation.api.v1.domain.InteropTransactionRole;
+import org.apache.fineract.cn.interoperation.api.v1.domain.InteropTransactionScenario;
+
+import javax.validation.constraints.NotNull;
+import javax.validation.constraints.Pattern;
+
+public class InteropTransactionTypeData {
+
+    @NotNull
+    private InteropTransactionScenario scenario;
+
+    @Pattern(regexp = "^[A-Z_]{1,32}$")
+    private String subScenario;
+
+    @NotNull
+    private InteropTransactionRole initiator;
+
+    @NotNull
+    private InteropInitiatorType initiatorType;
+
+    protected InteropTransactionTypeData() {
+    }
+
+    public InteropTransactionTypeData(InteropTransactionScenario scenario, String subScenario, InteropTransactionRole initiator, InteropInitiatorType initiatorType) {
+        this.scenario = scenario;
+        this.subScenario = subScenario;
+        this.initiator = initiator;
+        this.initiatorType = initiatorType;
+    }
+
+    public InteropTransactionScenario getScenario() {
+        return scenario;
+    }
+
+    public String getSubScenario() {
+        return subScenario;
+    }
+
+    public InteropTransactionRole getInitiator() {
+        return initiator;
+    }
+
+    public InteropInitiatorType getInitiatorType() {
+        return initiatorType;
+    }
+
+    protected void setScenario(InteropTransactionScenario scenario) {
+        this.scenario = scenario;
+    }
+
+    protected void setSubScenario(String subScenario) {
+        this.subScenario = subScenario;
+    }
+
+    protected void setInitiator(InteropTransactionRole initiator) {
+        this.initiator = initiator;
+    }
+
+    protected void setInitiatorType(InteropInitiatorType initiatorType) {
+        this.initiatorType = initiatorType;
+    }
+}
diff --git a/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/data/InteropTransferCommand.java b/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/data/InteropTransferCommand.java
new file mode 100644
index 0000000..15a75cb
--- /dev/null
+++ b/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/data/InteropTransferCommand.java
@@ -0,0 +1,49 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.fineract.cn.interoperation.api.v1.domain.data;
+
+import org.apache.fineract.cn.interoperation.api.v1.domain.InteropActionType;
+import org.apache.fineract.cn.interoperation.api.v1.domain.InteropTransferActionType;
+
+import javax.validation.constraints.NotNull;
+import java.beans.Transient;
+
+public class InteropTransferCommand extends InteropTransferRequestData {
+
+    @NotNull
+    private final InteropTransferActionType action;
+
+    public InteropTransferCommand(@NotNull InteropTransferRequestData requestData, @NotNull InteropTransferActionType action) {
+        super(requestData.getTransactionCode(), requestData.getAccountId(), requestData.getAmount(), requestData.getTransactionRole(),
+                requestData.getNote(), requestData.getExpiration(), requestData.getExtensionList(), requestData.getTransferCode(),
+                requestData.getFspFee(), requestData.getFspCommission());
+        this.action = action;
+    }
+
+    public InteropTransferActionType getAction() {
+        return action;
+    }
+
+    @NotNull
+    @Transient
+    @Override
+    public InteropActionType getActionType() {
+        return action == InteropTransferActionType.PREPARE ? InteropActionType.PREPARE : InteropActionType.COMMIT;
+    }
+}
diff --git a/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/data/InteropTransferRequestData.java b/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/data/InteropTransferRequestData.java
new file mode 100644
index 0000000..08b1539
--- /dev/null
+++ b/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/data/InteropTransferRequestData.java
@@ -0,0 +1,97 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.fineract.cn.interoperation.api.v1.domain.data;
+
+import org.apache.fineract.cn.deposit.api.v1.definition.domain.Currency;
+import org.apache.fineract.cn.interoperation.api.v1.domain.InteropActionType;
+import org.apache.fineract.cn.interoperation.api.v1.domain.InteropTransactionRole;
+
+import javax.validation.Valid;
+import javax.validation.constraints.NotNull;
+import javax.validation.constraints.Pattern;
+import java.beans.Transient;
+import java.time.LocalDateTime;
+import java.util.List;
+
+public class InteropTransferRequestData extends InteropRequestData {
+
+    @NotNull
+    @Pattern(regexp = "^[0-9a-f]{8}-[0-9a-f]{4}-[1-5][0-9a-f]{3}-[89ab][0-9a-f]{3}-[0-9a-f]{12}$")
+    private String transferCode;
+
+    @Valid
+    private MoneyData fspFee;
+
+    @Valid
+    private MoneyData fspCommission;
+
+    protected InteropTransferRequestData() {
+        super();
+    }
+
+    public InteropTransferRequestData(@NotNull String transactionCode, @NotNull String accountId, @NotNull MoneyData amount,
+                                      @NotNull InteropTransactionRole transactionRole, String note, LocalDateTime expiration,
+                                      List<ExtensionData> extensionList, @NotNull String transferCode, MoneyData fspFee, MoneyData fspCommission) {
+        super(transactionCode, null, accountId, amount, transactionRole, null, note, null, expiration, extensionList);
+        this.transferCode = transferCode;
+        this.fspFee = fspFee;
+        this.fspCommission = fspCommission;
+    }
+
+    public InteropTransferRequestData(@NotNull String transactionCode, @NotNull String accountId, @NotNull MoneyData amount,
+                                      @NotNull InteropTransactionRole transactionRole, @NotNull String transferCode) {
+        this(transactionCode, accountId, amount, transactionRole, null, null, null, transferCode, null, null);
+    }
+
+    private InteropTransferRequestData(InteropRequestData other, @NotNull String transferCode, MoneyData fspFee, MoneyData fspCommission) {
+        this(other.getTransactionCode(), other.getAccountId(), other.getAmount(), other.getTransactionRole(),
+                other.getNote(), other.getExpiration(), other.getExtensionList(), transferCode, fspFee, fspCommission);
+    }
+
+    public String getTransferCode() {
+        return transferCode;
+    }
+
+    public MoneyData getFspFee() {
+        return fspFee;
+    }
+
+    public MoneyData getFspCommission() {
+        return fspCommission;
+    }
+
+    public void normalizeAmounts(@NotNull Currency currency) {
+        super.normalizeAmounts(currency);
+        if (fspFee != null)
+            fspFee.normalizeAmount(currency);
+    }
+
+    @Transient
+    @Override
+    public InteropActionType getActionType() {
+        return null;
+    }
+
+    @Transient
+    @NotNull
+    @Override
+    public String getIdentifier() {
+        return transferCode;
+    }
+}
diff --git a/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/data/InteropTransferResponseData.java b/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/data/InteropTransferResponseData.java
new file mode 100644
index 0000000..2e24a3e
--- /dev/null
+++ b/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/data/InteropTransferResponseData.java
@@ -0,0 +1,65 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.fineract.cn.interoperation.api.v1.domain.data;
+
+import org.apache.fineract.cn.interoperation.api.v1.domain.InteropActionState;
+
+import javax.validation.constraints.NotNull;
+import java.beans.Transient;
+import java.time.LocalDateTime;
+import java.util.List;
+
+public class InteropTransferResponseData extends InteropResponseData {
+
+    @NotNull
+    private final String transferCode;
+
+    private String completedTimestamp;
+
+    private InteropTransferResponseData(@NotNull String transactionCode, @NotNull InteropActionState state, LocalDateTime expiration,
+                                        List<ExtensionData> extensionList, @NotNull String transferCode, LocalDateTime completedTimestamp) {
+        super(transactionCode, state, expiration, extensionList);
+        this.transferCode = transferCode;
+        this.completedTimestamp = format(completedTimestamp);
+    }
+
+    public static InteropTransferResponseData build(@NotNull String transactionCode, @NotNull InteropActionState state,
+                                                    LocalDateTime expiration, List<ExtensionData> extensionList,
+                                                    @NotNull String transferCode, LocalDateTime completedTimestamp) {
+        return new InteropTransferResponseData(transactionCode, state, expiration, extensionList, transferCode, completedTimestamp);
+    }
+
+    public static InteropTransferResponseData build(@NotNull String transactionCode, @NotNull InteropActionState state,
+                                                    LocalDateTime expiration, @NotNull String transferCode, LocalDateTime completedTimestamp) {
+        return build(transactionCode, state, expiration, transferCode, completedTimestamp);
+    }
+
+    public String getTransferCode() {
+        return transferCode;
+    }
+
+    public String getCompletedTimestamp() {
+        return completedTimestamp;
+    }
+
+    @Transient
+    public LocalDateTime getCompletedTimestampDate() {
+        return parse(completedTimestamp);
+    }
+}
diff --git a/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/data/MoneyData.java b/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/data/MoneyData.java
new file mode 100644
index 0000000..972d838
--- /dev/null
+++ b/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/data/MoneyData.java
@@ -0,0 +1,78 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.fineract.cn.interoperation.api.v1.domain.data;
+
+import org.apache.fineract.cn.deposit.api.v1.definition.domain.Currency;
+import org.apache.fineract.cn.interoperation.api.v1.util.MathUtil;
+import org.hibernate.validator.constraints.Length;
+
+import javax.validation.constraints.Digits;
+import javax.validation.constraints.Min;
+import javax.validation.constraints.NotNull;
+import java.math.BigDecimal;
+
+public class MoneyData {
+
+    @NotNull
+    @Min(0)
+    @Digits(integer = 15, fraction = 4) // interoperation schema allows integer = 18, AccountEntity amount allows fraction = 5
+    private BigDecimal amount;
+
+    @NotNull
+    @Length(min = 3, max = 3)
+    private String currency;
+
+    protected MoneyData() {
+    }
+
+    MoneyData(BigDecimal amount, String currency) {
+        this.amount = amount;
+        this.currency = currency;
+    }
+
+    public static MoneyData build(BigDecimal amount, String currency) {
+        return amount == null ? null : new MoneyData(amount, currency);
+    }
+
+    public static MoneyData build(BigDecimal amount, Currency currency) {
+        return amount == null ? null : build(amount, currency.getCode());
+    }
+
+    public BigDecimal getAmount() {
+        return amount;
+    }
+
+    public String getCurrency() {
+        return currency;
+    }
+
+    public void normalizeAmount(@NotNull Currency currency) {
+        if (!currency.getCode().equals(this.currency))
+            throw new UnsupportedOperationException("Internal error: Invalid currency " + currency.getCode());
+        MathUtil.normalize(amount, currency);
+    }
+
+    protected void setAmount(BigDecimal amount) {
+        this.amount = amount;
+    }
+
+    protected void setCurrency(String currency) {
+        this.currency = currency;
+    }
+}
diff --git a/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/validation/InteroperationDataValidator.java b/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/validation/InteroperationDataValidator.java
new file mode 100644
index 0000000..2931ecf
--- /dev/null
+++ b/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/domain/validation/InteroperationDataValidator.java
@@ -0,0 +1,65 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.fineract.cn.interoperation.api.v1.domain.validation;
+
+import org.apache.fineract.cn.interoperation.api.v1.domain.data.InteropIdentifierCommand;
+import org.apache.fineract.cn.interoperation.api.v1.domain.data.InteropIdentifierDeleteCommand;
+import org.apache.fineract.cn.interoperation.api.v1.domain.data.InteropQuoteRequestData;
+import org.apache.fineract.cn.interoperation.api.v1.domain.data.InteropTransactionRequestData;
+import org.apache.fineract.cn.interoperation.api.v1.domain.data.InteropTransferCommand;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+
+@Component
+public class InteroperationDataValidator {
+
+    public InteroperationDataValidator() {
+    }
+
+    public InteropIdentifierCommand registerAccountIdentifier(InteropIdentifierCommand requestData) {
+        return requestData;
+    }
+
+    public InteropIdentifierDeleteCommand deleteAccountIdentifier(InteropIdentifierDeleteCommand requestData) {
+        return requestData;
+    }
+
+    public InteropTransactionRequestData validateCreateRequest(InteropTransactionRequestData requestData) {
+        return requestData;
+    }
+
+    public InteropQuoteRequestData validateCreateQuote(InteropQuoteRequestData requestData) {
+        return requestData;
+    }
+
+    public InteropTransferCommand validatePrepareTransfer(InteropTransferCommand requestData) {
+        return validateCommitTransfer(requestData);
+    }
+
+    public InteropTransferCommand validateCommitTransfer(InteropTransferCommand requestData) {
+        return requestData;
+    }
+
+    private void throwExceptionIfValidationWarningsExist(List<String> errors) {
+        if (errors != null && !errors.isEmpty()) {
+            throw new UnsupportedOperationException(String.join(", ", errors)); // TODO
+        }
+    }
+}
diff --git a/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/util/InteroperationUtil.java b/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/util/InteroperationUtil.java
new file mode 100644
index 0000000..b24d5a7
--- /dev/null
+++ b/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/util/InteroperationUtil.java
@@ -0,0 +1,23 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.fineract.cn.interoperation.api.v1.util;
+
+public class InteroperationUtil {
+
+}
diff --git a/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/util/MathUtil.java b/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/util/MathUtil.java
new file mode 100644
index 0000000..abfecfc
--- /dev/null
+++ b/api/src/main/java/org/apache/fineract/cn/interoperation/api/v1/util/MathUtil.java
@@ -0,0 +1,325 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.fineract.cn.interoperation.api.v1.util;
+
+import org.apache.fineract.cn.deposit.api.v1.definition.domain.Currency;
+
+import javax.validation.constraints.NotNull;
+import java.math.BigDecimal;
+import java.math.MathContext;
+import java.math.RoundingMode;
+
+public class MathUtil {
+
+    public static final MathContext DEFAULT_MATH_CONTEXT = new MathContext(2, RoundingMode.HALF_EVEN);
+    public static final MathContext CALCULATION_MATH_CONTEXT = new MathContext(5, RoundingMode.HALF_EVEN);
+
+    public static Double nullToZero(Double value) {
+        return nullToDefault(value, 0D);
+    }
+
+    public static Double nullToDefault(Double value, Double def) {
+        return value == null ? def : value;
+    }
+
+    public static Double zeroToNull(Double value) {
+        return isEmpty(value) ? null : value;
+    }
+
+    /** @return parameter value or ZERO if it is negative */
+    public static Double negativeToZero(Double value) {
+        return isGreaterThanZero(value) ? value : 0D;
+    }
+
+    public static boolean isEmpty(Double value) {
+        return value == null || value.equals(0D);
+    }
+
+    public static boolean isGreaterThanZero(Double value) {
+        return value != null && value > 0D;
+    }
+
+    public static boolean isLessThanZero(Double value) {
+        return value != null && value < 0D;
+    }
+
+    public static boolean isZero(Double value) {
+        return value != null && value.equals(0D);
+    }
+
+    public static boolean isEqualTo(Double first, Double second) {
+        return nullToZero(first).equals(nullToZero(second));
+    }
+
+    public static boolean isGreaterThan(Double first, Double second) {
+        return nullToZero(first) > nullToZero(second);
+    }
+
+    public static boolean isLessThan(Double first, Double second) {
+        return nullToZero(first) < nullToZero(second);
+    }
+
+    public static boolean isGreaterThanOrEqualTo(Double first, Double second) {
+        return nullToZero(first) >= nullToZero(second);
+    }
+
+    public static boolean isLessThanOrEqualZero(Double value) {
+        return nullToZero(value) <= 0D;
+    }
+
+    /** @return parameter value or negated value to positive */
+    public static Double abs(Double value) {
+        return value == null ? 0D : Math.abs(value);
+    }
+
+    /** @return calculates minimum of the two values considering null values
+     * @param notNull if true then null parameter is omitted, otherwise returns null */
+    public static Double min(Double first, Double second, boolean notNull) {
+        return first == null
+                ? (notNull ? second : null)
+                : second == null ? (notNull ? first : null) : Math.min(first, second);
+    }
+
+    /** @return calculates minimum of the values considering null values
+     * @param notNull if true then null parameter is omitted, otherwise returns null */
+    public static Double min(Double first, Double second, Double third, boolean notNull) {
+        return min(min(first, second, notNull), third, notNull);
+    }
+
+    /** @return sum the two values considering null values */
+    public static Double add(Double first, Double second) {
+        return first == null
+                ? second
+                : second == null ? first : first + second;
+    }
+
+    /** @return sum the values considering null values */
+    public static Double add(Double first, Double second, Double third) {
+        return add(add(first, second), third);
+    }
+
+    /** @return sum the values considering null values */
+    public static Double add(Double first, Double second, Double third, Double fourth) {
+        return add(add(add(first, second), third), fourth);
+    }
+
+    /** @return sum the values considering null values */
+    public static Double add(Double first, Double second, Double third, Double fourth, Double fifth) {
+        return add(add(add(add(first, second), third), fourth), fifth);
+    }
+
+    /** @return first minus second considering null values, maybe negative */
+    public static Double subtract(Double first, Double second) {
+        return first == null
+                ? null
+                : second == null ? first : first - second;
+    }
+
+    /** @return first minus the others considering null values, maybe negative */
+    public static Double subtractToZero(Double first, Double second, Double third) {
+        return subtractToZero(subtract(first, second), third);
+    }
+
+    /** @return first minus the others considering null values, maybe negative */
+    public static Double subtractToZero(Double first, Double second, Double third, Double fourth) {
+        return subtractToZero(subtract(subtract(first, second), third), fourth);
+    }
+
+    /** @return NONE negative first minus second considering null values */
+    public static Double subtractToZero(Double first, Double second) {
+        return negativeToZero(subtract(first, second));
+    }
+
+    /** @return BigDecimal with scale set to the 'digitsAfterDecimal' of the parameter currency */
+    public static Double normalize(Double amount, @NotNull Currency currency) {
+        return amount == null ? null : normalize(BigDecimal.valueOf(amount), currency).doubleValue();
+    }
+
+    /** @return BigDecimal with scale set to the 'digitsAfterDecimal' of the parameter currency */
+    public static Double normalize(Double amount, @NotNull MathContext mc) {
+        return amount == null ? null : normalize(BigDecimal.valueOf(amount), mc).doubleValue();
+    }
+
+    /** @return BigDecimal null safe negate */
+    public static Double negate(Double amount) {
+        return isEmpty(amount) ? amount : amount * -1;
+    }
+
+
+    // ----------------- BigDecimal -----------------
+
+    public static BigDecimal nullToZero(BigDecimal value) {
+        return nullToDefault(value, BigDecimal.ZERO);
+    }
+
+    public static BigDecimal nullToDefault(BigDecimal value, BigDecimal def) {
+        return value == null ? def : value;
+    }
+
+    public static BigDecimal zeroToNull(BigDecimal value) {
+        return isEmpty(value) ? null : value;
+    }
+
+    /** @return parameter value or ZERO if it is negative */
+    public static BigDecimal negativeToZero(BigDecimal value) {
+        return isGreaterThanZero(value) ? value : BigDecimal.ZERO;
+    }
+
+    public static boolean isEmpty(BigDecimal value) {
+        return value == null || BigDecimal.ZERO.compareTo(value) == 0;
+    }
+
+    public static boolean isGreaterThanZero(BigDecimal value) {
+        return value != null && value.compareTo(BigDecimal.ZERO) > 0;
+    }
+
+    public static boolean isLessThanZero(BigDecimal value) {
+        return value != null && value.compareTo(BigDecimal.ZERO) < 0;
+    }
+
+    public static boolean isZero(BigDecimal value) {
+        return value != null && value.compareTo(BigDecimal.ZERO) == 0;
+    }
+
+    public static boolean isEqualTo(BigDecimal first, BigDecimal second) {
+        return nullToZero(first).compareTo(nullToZero(second)) == 0;
+    }
+
+    public static boolean isGreaterThan(BigDecimal first, BigDecimal second) {
+        return nullToZero(first).compareTo(nullToZero(second)) > 0;
+    }
+
+    public static boolean isLessThan(BigDecimal first, BigDecimal second) {
+        return nullToZero(first).compareTo(nullToZero(second)) < 0;
+    }
+
+    public static boolean isGreaterThanOrEqualTo(BigDecimal first, BigDecimal second) {
+        return nullToZero(first).compareTo(nullToZero(second)) >= 0;
+    }
+
+    public static boolean isLessThanOrEqualZero(BigDecimal value) {
+        return nullToZero(value).compareTo(BigDecimal.ZERO) <= 0;
+    }
+
+    /** @return parameter value or negated value to positive */
+    public static BigDecimal abs(BigDecimal value) {
+        return value == null ? BigDecimal.ZERO : value.abs();
+    }
+
+    /** @return calculates minimum of the two values considering null values
+     * @param notNull if true then null parameter is omitted, otherwise returns null */
+    public static BigDecimal min(BigDecimal first, BigDecimal second, boolean notNull) {
+        return notNull
+                ? first == null
+                ? second
+                : second == null ? first : min(first, second, false)
+                : isLessThan(first, second) ? first : second;
+    }
+
+    /** @return calculates minimum of the values considering null values
+     * @param notNull if true then null parameter is omitted, otherwise returns null */
+    public static BigDecimal min(BigDecimal first, BigDecimal second, BigDecimal third, boolean notNull) {
+        return min(min(first, second, notNull), third, notNull);
+    }
+
+    /** @return sum the two values considering null values */
+    public static BigDecimal add(BigDecimal first, BigDecimal second) {
+        return add(first, second, CALCULATION_MATH_CONTEXT);
+    }
+
+    /** @return sum the two values considering null values */
+    public static BigDecimal add(BigDecimal first, BigDecimal second, MathContext mc) {
+        return first == null
+                ? second
+                : second == null ? first : first.add(second, mc);
+    }
+
+    /** @return sum the values considering null values */
+    public static BigDecimal add(BigDecimal first, BigDecimal second, BigDecimal third) {
+        return add(first, second, third, CALCULATION_MATH_CONTEXT);
+    }
+
+    /** @return sum the values considering null values */
+    public static BigDecimal add(BigDecimal first, BigDecimal second, BigDecimal third, MathContext mc) {
+        return add(add(first, second, mc), third, mc);
+    }
+
+    /** @return sum the values considering null values */
+    public static BigDecimal add(BigDecimal first, BigDecimal second, BigDecimal third, BigDecimal fourth) {
+        return add(first, second, third, fourth, CALCULATION_MATH_CONTEXT);
+    }
+
+    /** @return sum the values considering null values */
+    public static BigDecimal add(BigDecimal first, BigDecimal second, BigDecimal third, BigDecimal fourth, MathContext mc) {
+        return add(add(add(first, second, mc), third, mc), fourth, mc);
+    }
+
+    /** @return sum the values considering null values */
+    public static BigDecimal add(BigDecimal first, BigDecimal second, BigDecimal third, BigDecimal fourth, BigDecimal fifth) {
+        return add(first, second, third, fourth, fifth, CALCULATION_MATH_CONTEXT);
+    }
+
+    /** @return sum the values considering null values */
+    public static BigDecimal add(BigDecimal first, BigDecimal second, BigDecimal third, BigDecimal fourth, BigDecimal fifth, MathContext mc) {
+        return add(add(add(add(first, second, mc), third, mc), fourth, mc), fifth, mc);
+    }
+
+    /** @return first minus second considering null values, maybe negative */
+    public static BigDecimal subtract(BigDecimal first, BigDecimal second) {
+        return first == null
+                ? null
+                : second == null ? first : first.subtract(second, CALCULATION_MATH_CONTEXT);
+    }
+
+    /** @return NONE negative first minus second considering null values */
+    public static BigDecimal subtractToZero(BigDecimal first, BigDecimal second) {
+        return negativeToZero(subtract(first, second));
+    }
+
+    /** @return first minus the others considering null values, maybe negative */
+    public static BigDecimal subtractToZero(BigDecimal first, BigDecimal second, BigDecimal third) {
+        MathContext mc = CALCULATION_MATH_CONTEXT;
+        return subtractToZero(subtract(first, second), third);
+    }
+
+    /** @return first minus the others considering null values, maybe negative */
+    public static BigDecimal subtractToZero(BigDecimal first, BigDecimal second, BigDecimal third, BigDecimal fourth) {
+        return subtractToZero(subtract(subtract(first, second), third), fourth);
+    }
+
+    /** @return BigDecimal with scale set to the 'digitsAfterDecimal' of the parameter currency */
+    public static BigDecimal normalize(BigDecimal amount, @NotNull Currency currency) {
+        return amount == null ? null : amount.setScale(currency.getScale(), CALCULATION_MATH_CONTEXT.getRoundingMode());
+    }
+
+    /** @return BigDecimal with scale set to the 'digitsAfterDecimal' of the parameter currency */
+    public static BigDecimal normalize(BigDecimal amount, @NotNull MathContext mc) {
+        return amount == null ? null : amount.setScale(mc.getPrecision(), mc.getRoundingMode());
+    }
+
+    /** @return BigDecimal null safe negate */
+    public static BigDecimal negate(BigDecimal amount) {
+        return negate(amount, CALCULATION_MATH_CONTEXT);
+    }
+
+    /** @return BigDecimal null safe negate */
+    public static BigDecimal negate(BigDecimal amount, MathContext mc) {
+        return isEmpty(amount) ? amount : amount.negate(mc);
+    }
+}
diff --git a/build.gradle b/build.gradle
new file mode 100644
index 0000000..949f5bb
--- /dev/null
+++ b/build.gradle
@@ -0,0 +1,45 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+group 'org.apache.fineract.cn'
+
+task publishApiToMavenLocal {
+    dependsOn gradle.includedBuild('api').task(':publishToMavenLocal')
+}
+
+task publishServiceToMavenLocal {
+    mustRunAfter publishApiToMavenLocal
+    dependsOn gradle.includedBuild('service').task(':publishToMavenLocal')
+}
+
+task publishToMavenLocal {
+    group 'all'
+    dependsOn publishApiToMavenLocal
+    dependsOn publishServiceToMavenLocal
+}
+
+task licenseFormat {
+    group 'all'
+    dependsOn gradle.includedBuild('api').task(':licenseFormat')
+    dependsOn gradle.includedBuild('service').task(':licenseFormat')
+}
+
+task rat {
+    group 'all'
+    dependsOn gradle.includedBuild('api').task(':rat')
+    dependsOn gradle.includedBuild('service').task(':rat')
+}
diff --git a/gradle/wrapper/gradle-wrapper.jar b/gradle/wrapper/gradle-wrapper.jar
new file mode 100644
index 0000000..811409c
--- /dev/null
+++ b/gradle/wrapper/gradle-wrapper.jar
Binary files differ
diff --git a/gradle/wrapper/gradle-wrapper.properties b/gradle/wrapper/gradle-wrapper.properties
new file mode 100644
index 0000000..e2f405e
--- /dev/null
+++ b/gradle/wrapper/gradle-wrapper.properties
@@ -0,0 +1,6 @@
+#Sat Apr 14 20:59:05 CEST 2018
+distributionBase=GRADLE_USER_HOME
+distributionPath=wrapper/dists
+zipStoreBase=GRADLE_USER_HOME
+zipStorePath=wrapper/dists
+distributionUrl=https\://services.gradle.org/distributions/gradle-3.4.1-bin.zip
diff --git a/gradlew b/gradlew
new file mode 100644
index 0000000..f6cb21f
--- /dev/null
+++ b/gradlew
@@ -0,0 +1,173 @@
+#!/usr/bin/env sh
+
+##############################################################################
+##
+##  Gradle start up script for UN*X
+##
+##############################################################################
+
+# Attempt to set APP_HOME
+# Resolve links: $0 may be a link
+PRG="$0"
+# Need this for relative symlinks.
+while [ -h "$PRG" ] ; do
+    ls=`ls -ld "$PRG"`
+    link=`expr "$ls" : '.*-> \(.*\)$'`
+    if expr "$link" : '/.*' > /dev/null; then
+        PRG="$link"
+    else
+        PRG=`dirname "$PRG"`"/$link"
+    fi
+done
+SAVED="`pwd`"
+cd "`dirname \"$PRG\"`/" >/dev/null
+APP_HOME="`pwd -P`"
+cd "$SAVED" >/dev/null
+
+APP_NAME="Gradle"
+APP_BASE_NAME=`basename "$0"`
+
+# Add default JVM options here. You can also use JAVA_OPTS and GRADLE_OPTS to pass JVM options to this script.
+DEFAULT_JVM_OPTS=""
+JAVA_OPTS="-Xms512m -Xmx2048m"
+
+# Use the maximum available, or set MAX_FD != -1 to use that value.
+MAX_FD="maximum"
+
+warn ( ) {
+    echo "$*"
+}
+
+die ( ) {
+    echo
+    echo "$*"
+    echo
+    exit 1
+}
+
+# OS specific support (must be 'true' or 'false').
+cygwin=false
+msys=false
+darwin=false
+nonstop=false
+case "`uname`" in
+  CYGWIN* )
+    cygwin=true
+    ;;
+  Darwin* )
+    darwin=true
+    ;;
+  MINGW* )
+    msys=true
+    ;;
+  NONSTOP* )
+    nonstop=true
+    ;;
+esac
+
+CLASSPATH=$APP_HOME/gradle/wrapper/gradle-wrapper.jar
+
+# Determine the Java command to use to start the JVM.
+if [ -n "$JAVA_HOME" ] ; then
+    if [ -x "$JAVA_HOME/jre/sh/java" ] ; then
+        # IBM's JDK on AIX uses strange locations for the executables
+        JAVACMD="$JAVA_HOME/jre/sh/java"
+    else
+        JAVACMD="$JAVA_HOME/bin/java"
+    fi
+    if [ ! -x "$JAVACMD" ] ; then
+        die "ERROR: JAVA_HOME is set to an invalid directory: $JAVA_HOME
+
+Please set the JAVA_HOME variable in your environment to match the
+location of your Java installation."
+    fi
+else
+    JAVACMD="java"
+    which java >/dev/null 2>&1 || die "ERROR: JAVA_HOME is not set and no 'java' command could be found in your PATH.
+
+Please set the JAVA_HOME variable in your environment to match the
+location of your Java installation."
+fi
+
+# Increase the maximum file descriptors if we can.
+if [ "$cygwin" = "false" -a "$darwin" = "false" -a "$nonstop" = "false" ] ; then
+    MAX_FD_LIMIT=`ulimit -H -n`
+    if [ $? -eq 0 ] ; then
+        if [ "$MAX_FD" = "maximum" -o "$MAX_FD" = "max" ] ; then
+            MAX_FD="$MAX_FD_LIMIT"
+        fi
+        ulimit -n $MAX_FD
+        if [ $? -ne 0 ] ; then
+            warn "Could not set maximum file descriptor limit: $MAX_FD"
+        fi
+    else
+        warn "Could not query maximum file descriptor limit: $MAX_FD_LIMIT"
+    fi
+fi
+
+# For Darwin, add options to specify how the application appears in the dock
+if $darwin; then
+    GRADLE_OPTS="$GRADLE_OPTS \"-Xdock:name=$APP_NAME\" \"-Xdock:icon=$APP_HOME/media/gradle.icns\""
+fi
+
+# For Cygwin, switch paths to Windows format before running java
+if $cygwin ; then
+    APP_HOME=`cygpath --path --mixed "$APP_HOME"`
+    CLASSPATH=`cygpath --path --mixed "$CLASSPATH"`
+    JAVACMD=`cygpath --unix "$JAVACMD"`
+
+    # We build the pattern for arguments to be converted via cygpath
+    ROOTDIRSRAW=`find -L / -maxdepth 1 -mindepth 1 -type d 2>/dev/null`
+    SEP=""
+    for dir in $ROOTDIRSRAW ; do
+        ROOTDIRS="$ROOTDIRS$SEP$dir"
+        SEP="|"
+    done
+    OURCYGPATTERN="(^($ROOTDIRS))"
+    # Add a user-defined pattern to the cygpath arguments
+    if [ "$GRADLE_CYGPATTERN" != "" ] ; then
+        OURCYGPATTERN="$OURCYGPATTERN|($GRADLE_CYGPATTERN)"
+    fi
+    # Now convert the arguments - kludge to limit ourselves to /bin/sh
+    i=0
+    for arg in "$@" ; do
+        CHECK=`echo "$arg"|egrep -c "$OURCYGPATTERN" -`
+        CHECK2=`echo "$arg"|egrep -c "^-"`                                 ### Determine if an option
+
+        if [ $CHECK -ne 0 ] && [ $CHECK2 -eq 0 ] ; then                    ### Added a condition
+            eval `echo args$i`=`cygpath --path --ignore --mixed "$arg"`
+        else
+            eval `echo args$i`="\"$arg\""
+        fi
+        i=$((i+1))
+    done
+    case $i in
+        (0) set -- ;;
+        (1) set -- "$args0" ;;
+        (2) set -- "$args0" "$args1" ;;
+        (3) set -- "$args0" "$args1" "$args2" ;;
+        (4) set -- "$args0" "$args1" "$args2" "$args3" ;;
+        (5) set -- "$args0" "$args1" "$args2" "$args3" "$args4" ;;
+        (6) set -- "$args0" "$args1" "$args2" "$args3" "$args4" "$args5" ;;
+        (7) set -- "$args0" "$args1" "$args2" "$args3" "$args4" "$args5" "$args6" ;;
+        (8) set -- "$args0" "$args1" "$args2" "$args3" "$args4" "$args5" "$args6" "$args7" ;;
+        (9) set -- "$args0" "$args1" "$args2" "$args3" "$args4" "$args5" "$args6" "$args7" "$args8" ;;
+    esac
+fi
+
+# Escape application args
+save ( ) {
+    for i do printf %s\\n "$i" | sed "s/'/'\\\\''/g;1s/^/'/;\$s/\$/' \\\\/" ; done
+    echo " "
+}
+APP_ARGS=$(save "$@")
+
+# Collect all arguments for the java command, following the shell quoting and substitution rules
+eval set -- $DEFAULT_JVM_OPTS $JAVA_OPTS $GRADLE_OPTS "\"-Dorg.gradle.appname=$APP_BASE_NAME\"" -classpath "\"$CLASSPATH\"" org.gradle.wrapper.GradleWrapperMain "$APP_ARGS"
+
+# by default we should be in the correct project dir, but when run from Finder on Mac, the cwd is wrong
+if [ "$(uname)" = "Darwin" ] && [ "$HOME" = "$PWD" ]; then
+  cd "$(dirname "$0")"
+fi
+
+exec "$JAVACMD" "$@"
diff --git a/gradlew.bat b/gradlew.bat
new file mode 100644
index 0000000..f955316
--- /dev/null
+++ b/gradlew.bat
@@ -0,0 +1,84 @@
+@if "%DEBUG%" == "" @echo off
+@rem ##########################################################################
+@rem
+@rem  Gradle startup script for Windows
+@rem
+@rem ##########################################################################
+
+@rem Set local scope for the variables with windows NT shell
+if "%OS%"=="Windows_NT" setlocal
+
+set DIRNAME=%~dp0
+if "%DIRNAME%" == "" set DIRNAME=.
+set APP_BASE_NAME=%~n0
+set APP_HOME=%DIRNAME%
+
+@rem Add default JVM options here. You can also use JAVA_OPTS and GRADLE_OPTS to pass JVM options to this script.
+set DEFAULT_JVM_OPTS=
+
+@rem Find java.exe
+if defined JAVA_HOME goto findJavaFromJavaHome
+
+set JAVA_EXE=java.exe
+%JAVA_EXE% -version >NUL 2>&1
+if "%ERRORLEVEL%" == "0" goto init
+
+echo.
+echo ERROR: JAVA_HOME is not set and no 'java' command could be found in your PATH.
+echo.
+echo Please set the JAVA_HOME variable in your environment to match the
+echo location of your Java installation.
+
+goto fail
+
+:findJavaFromJavaHome
+set JAVA_HOME=%JAVA_HOME:"=%
+set JAVA_EXE=%JAVA_HOME%/bin/java.exe
+
+if exist "%JAVA_EXE%" goto init
+
+echo.
+echo ERROR: JAVA_HOME is set to an invalid directory: %JAVA_HOME%
+echo.
+echo Please set the JAVA_HOME variable in your environment to match the
+echo location of your Java installation.
+
+goto fail
+
+:init
+@rem Get command-line arguments, handling Windows variants
+
+if not "%OS%" == "Windows_NT" goto win9xME_args
+
+:win9xME_args
+@rem Slurp the command line arguments.
+set CMD_LINE_ARGS=
+set _SKIP=2
+
+:win9xME_args_slurp
+if "x%~1" == "x" goto execute
+
+set CMD_LINE_ARGS=%*
+
+:execute
+@rem Setup the command line
+
+set CLASSPATH=%APP_HOME%\gradle\wrapper\gradle-wrapper.jar
+
+@rem Execute Gradle
+"%JAVA_EXE%" %DEFAULT_JVM_OPTS% %JAVA_OPTS% %GRADLE_OPTS% "-Dorg.gradle.appname=%APP_BASE_NAME%" -classpath "%CLASSPATH%" org.gradle.wrapper.GradleWrapperMain %CMD_LINE_ARGS%
+
+:end
+@rem End local scope for the variables with windows NT shell
+if "%ERRORLEVEL%"=="0" goto mainEnd
+
+:fail
+rem Set variable GRADLE_EXIT_CONSOLE if you need the _script_ return code instead of
+rem the _cmd.exe /c_ return code!
+if  not "" == "%GRADLE_EXIT_CONSOLE%" exit 1
+exit /b 1
+
+:mainEnd
+if "%OS%"=="Windows_NT" endlocal
+
+:omega
diff --git a/service/build.gradle b/service/build.gradle
new file mode 100644
index 0000000..5035f25
--- /dev/null
+++ b/service/build.gradle
@@ -0,0 +1,83 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+buildscript {
+    ext {
+        springBootVersion = '1.4.1.RELEASE'
+    }
+
+    repositories {
+        jcenter()
+    }
+
+    dependencies {
+        classpath("org.springframework.boot:spring-boot-gradle-plugin:${springBootVersion}")
+    }
+}
+
+plugins {
+    id "com.github.hierynomus.license" version "0.13.1"
+    id("org.nosphere.apache.rat") version "0.3.1"
+}
+
+apply from: '../shared.gradle'
+
+apply plugin: 'spring-boot'
+
+springBoot {
+    executable = true
+    classifier = 'boot'
+}
+
+dependencies {
+    compile(
+            [group: 'org.springframework.cloud', name: 'spring-cloud-starter-config'],
+            [group: 'org.springframework.cloud', name: 'spring-cloud-starter-eureka'],
+            [group: 'org.springframework.boot', name: 'spring-boot-starter-jetty'],
+            [group: 'org.hibernate', name: 'hibernate-validator', version: versions.validator],
+            [group: 'com.google.code.gson', name: 'gson'],
+            [group: 'org.apache.fineract.cn', name: 'lang', version: versions.frameworklang],
+            [group: 'org.apache.fineract.cn', name: 'async', version: versions.frameworkasync],
+            [group: 'org.apache.fineract.cn', name: 'cassandra', version: versions.frameworkcassandra],
+            [group: 'org.apache.fineract.cn', name: 'mariadb', version: versions.frameworkmariadb],
+            [group: 'org.apache.fineract.cn', name: 'command', version: versions.frameworkcommand],
+            [group: 'org.apache.fineract.cn.interoperation', name: 'api', version: versions.frameworkinter],
+            [group: 'org.apache.fineract.cn.anubis', name: 'library', version: versions.frameworkanubis],
+            [group: 'org.apache.fineract.cn.accounting', name: 'api', version: versions.frameworkledger],
+//            [group: 'org.apache.fineract.cn.teller', name: 'service', version: versions.frameworkteller],
+    )
+}
+
+publishToMavenLocal.dependsOn bootRepackage
+
+publishing {
+    publications {
+        service(MavenPublication) {
+            from components.java
+            groupId project.group
+            artifactId project.name
+            version project.version
+        }
+        bootService(MavenPublication) {
+            // "boot" jar
+            artifact("$buildDir/libs/$project.name-$version-boot.jar")
+            groupId project.group
+            artifactId("$project.name-boot")
+            version project.version
+        }
+    }
+}
diff --git a/service/settings.gradle b/service/settings.gradle
new file mode 100644
index 0000000..1a4c2fd
--- /dev/null
+++ b/service/settings.gradle
@@ -0,0 +1,18 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+rootProject.name = 'service'
\ No newline at end of file
diff --git a/service/src/main/java/org/apache/fineract/cn/interoperation/service/InteropApplication.java b/service/src/main/java/org/apache/fineract/cn/interoperation/service/InteropApplication.java
new file mode 100644
index 0000000..aaa559a
--- /dev/null
+++ b/service/src/main/java/org/apache/fineract/cn/interoperation/service/InteropApplication.java
@@ -0,0 +1,32 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.fineract.cn.interoperation.service;
+
+import org.springframework.boot.SpringApplication;
+
+public class InteropApplication {
+
+  public InteropApplication() {
+    super();
+  }
+
+  public static void main(String[] args) {
+    SpringApplication.run(InteropServiceConfiguration.class, args);
+  }
+}
diff --git a/service/src/main/java/org/apache/fineract/cn/interoperation/service/InteropServiceConfiguration.java b/service/src/main/java/org/apache/fineract/cn/interoperation/service/InteropServiceConfiguration.java
new file mode 100644
index 0000000..899d938
--- /dev/null
+++ b/service/src/main/java/org/apache/fineract/cn/interoperation/service/InteropServiceConfiguration.java
@@ -0,0 +1,83 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.fineract.cn.interoperation.service;
+
+import com.google.gson.Gson;
+import org.apache.fineract.cn.accounting.api.v1.client.LedgerManager;
+import org.apache.fineract.cn.anubis.config.EnableAnubis;
+import org.apache.fineract.cn.async.config.EnableAsync;
+import org.apache.fineract.cn.cassandra.config.EnableCassandra;
+import org.apache.fineract.cn.command.config.EnableCommandProcessing;
+import org.apache.fineract.cn.deposit.api.v1.client.DepositAccountManager;
+import org.apache.fineract.cn.lang.config.EnableServiceException;
+import org.apache.fineract.cn.lang.config.EnableTenantContext;
+import org.apache.fineract.cn.mariadb.config.EnableMariaDB;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
+import org.springframework.boot.autoconfigure.domain.EntityScan;
+import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
+import org.springframework.cloud.netflix.feign.EnableFeignClients;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.ComponentScan;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.data.jpa.repository.config.EnableJpaRepositories;
+import org.springframework.web.servlet.config.annotation.WebMvcConfigurerAdapter;
+
+@SuppressWarnings("WeakerAccess")
+@Configuration
+@EnableAutoConfiguration
+@EnableDiscoveryClient
+@EnableAsync
+@EnableTenantContext
+@EnableCassandra
+@EnableMariaDB
+@EnableCommandProcessing
+@EnableAnubis
+@EnableServiceException
+@EnableFeignClients(clients = {
+        LedgerManager.class,
+        DepositAccountManager.class
+})
+@ComponentScan({
+        "org.apache.fineract.cn.interoperation.service.rest",
+        "org.apache.fineract.cn.interoperation.service.internal.service",
+        "org.apache.fineract.cn.interoperation.service.internal.repository",
+        "org.apache.fineract.cn.interoperation.service.internal.command.handler",
+        "org.apache.fineract.cn.interoperation.api.v1.domain.validation",
+        "org.apache.fineract.cn.interoperation.internal.command.handler"
+})
+@EnableJpaRepositories(basePackages = "org.apache.fineract.cn.interoperation.service.internal.repository")
+@EntityScan(basePackages = "org.apache.fineract.cn.interoperation.service.internal.repository")
+public class InteropServiceConfiguration extends WebMvcConfigurerAdapter {
+
+    public InteropServiceConfiguration() {
+        super();
+    }
+
+    @Bean(name = ServiceConstants.LOGGER_NAME)
+    public Logger logger() {
+        return LoggerFactory.getLogger(ServiceConstants.LOGGER_NAME);
+    }
+
+    @Bean(name = ServiceConstants.GSON_NAME)
+    public Gson gson() {
+        return new Gson();
+    }
+}
diff --git a/service/src/main/java/org/apache/fineract/cn/interoperation/service/ServiceConstants.java b/service/src/main/java/org/apache/fineract/cn/interoperation/service/ServiceConstants.java
new file mode 100644
index 0000000..9df33c5
--- /dev/null
+++ b/service/src/main/java/org/apache/fineract/cn/interoperation/service/ServiceConstants.java
@@ -0,0 +1,26 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.fineract.cn.interoperation.service;
+
+public interface ServiceConstants {
+
+  String LOGGER_NAME = "interoperation-logger";
+  String GSON_NAME = "interoperation-gson";
+
+}
diff --git a/service/src/main/java/org/apache/fineract/cn/interoperation/service/internal/command/InitializeServiceCommand.java b/service/src/main/java/org/apache/fineract/cn/interoperation/service/internal/command/InitializeServiceCommand.java
new file mode 100644
index 0000000..f8acab6
--- /dev/null
+++ b/service/src/main/java/org/apache/fineract/cn/interoperation/service/internal/command/InitializeServiceCommand.java
@@ -0,0 +1,26 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.fineract.cn.interoperation.service.internal.command;
+
+public class InitializeServiceCommand {
+
+  public InitializeServiceCommand() {
+    super();
+  }
+}
diff --git a/service/src/main/java/org/apache/fineract/cn/interoperation/service/internal/command/handler/InteropHandler.java b/service/src/main/java/org/apache/fineract/cn/interoperation/service/internal/command/handler/InteropHandler.java
new file mode 100644
index 0000000..f35d281
--- /dev/null
+++ b/service/src/main/java/org/apache/fineract/cn/interoperation/service/internal/command/handler/InteropHandler.java
@@ -0,0 +1,112 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.fineract.cn.interoperation.service.internal.command.handler;
+
+import org.apache.fineract.cn.command.annotation.Aggregate;
+import org.apache.fineract.cn.command.annotation.CommandHandler;
+import org.apache.fineract.cn.command.annotation.CommandLogLevel;
+import org.apache.fineract.cn.interoperation.api.v1.domain.data.InteropIdentifierCommand;
+import org.apache.fineract.cn.interoperation.api.v1.domain.data.InteropIdentifierData;
+import org.apache.fineract.cn.interoperation.api.v1.domain.data.InteropIdentifierDeleteCommand;
+import org.apache.fineract.cn.interoperation.api.v1.domain.data.InteropQuoteRequestData;
+import org.apache.fineract.cn.interoperation.api.v1.domain.data.InteropQuoteResponseData;
+import org.apache.fineract.cn.interoperation.api.v1.domain.data.InteropTransactionRequestData;
+import org.apache.fineract.cn.interoperation.api.v1.domain.data.InteropTransactionRequestResponseData;
+import org.apache.fineract.cn.interoperation.api.v1.domain.data.InteropTransferCommand;
+import org.apache.fineract.cn.interoperation.api.v1.domain.data.InteropTransferResponseData;
+import org.apache.fineract.cn.interoperation.api.v1.domain.validation.InteroperationDataValidator;
+import org.apache.fineract.cn.interoperation.service.ServiceConstants;
+import org.apache.fineract.cn.interoperation.service.internal.service.InteropService;
+import org.slf4j.Logger;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.transaction.annotation.Transactional;
+
+import javax.validation.constraints.NotNull;
+
+@SuppressWarnings("unused")
+@Aggregate
+public class InteropHandler {
+
+    private final Logger logger;
+
+    private final InteroperationDataValidator dataValidator;
+
+    private final InteropService interopService;
+
+    @Autowired
+    public InteropHandler(@Qualifier(ServiceConstants.LOGGER_NAME) final Logger logger,
+                          InteroperationDataValidator interoperationDataValidator,
+                          InteropService interopService) {
+        this.logger = logger;
+        this.dataValidator = interoperationDataValidator;
+        this.interopService = interopService;
+    }
+
+    @NotNull
+    @Transactional
+    @CommandHandler(logStart = CommandLogLevel.INFO, logFinish = CommandLogLevel.INFO)
+    public InteropIdentifierData registerAccountIdentifier(@NotNull InteropIdentifierCommand command) {
+        command = dataValidator.registerAccountIdentifier(command);
+        return interopService.registerAccountIdentifier(command);
+    }
+
+    @NotNull
+    @Transactional
+    @CommandHandler(logStart = CommandLogLevel.INFO, logFinish = CommandLogLevel.INFO)
+    public InteropIdentifierData deleteAccountIdentifier(@NotNull InteropIdentifierDeleteCommand command) {
+        command = dataValidator.deleteAccountIdentifier(command);
+        return interopService.deleteAccountIdentifier(command);
+    }
+
+    @NotNull
+    @Transactional
+    @CommandHandler(logStart = CommandLogLevel.INFO, logFinish = CommandLogLevel.INFO)
+    public InteropTransactionRequestResponseData createTransactionRequest(@NotNull InteropTransactionRequestData command) {
+        // only when Payee request transaction from Payer, so here role must be always Payer
+        command = dataValidator.validateCreateRequest(command);
+        return interopService.createTransactionRequest(command);
+    }
+
+    @NotNull
+    @Transactional
+    @CommandHandler(logStart = CommandLogLevel.INFO, logFinish = CommandLogLevel.INFO)
+    public InteropQuoteResponseData createQuote(@NotNull InteropQuoteRequestData command) {
+        command = dataValidator.validateCreateQuote(command);
+        return interopService.createQuote(command);
+    }
+
+    @NotNull
+    @Transactional
+    @CommandHandler(logStart = CommandLogLevel.INFO, logFinish = CommandLogLevel.INFO)
+    public InteropTransferResponseData performTransfer(@NotNull InteropTransferCommand command) {
+        switch (command.getAction()) {
+            case PREPARE: {
+                command = dataValidator.validatePrepareTransfer(command);
+                return interopService.prepareTransfer(command);
+            }
+            case CREATE: {
+                command = dataValidator.validateCommitTransfer(command);
+                return interopService.commitTransfer(command);
+            }
+            default:
+                return null;
+        }
+    }
+}
diff --git a/service/src/main/java/org/apache/fineract/cn/interoperation/service/internal/command/handler/MigrationAggregate.java b/service/src/main/java/org/apache/fineract/cn/interoperation/service/internal/command/handler/MigrationAggregate.java
new file mode 100644
index 0000000..f60bdbc
--- /dev/null
+++ b/service/src/main/java/org/apache/fineract/cn/interoperation/service/internal/command/handler/MigrationAggregate.java
@@ -0,0 +1,64 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.fineract.cn.interoperation.service.internal.command.handler;
+
+import org.apache.fineract.cn.command.annotation.Aggregate;
+import org.apache.fineract.cn.command.annotation.CommandHandler;
+import org.apache.fineract.cn.command.annotation.EventEmitter;
+import org.apache.fineract.cn.interoperation.api.v1.EventConstants;
+import org.apache.fineract.cn.interoperation.service.ServiceConstants;
+import org.apache.fineract.cn.interoperation.service.internal.command.InitializeServiceCommand;
+import org.apache.fineract.cn.lang.ApplicationName;
+import org.apache.fineract.cn.mariadb.domain.FlywayFactoryBean;
+import org.slf4j.Logger;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.transaction.annotation.Transactional;
+
+import javax.sql.DataSource;
+
+@Aggregate
+public class MigrationAggregate {
+
+  private final Logger logger;
+  private final DataSource dataSource;
+  private final FlywayFactoryBean flywayFactoryBean;
+  private final ApplicationName applicationName;
+
+  @Autowired
+  public MigrationAggregate(@Qualifier(ServiceConstants.LOGGER_NAME) final Logger logger,
+                            final DataSource dataSource,
+                            final FlywayFactoryBean flywayFactoryBean,
+                            final ApplicationName applicationName) {
+    super();
+    this.logger = logger;
+    this.dataSource = dataSource;
+    this.flywayFactoryBean = flywayFactoryBean;
+    this.applicationName = applicationName;
+  }
+
+  @CommandHandler
+  @EventEmitter(selectorName = EventConstants.OPERATION_HEADER, selectorValue = EventConstants.INITIALIZE)
+  @Transactional
+  public String process(final InitializeServiceCommand initializeCommand) {
+    this.logger.info("Starting migration for interoperation version: {}.", applicationName.getVersionString());
+    this.flywayFactoryBean.create(this.dataSource).migrate();
+    return EventConstants.INITIALIZE;
+  }
+}
diff --git a/service/src/main/java/org/apache/fineract/cn/interoperation/service/internal/repository/InteropActionEntity.java b/service/src/main/java/org/apache/fineract/cn/interoperation/service/internal/repository/InteropActionEntity.java
new file mode 100644
index 0000000..e4157ab
--- /dev/null
+++ b/service/src/main/java/org/apache/fineract/cn/interoperation/service/internal/repository/InteropActionEntity.java
@@ -0,0 +1,250 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.fineract.cn.interoperation.service.internal.repository;
+
+import org.apache.fineract.cn.interoperation.api.v1.domain.InteropActionState;
+import org.apache.fineract.cn.interoperation.api.v1.domain.InteropActionType;
+import org.apache.fineract.cn.mariadb.util.LocalDateTimeConverter;
+
+import javax.persistence.*;
+import javax.validation.constraints.NotNull;
+import java.math.BigDecimal;
+import java.time.LocalDateTime;
+
+@Entity
+@Table(name = "hathor_actions", uniqueConstraints = {
+        @UniqueConstraint(name = "uk_hathor_actions_id", columnNames = {"identifier"}),
+        @UniqueConstraint(name = "uk_hathor_actions_type", columnNames = {"transaction_id", "action_type"}),
+        @UniqueConstraint(name = "uk_hathor_actions_seq", columnNames = {"transaction_id", "seq_no"})
+})
+public class InteropActionEntity {
+
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    @Column(name = "id")
+    private Long id;
+
+    @Column(name = "identifier", nullable = false, length = 64)
+    private String identifier;
+
+    @ManyToOne(optional = false, fetch = FetchType.LAZY)
+    @JoinColumn(name = "transaction_id", referencedColumnName="id", nullable = false)
+    private InteropTransactionEntity transaction;
+
+    @Column(name = "action_type", nullable = false, length = 32)
+    @Enumerated(EnumType.STRING)
+    private InteropActionType actionType;
+
+    @Column(name = "seq_no", nullable = false)
+    private int seqNo;
+
+    @Column(name = "state", nullable = false, length = 32)
+    @Enumerated(EnumType.STRING)
+    private InteropActionState state;
+
+    @Column(name = "amount", nullable = false)
+    private BigDecimal amount;
+
+    @Column(name = "fee")
+    private BigDecimal fee;
+
+    @Column(name = "commission")
+    private BigDecimal commission;
+//
+//    @Column(name = "charges", nullable = false, length = 1024)
+//    private String charges;
+//
+//    @Column(name = "ledgers", nullable = false, length = 1024)
+//    private String ledgers;
+
+    @Column(name = "error_code", length = 4)
+    private String errorCode;
+
+    @Column(name = "error_msg", length = 128)
+    private String errorMsg;
+
+    @Column(name = "expiration_date")
+    @Convert(converter = LocalDateTimeConverter.class)
+    private LocalDateTime expirationDate;
+
+    @Column(name = "created_by", nullable = false, length = 32)
+    private String createdBy;
+
+    @Column(name = "created_on", nullable = false)
+    @Convert(converter = LocalDateTimeConverter.class)
+    private LocalDateTime createdOn;
+
+
+    protected InteropActionEntity() {
+    }
+
+    public InteropActionEntity(@NotNull String identifier, @NotNull InteropTransactionEntity transaction, @NotNull InteropActionType actionType,
+                               int seqNo, @NotNull String createdBy, @NotNull LocalDateTime createdOn) {
+        this.identifier = identifier;
+        this.transaction = transaction;
+        this.actionType = actionType;
+        this.seqNo = seqNo;
+        this.createdBy = createdBy;
+        this.createdOn = createdOn;
+    }
+
+    public Long getId() {
+        return id;
+    }
+
+    private void setId(Long id) {
+        this.id = id;
+    }
+
+    public String getIdentifier() {
+        return identifier;
+    }
+
+    private void setIdentifier(String identifier) {
+        this.identifier = identifier;
+    }
+
+    public InteropTransactionEntity getTransaction() {
+        return transaction;
+    }
+
+    private void setTransaction(InteropTransactionEntity transaction) {
+        this.transaction = transaction;
+    }
+
+    public InteropActionType getActionType() {
+        return actionType;
+    }
+
+    private void setActionType(InteropActionType actionType) {
+        this.actionType = actionType;
+    }
+
+    public int getSeqNo() {
+        return seqNo;
+    }
+
+    private void setSeqNo(int seqNo) {
+        this.seqNo = seqNo;
+    }
+
+    public InteropActionState getState() {
+        return state;
+    }
+
+    public void setState(InteropActionState state) {
+        this.state = state;
+    }
+
+    public BigDecimal getAmount() {
+        return amount;
+    }
+
+    public void setAmount(BigDecimal amount) {
+        this.amount = amount;
+    }
+
+    public BigDecimal getFee() {
+        return fee;
+    }
+
+    public void setFee(BigDecimal fee) {
+        this.fee = fee;
+    }
+
+    public BigDecimal getCommission() {
+        return commission;
+    }
+
+    public void setCommission(BigDecimal commission) {
+        this.commission = commission;
+    }
+//
+//    public String getCharges() {
+//        return charges;
+//    }
+//
+//    public void setCharges(String charges) {
+//        this.charges = charges;
+//    }
+//
+//    public String getLedgers() {
+//        return ledgers;
+//    }
+//
+//    public void setLedgers(String ledgers) {
+//        this.ledgers = ledgers;
+//    }
+
+    public String getErrorCode() {
+        return errorCode;
+    }
+
+    public void setErrorCode(String errorCode) {
+        this.errorCode = errorCode;
+    }
+
+    public String getErrorMsg() {
+        return errorMsg;
+    }
+
+    public void setErrorMsg(String errorMsg) {
+        this.errorMsg = errorMsg;
+    }
+
+    public LocalDateTime getExpirationDate() {
+        return expirationDate;
+    }
+
+    public void setExpirationDate(LocalDateTime expirationDate) {
+        this.expirationDate = expirationDate;
+    }
+
+    public String getCreatedBy() {
+        return createdBy;
+    }
+
+    private void setCreatedBy(String createdBy) {
+        this.createdBy = createdBy;
+    }
+
+    public LocalDateTime getCreatedOn() {
+        return createdOn;
+    }
+
+    private void setCreatedOn(LocalDateTime createdOn) {
+        this.createdOn = createdOn;
+    }
+
+    @Override
+    public boolean equals(Object o) {
+        if (this == o) return true;
+        if (o == null || getClass() != o.getClass()) return false;
+
+        InteropActionEntity that = (InteropActionEntity) o;
+
+        return identifier.equals(that.identifier);
+
+    }
+
+    @Override
+    public int hashCode() {
+        return identifier.hashCode();
+    }
+}
diff --git a/service/src/main/java/org/apache/fineract/cn/interoperation/service/internal/repository/InteropActionRepository.java b/service/src/main/java/org/apache/fineract/cn/interoperation/service/internal/repository/InteropActionRepository.java
new file mode 100644
index 0000000..de5d46d
--- /dev/null
+++ b/service/src/main/java/org/apache/fineract/cn/interoperation/service/internal/repository/InteropActionRepository.java
@@ -0,0 +1,30 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.fineract.cn.interoperation.service.internal.repository;
+
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.stereotype.Repository;
+
+import javax.validation.constraints.NotNull;
+
+@Repository
+public interface InteropActionRepository extends JpaRepository<InteropActionEntity, Long> {
+
+    InteropActionEntity findByIdentifier(@NotNull String identifier);
+}
diff --git a/service/src/main/java/org/apache/fineract/cn/interoperation/service/internal/repository/InteropIdentifierEntity.java b/service/src/main/java/org/apache/fineract/cn/interoperation/service/internal/repository/InteropIdentifierEntity.java
new file mode 100644
index 0000000..7af5745
--- /dev/null
+++ b/service/src/main/java/org/apache/fineract/cn/interoperation/service/internal/repository/InteropIdentifierEntity.java
@@ -0,0 +1,177 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.fineract.cn.interoperation.service.internal.repository;
+
+import org.apache.fineract.cn.interoperation.api.v1.domain.InteropIdentifierType;
+import org.apache.fineract.cn.mariadb.util.LocalDateTimeConverter;
+
+import javax.persistence.*;
+import javax.validation.constraints.NotNull;
+import java.time.LocalDateTime;
+
+@Entity
+@Table(name = "hathor_identifiers", uniqueConstraints = {
+        @UniqueConstraint(name = "uk_hathor_identifiers_value", columnNames = {"type", "a_value", "sub_value_or_type"})
+})
+public class InteropIdentifierEntity {
+
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    @Column(name = "id")
+    private Long id;
+
+    @Column(name = "customer_account_identifier", nullable = false, length = 32)
+    private String customerAccountIdentifier;
+
+    @Column(name = "type", nullable = false, length = 32)
+    @Enumerated(EnumType.STRING)
+    private InteropIdentifierType type;
+
+    @Column(name = "a_value", nullable = false, length = 128)
+    private String value;
+
+    @Column(name = "sub_value_or_type", length = 128)
+    private String subValueOrType;
+
+    @Column(name = "created_by", nullable = false, length = 32)
+    private String createdBy;
+
+    @Column(name = "created_on", nullable = false)
+    @Convert(converter = LocalDateTimeConverter.class)
+    private LocalDateTime createdOn;
+
+    @Column(name = "last_modified_by", length = 32)
+    private String lastModifiedBy;
+
+    @Column(name = "last_modified_on")
+    @Convert(converter = LocalDateTimeConverter.class)
+    private LocalDateTime lastModifiedOn;
+
+
+    protected InteropIdentifierEntity() {
+    }
+
+    public InteropIdentifierEntity(@NotNull String customerAccountIdentifier, @NotNull InteropIdentifierType type, @NotNull String value,
+                                   String subValueOrType, @NotNull String createdBy, @NotNull LocalDateTime createdOn) {
+        this.customerAccountIdentifier = customerAccountIdentifier;
+        this.type = type;
+        this.value = value;
+        this.subValueOrType = subValueOrType;
+        this.createdBy = createdBy;
+        this.createdOn = createdOn;
+    }
+
+    public InteropIdentifierEntity(@NotNull String customerAccountIdentifier, @NotNull InteropIdentifierType type, @NotNull String createdBy,
+                                   @NotNull LocalDateTime createdOn) {
+        this(customerAccountIdentifier, type, null, null, createdBy, createdOn);
+    }
+
+    public Long getId() {
+        return id;
+    }
+
+    private void setId(Long id) {
+        this.id = id;
+    }
+
+    public String getCustomerAccountIdentifier() {
+        return customerAccountIdentifier;
+    }
+
+    private void setCustomerAccountIdentifier(String customerAccountIdentifier) {
+        this.customerAccountIdentifier = customerAccountIdentifier;
+    }
+
+    public InteropIdentifierType getType() {
+        return type;
+    }
+
+    private void setType(InteropIdentifierType type) {
+        this.type = type;
+    }
+
+    public String getValue() {
+        return value;
+    }
+
+    public void setValue(String value) {
+        this.value = value;
+    }
+
+    public String getSubValueOrType() {
+        return subValueOrType;
+    }
+
+    public void setSubValueOrType(String subValueOrType) {
+        this.subValueOrType = subValueOrType;
+    }
+
+    public String getCreatedBy() {
+        return createdBy;
+    }
+
+    private void setCreatedBy(String createdBy) {
+        this.createdBy = createdBy;
+    }
+
+    public LocalDateTime getCreatedOn() {
+        return createdOn;
+    }
+
+    private void setCreatedOn(LocalDateTime createdOn) {
+        this.createdOn = createdOn;
+    }
+
+    public String getLastModifiedBy() {
+        return lastModifiedBy;
+    }
+
+    public void setLastModifiedBy(String lastModifiedBy) {
+        this.lastModifiedBy = lastModifiedBy;
+    }
+
+    public LocalDateTime getLastModifiedOn() {
+        return lastModifiedOn;
+    }
+
+    public void setLastModifiedOn(LocalDateTime lastModifiedOn) {
+        this.lastModifiedOn = lastModifiedOn;
+    }
+
+    @Override
+    public boolean equals(Object o) {
+        if (this == o) return true;
+        if (o == null || getClass() != o.getClass()) return false;
+
+        InteropIdentifierEntity that = (InteropIdentifierEntity) o;
+
+        if (!customerAccountIdentifier.equals(that.customerAccountIdentifier)) return false;
+        if (type != that.type) return false;
+        if (!value.equals(that.value)) return false;
+        return subValueOrType != null ? subValueOrType.equals(that.subValueOrType) : that.subValueOrType == null;
+    }
+
+    @Override
+    public int hashCode() {
+        int result = type.hashCode();
+        result = 31 * result + value.hashCode();
+        result = 31 * result + (subValueOrType != null ? subValueOrType.hashCode() : 0);
+        return result;
+    }
+}
diff --git a/service/src/main/java/org/apache/fineract/cn/interoperation/service/internal/repository/InteropIdentifierRepository.java b/service/src/main/java/org/apache/fineract/cn/interoperation/service/internal/repository/InteropIdentifierRepository.java
new file mode 100644
index 0000000..8686e3b
--- /dev/null
+++ b/service/src/main/java/org/apache/fineract/cn/interoperation/service/internal/repository/InteropIdentifierRepository.java
@@ -0,0 +1,27 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.fineract.cn.interoperation.service.internal.repository;
+
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.JpaSpecificationExecutor;
+import org.springframework.stereotype.Repository;
+
+@Repository
+public interface InteropIdentifierRepository extends JpaRepository<InteropIdentifierEntity, Long>, JpaSpecificationExecutor<InteropIdentifierEntity> {
+}
diff --git a/service/src/main/java/org/apache/fineract/cn/interoperation/service/internal/repository/InteropTransactionEntity.java b/service/src/main/java/org/apache/fineract/cn/interoperation/service/internal/repository/InteropTransactionEntity.java
new file mode 100644
index 0000000..217f589
--- /dev/null
+++ b/service/src/main/java/org/apache/fineract/cn/interoperation/service/internal/repository/InteropTransactionEntity.java
@@ -0,0 +1,258 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.fineract.cn.interoperation.service.internal.repository;
+
+import org.apache.fineract.cn.interoperation.api.v1.domain.InteropState;
+import org.apache.fineract.cn.interoperation.api.v1.domain.TransactionType;
+import org.apache.fineract.cn.mariadb.util.LocalDateTimeConverter;
+
+import javax.persistence.*;
+import javax.validation.constraints.NotNull;
+import java.math.BigDecimal;
+import java.time.LocalDateTime;
+import java.util.ArrayList;
+import java.util.List;
+
+@Entity
+@Table(name = "hathor_transactions", uniqueConstraints = {@UniqueConstraint(name = "uk_hathor_transactions_id", columnNames = {"identifier"})})
+public class InteropTransactionEntity {
+
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    @Column(name = "id")
+    private Long id;
+
+    @Column(name = "identifier", nullable = false, length = 36)
+    private String identifier;
+
+    @Column(name = "a_name", length = 256)
+    private String name;
+
+    @Column(name = "description", length = 1024)
+    private String description;
+
+    @Column(name = "transaction_type", nullable = false, length = 32)
+    @Enumerated(EnumType.STRING)
+    private TransactionType transactionType;
+
+    @Column(name = "amount", nullable = false)
+    private BigDecimal amount;
+
+    @Column(name = "state", nullable = false, length = 32)
+    @Enumerated(EnumType.STRING)
+    private InteropState state;
+
+    @Column(name = "customer_account_identifier", nullable = false, length = 32)
+    private String customerAccountIdentifier;
+
+    @Column(name = "payable_account_identifier", length = 32)
+    private String prepareAccountIdentifier;
+
+    @Column(name = "nostro_account_identifier", nullable = false, length = 32)
+    private String nostroAccountIdentifier;
+
+    @Column(name = "transaction_date")
+    @Convert(converter = LocalDateTimeConverter.class)
+    private LocalDateTime transactionDate;
+
+    @Column(name = "expiration_date")
+    @Convert(converter = LocalDateTimeConverter.class)
+    private LocalDateTime expirationDate;
+
+    @Column(name = "created_by", nullable = false, length = 32)
+    private String createdBy;
+
+    @Column(name = "created_on", nullable = false)
+    @Convert(converter = LocalDateTimeConverter.class)
+    private LocalDateTime createdOn;
+
+    @Column(name = "last_modified_by", length = 32)
+    private String lastModifiedBy;
+
+    @Column(name = "last_modified_on")
+    @Convert(converter = LocalDateTimeConverter.class)
+    private LocalDateTime lastModifiedOn;
+
+    @OneToMany(cascade = CascadeType.ALL, mappedBy = "transaction", orphanRemoval = true, fetch=FetchType.LAZY)
+    @OrderBy("seqNo")
+    private List<InteropActionEntity> actions = new ArrayList<>();
+
+
+    protected InteropTransactionEntity() {
+    }
+
+    public InteropTransactionEntity(@NotNull String identifier, @NotNull String customerAccountIdentifier, @NotNull String createdBy,
+                                    @NotNull LocalDateTime createdOn) {
+        this.identifier = identifier;
+        this.customerAccountIdentifier = customerAccountIdentifier;
+        this.createdBy = createdBy;
+        this.createdOn = createdOn;
+    }
+
+    public Long getId() {
+        return id;
+    }
+
+    private void setId(Long id) {
+        this.id = id;
+    }
+
+    public String getIdentifier() {
+        return identifier;
+    }
+
+    private void setIdentifier(String identifier) {
+        this.identifier = identifier;
+    }
+
+    public String getName() {
+        return name;
+    }
+
+    public void setName(String name) {
+        this.name = name;
+    }
+
+    public String getDescription() {
+        return description;
+    }
+
+    public void setDescription(String description) {
+        this.description = description;
+    }
+
+    public TransactionType getTransactionType() {
+        return transactionType;
+    }
+
+    public void setTransactionType(TransactionType transactionType) {
+        this.transactionType = transactionType;
+    }
+
+    public BigDecimal getAmount() {
+        return amount;
+    }
+
+    public void setAmount(BigDecimal amount) {
+        this.amount = amount;
+    }
+
+    public InteropState getState() {
+        return state;
+    }
+
+    public void setState(InteropState state) {
+        this.state = state;
+    }
+
+    public String getCustomerAccountIdentifier() {
+        return customerAccountIdentifier;
+    }
+
+    private void setCustomerAccountIdentifier(String customerAccountIdentifier) {
+        this.customerAccountIdentifier = customerAccountIdentifier;
+    }
+
+    public String getPrepareAccountIdentifier() {
+        return prepareAccountIdentifier;
+    }
+
+    public void setPrepareAccountIdentifier(String prepareAccountIdentifier) {
+        this.prepareAccountIdentifier = prepareAccountIdentifier;
+    }
+
+    public String getNostroAccountIdentifier() {
+        return nostroAccountIdentifier;
+    }
+
+    public void setNostroAccountIdentifier(String nostroAccountIdentifier) {
+        this.nostroAccountIdentifier = nostroAccountIdentifier;
+    }
+
+    public LocalDateTime getTransactionDate() {
+        return transactionDate;
+    }
+
+    public void setTransactionDate(LocalDateTime transactionDate) {
+        this.transactionDate = transactionDate;
+    }
+
+    public LocalDateTime getExpirationDate() {
+        return expirationDate;
+    }
+
+    public void setExpirationDate(LocalDateTime expirationDate) {
+        this.expirationDate = expirationDate;
+    }
+
+    public String getCreatedBy() {
+        return createdBy;
+    }
+
+    private void setCreatedBy(String createdBy) {
+        this.createdBy = createdBy;
+    }
+
+    public LocalDateTime getCreatedOn() {
+        return createdOn;
+    }
+
+    private void setCreatedOn(LocalDateTime createdOn) {
+        this.createdOn = createdOn;
+    }
+
+    public String getLastModifiedBy() {
+        return lastModifiedBy;
+    }
+
+    public void setLastModifiedBy(String lastModifiedBy) {
+        this.lastModifiedBy = lastModifiedBy;
+    }
+
+    public LocalDateTime getLastModifiedOn() {
+        return lastModifiedOn;
+    }
+
+    public void setLastModifiedOn(LocalDateTime lastModifiedOn) {
+        this.lastModifiedOn = lastModifiedOn;
+    }
+
+    public List<InteropActionEntity> getActions() {
+        return actions;
+    }
+
+    public void setActions(List<InteropActionEntity> actions) {
+        this.actions = actions;
+    }
+
+    @Override
+    public boolean equals(Object o) {
+        if (this == o) return true;
+        if (o == null || getClass() != o.getClass()) return false;
+
+        InteropTransactionEntity that = (InteropTransactionEntity) o;
+
+        return identifier.equals(that.identifier);
+    }
+
+    @Override
+    public int hashCode() {
+        return identifier.hashCode();
+    }
+}
diff --git a/service/src/main/java/org/apache/fineract/cn/interoperation/service/internal/repository/InteropTransactionRepository.java b/service/src/main/java/org/apache/fineract/cn/interoperation/service/internal/repository/InteropTransactionRepository.java
new file mode 100644
index 0000000..d02023d
--- /dev/null
+++ b/service/src/main/java/org/apache/fineract/cn/interoperation/service/internal/repository/InteropTransactionRepository.java
@@ -0,0 +1,30 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.fineract.cn.interoperation.service.internal.repository;
+
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.stereotype.Repository;
+
+import javax.validation.constraints.NotNull;
+
+@Repository
+public interface InteropTransactionRepository extends JpaRepository<InteropTransactionEntity, Long> {
+
+    InteropTransactionEntity findOneByIdentifier(@NotNull String identifier);
+}
diff --git a/service/src/main/java/org/apache/fineract/cn/interoperation/service/internal/service/InteropService.java b/service/src/main/java/org/apache/fineract/cn/interoperation/service/internal/service/InteropService.java
new file mode 100644
index 0000000..ae9f119
--- /dev/null
+++ b/service/src/main/java/org/apache/fineract/cn/interoperation/service/internal/service/InteropService.java
@@ -0,0 +1,847 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.fineract.cn.interoperation.service.internal.service;
+
+import org.apache.fineract.cn.accounting.api.v1.domain.Account;
+import org.apache.fineract.cn.accounting.api.v1.domain.AccountType;
+import org.apache.fineract.cn.accounting.api.v1.domain.Creditor;
+import org.apache.fineract.cn.accounting.api.v1.domain.Debtor;
+import org.apache.fineract.cn.accounting.api.v1.domain.JournalEntry;
+import org.apache.fineract.cn.api.util.UserContextHolder;
+import org.apache.fineract.cn.deposit.api.v1.definition.domain.Charge;
+import org.apache.fineract.cn.deposit.api.v1.definition.domain.Currency;
+import org.apache.fineract.cn.deposit.api.v1.definition.domain.ProductDefinition;
+import org.apache.fineract.cn.deposit.api.v1.instance.domain.ProductInstance;
+import org.apache.fineract.cn.interoperation.api.v1.domain.InteropActionState;
+import org.apache.fineract.cn.interoperation.api.v1.domain.InteropActionType;
+import org.apache.fineract.cn.interoperation.api.v1.domain.InteropIdentifierType;
+import org.apache.fineract.cn.interoperation.api.v1.domain.InteropState;
+import org.apache.fineract.cn.interoperation.api.v1.domain.InteropStateMachine;
+import org.apache.fineract.cn.interoperation.api.v1.domain.TransactionType;
+import org.apache.fineract.cn.interoperation.api.v1.domain.data.*;
+import org.apache.fineract.cn.interoperation.api.v1.util.MathUtil;
+import org.apache.fineract.cn.interoperation.service.ServiceConstants;
+import org.apache.fineract.cn.interoperation.service.internal.repository.InteropActionEntity;
+import org.apache.fineract.cn.interoperation.service.internal.repository.InteropActionRepository;
+import org.apache.fineract.cn.interoperation.service.internal.repository.InteropIdentifierEntity;
+import org.apache.fineract.cn.interoperation.service.internal.repository.InteropIdentifierRepository;
+import org.apache.fineract.cn.interoperation.service.internal.repository.InteropTransactionEntity;
+import org.apache.fineract.cn.interoperation.service.internal.repository.InteropTransactionRepository;
+import org.apache.fineract.cn.interoperation.service.internal.service.helper.InteropAccountingService;
+import org.apache.fineract.cn.interoperation.service.internal.service.helper.InteropDepositService;
+import org.apache.fineract.cn.lang.DateConverter;
+import org.slf4j.Logger;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.data.jpa.domain.Specification;
+import org.springframework.data.jpa.domain.Specifications;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Propagation;
+import org.springframework.transaction.annotation.Transactional;
+
+import javax.persistence.criteria.CriteriaBuilder;
+import javax.persistence.criteria.CriteriaQuery;
+import javax.persistence.criteria.Path;
+import javax.persistence.criteria.Root;
+import javax.validation.constraints.NotNull;
+import java.math.BigDecimal;
+import java.math.MathContext;
+import java.time.Clock;
+import java.time.LocalDateTime;
+import java.util.ArrayList;
+import java.util.HashSet;
+import java.util.List;
+
+//import static org.apache.fineract.cn.interoperation.api.v1.util.InteroperationUtil.DEFAULT_ROUTING_CODE;
+
+@Service
+public class InteropService {
+
+    public static final String ACCOUNT_NAME_NOSTRO = "Interoperation NOSTRO";
+
+    private final Logger logger;
+
+    private final InteropIdentifierRepository identifierRepository;
+    private final InteropTransactionRepository transactionRepository;
+    private final InteropActionRepository actionRepository;
+
+    private final InteropDepositService depositService;
+    private final InteropAccountingService accountingService;
+
+
+    @Autowired
+    public InteropService(@Qualifier(ServiceConstants.LOGGER_NAME) final Logger logger,
+                          InteropIdentifierRepository interopIdentifierRepository,
+                          InteropTransactionRepository interopTransactionRepository,
+                          InteropActionRepository interopActionRepository,
+                          InteropDepositService interopDepositService,
+                          InteropAccountingService interopAccountingService) {
+        this.logger = logger;
+        this.identifierRepository = interopIdentifierRepository;
+        this.transactionRepository = interopTransactionRepository;
+        this.actionRepository = interopActionRepository;
+        this.depositService = interopDepositService;
+        this.accountingService = interopAccountingService;
+    }
+
+    @NotNull
+    public InteropIdentifierData getAccountByIdentifier(@NotNull InteropIdentifierType idType, @NotNull String idValue, String subIdOrType) {
+        InteropIdentifierEntity identifier = findIdentifier(idType, idValue, subIdOrType);
+        if (identifier == null)
+            throw new UnsupportedOperationException("Account not found for identifier " + idType + "/" + idValue + (subIdOrType == null ? "" : ("/" + subIdOrType)));
+
+        return new InteropIdentifierData(identifier.getCustomerAccountIdentifier());
+    }
+
+    @NotNull
+    @Transactional(propagation = Propagation.MANDATORY)
+    public InteropIdentifierData registerAccountIdentifier(@NotNull InteropIdentifierCommand request) {
+        //TODO: error handling
+        String accountId = request.getAccountId();
+        validateAndGetAccount(accountId);
+
+        String createdBy = getLoginUser();
+        LocalDateTime createdOn = getNow();
+
+        InteropIdentifierEntity identifier = new InteropIdentifierEntity(accountId, request.getIdType(), request.getIdValue(),
+                request.getSubIdOrType(), createdBy, createdOn);
+
+        identifierRepository.save(identifier);
+
+        return new InteropIdentifierData(accountId);
+    }
+
+    @NotNull
+    @Transactional(propagation = Propagation.MANDATORY)
+    public InteropIdentifierData deleteAccountIdentifier(@NotNull InteropIdentifierDeleteCommand request) {
+        InteropIdentifierType idType = request.getIdType();
+        String idValue = request.getIdValue();
+        String subIdOrType = request.getSubIdOrType();
+
+        InteropIdentifierEntity identifier = findIdentifier(idType, idValue, subIdOrType);
+        if (identifier == null)
+            throw new UnsupportedOperationException("Account not found for identifier " + idType + "/" + idValue + (subIdOrType == null ? "" : ("/" + subIdOrType)));
+
+        String customerAccountIdentifier = identifier.getCustomerAccountIdentifier();
+
+        identifierRepository.delete(identifier);
+
+        return new InteropIdentifierData(customerAccountIdentifier);
+    }
+
+    public InteropTransactionRequestResponseData getTransactionRequest(@NotNull String transactionCode, @NotNull String requestCode) {
+        InteropActionEntity action = validateAndGetAction(transactionCode, calcActionIdentifier(requestCode, InteropActionType.REQUEST),
+                InteropActionType.REQUEST);
+        return InteropTransactionRequestResponseData.build(transactionCode, action.getState(), action.getExpirationDate(), requestCode);
+    }
+
+    @NotNull
+    @Transactional(propagation = Propagation.MANDATORY)
+    public InteropTransactionRequestResponseData createTransactionRequest(@NotNull InteropTransactionRequestData request) {
+        // only when Payee request transaction from Payer, so here role must be always Payer
+        //TODO: error handling
+        AccountWrapper accountWrapper = validateAndGetAccount(request);
+        //TODO: transaction expiration separated from action expiration
+        InteropTransactionEntity transaction = validateAndGetTransaction(request, accountWrapper);
+        InteropActionEntity action = addAction(transaction, request);
+
+        transactionRepository.save(transaction);
+
+        return InteropTransactionRequestResponseData.build(request.getTransactionCode(), action.getState(), action.getExpirationDate(),
+                request.getExtensionList(), request.getRequestCode());
+    }
+
+    public InteropQuoteResponseData getQuote(@NotNull String transactionCode, @NotNull String quoteCode) {
+        InteropActionEntity action = validateAndGetAction(transactionCode, calcActionIdentifier(quoteCode, InteropActionType.QUOTE),
+                InteropActionType.QUOTE);
+
+        Currency currency = getCurrency(action);
+
+        return InteropQuoteResponseData.build(transactionCode, action.getState(), action.getExpirationDate(), quoteCode,
+                MoneyData.build(action.getFee(), currency), MoneyData.build(action.getCommission(), currency));
+    }
+
+    @NotNull
+    @Transactional(propagation = Propagation.MANDATORY)
+    public InteropQuoteResponseData createQuote(@NotNull InteropQuoteRequestData request) {
+        //TODO: error handling
+        AccountWrapper accountWrapper = validateAndGetAccount(request);
+        //TODO: transaction expiration separated from action expiration
+        InteropTransactionEntity transaction = validateAndGetTransaction(request, accountWrapper);
+
+        TransactionType transactionType = request.getTransactionRole().getTransactionType();
+        String accountId = accountWrapper.account.getIdentifier();
+        List<Charge> charges = depositService.getCharges(accountId, transactionType);
+
+        BigDecimal amount = request.getAmount().getAmount();
+        BigDecimal fee = MathUtil.normalize(calcTotalCharges(charges, amount), MathUtil.DEFAULT_MATH_CONTEXT);
+
+        Double withdrawableBalance = getWithdrawableBalance(accountWrapper.account, accountWrapper.productDefinition);
+        boolean withdraw = request.getTransactionRole().isWithdraw();
+
+        BigDecimal total = MathUtil.nullToZero(withdraw ? MathUtil.add(amount, fee) : fee);
+        if (withdraw && withdrawableBalance < total.doubleValue())
+            throw new UnsupportedOperationException("Account balance is not enough to pay the fee " + accountId);
+
+        // TODO add action and set the status to failed in separated transaction
+        InteropActionEntity action = addAction(transaction, request);
+        action.setFee(fee);
+        // TODO: extend Charge with a property that could be stored in charges
+
+        transactionRepository.save(transaction);
+
+        InteropQuoteResponseData build = InteropQuoteResponseData.build(request.getTransactionCode(), action.getState(),
+                action.getExpirationDate(), request.getExtensionList(), request.getQuoteCode(),
+                MoneyData.build(fee, accountWrapper.productDefinition.getCurrency()), null);
+        return build;
+    }
+
+    public InteropTransferResponseData getTransfer(@NotNull String transactionCode, @NotNull String transferCode) {
+        InteropActionEntity action = validateAndGetAction(transactionCode, calcActionIdentifier(transferCode, InteropActionType.PREPARE),
+                InteropActionType.PREPARE, false);
+        if (action == null)
+            action = validateAndGetAction(transactionCode, calcActionIdentifier(transferCode, InteropActionType.COMMIT),
+                    InteropActionType.COMMIT);
+
+        return InteropTransferResponseData.build(transactionCode, action.getState(), action.getExpirationDate(), transferCode, action.getCreatedOn());
+    }
+
+    @NotNull
+    @Transactional(propagation = Propagation.MANDATORY)
+    public InteropTransferResponseData prepareTransfer(@NotNull InteropTransferCommand request) {
+        //TODO: error handling
+        //TODO: ABORT
+        AccountWrapper accountWrapper = validateAndGetAccount(request);
+
+        LocalDateTime transactionDate = getNow();
+        //TODO: transaction expiration separated from action expiration
+        InteropTransactionEntity transaction = validateAndGetTransaction(request, accountWrapper, transactionDate, true);
+
+        validateTransfer(request, accountWrapper);
+
+        TransactionType transactionType = request.getTransactionRole().getTransactionType();
+        List<Charge> charges = depositService.getCharges(accountWrapper.account.getIdentifier(), transactionType);
+
+        // TODO add action and set the status to failed in separated transaction
+        InteropActionEntity action = addAction(transaction, request, transactionDate);
+        MoneyData fee = request.getFspFee();
+        action.setFee(fee == null ? null : fee.getAmount());
+        // TODO: extend Charge with a property that could be stored in charges
+
+        prepareTransfer(request, accountWrapper, action, charges, transactionDate);
+
+        transactionRepository.save(transaction);
+
+        return InteropTransferResponseData.build(request.getTransferCode(), action.getState(), action.getExpirationDate(),
+                request.getExtensionList(), request.getTransferCode(), transactionDate);
+    }
+
+    @NotNull
+    @Transactional(propagation = Propagation.MANDATORY)
+    public InteropTransferResponseData commitTransfer(@NotNull InteropTransferCommand request) {
+        //TODO: error handling
+        //TODO: ABORT
+        AccountWrapper accountWrapper = validateAndGetAccount(request);
+
+        LocalDateTime transactionDate = getNow();
+        //TODO: transaction expiration separated from action expiration
+        InteropTransactionEntity transaction = validateAndGetTransaction(request, accountWrapper, transactionDate, true);
+        transaction.setTransactionDate(transactionDate);
+
+        validateTransfer(request, accountWrapper);
+
+        TransactionType transactionType = request.getTransactionRole().getTransactionType();
+        List<Charge> charges = depositService.getCharges(accountWrapper.account.getIdentifier(), transactionType);
+
+        // TODO add action and set the status to failed in separated transaction
+        InteropActionEntity action = addAction(transaction, request, transactionDate);
+        MoneyData fee = request.getFspFee();
+        action.setFee(fee == null ? null : fee.getAmount());
+        // TODO: extend Charge with a property that could be stored in charges
+
+        bookTransfer(request, accountWrapper, action, charges, transactionDate);
+
+        transactionRepository.save(transaction);
+
+        return InteropTransferResponseData.build(request.getTransferCode(), action.getState(), action.getExpirationDate(),
+                request.getExtensionList(), request.getTransferCode(), transactionDate);
+    }
+
+    Double getWithdrawableBalance(Account account, ProductDefinition productDefinition) {
+        // on-hold amount, if any, is subtracted to payable account
+        return MathUtil.subtractToZero(account.getBalance(), productDefinition.getMinimumBalance());
+    }
+
+    private void prepareTransfer(@NotNull InteropTransferCommand request, @NotNull AccountWrapper accountWrapper, @NotNull InteropActionEntity action,
+                                 List<Charge> charges, LocalDateTime transactionDate) {
+        BigDecimal amount = request.getAmount().getAmount();
+        // TODO: validate amount with quote amount
+        boolean isDebit = request.getTransactionRole().isWithdraw();
+        if (!isDebit)
+            return;
+
+        String prepareAccountId = action.getTransaction().getPrepareAccountIdentifier();
+        Account payableAccount = prepareAccountId == null ? null : validateAndGetAccount(request, prepareAccountId);
+        if (payableAccount == null) {
+            logger.warn("Can not prepare transfer: Payable account was not found for " + accountWrapper.account.getIdentifier());
+            return;
+        }
+
+        final JournalEntry journalEntry = createJournalEntry(action.getIdentifier(), TransactionType.CURRENCY_WITHDRAWAL.getCode(),
+                DateConverter.toIsoString(transactionDate), request.getNote(), getLoginUser());
+
+        HashSet<Debtor> debtors = new HashSet<>(1);
+        HashSet<Creditor> creditors = new HashSet<>(1);
+
+        addCreditor(accountWrapper.account.getIdentifier(), amount.doubleValue(), creditors);
+        addDebtor(payableAccount.getIdentifier(), amount.doubleValue(), debtors);
+
+        prepareCharges(request, accountWrapper, action, charges, payableAccount, debtors, creditors);
+
+        if (debtors.isEmpty()) // must be same size as creditors
+            return;
+
+        journalEntry.setDebtors(debtors);
+        journalEntry.setCreditors(creditors);
+        accountingService.createJournalEntry(journalEntry);
+    }
+
+    private void prepareCharges(@NotNull InteropTransferCommand request, @NotNull AccountWrapper accountWrapper, @NotNull InteropActionEntity action,
+                                @NotNull List<Charge> charges, Account payableAccount, HashSet<Debtor> debtors, HashSet<Creditor> creditors) {
+        MoneyData fspFee = request.getFspFee(); // TODO compare with calculated and with quote
+
+        BigDecimal amount = request.getAmount().getAmount();
+        Currency currency = accountWrapper.productDefinition.getCurrency();
+
+        BigDecimal total = MathUtil.normalize(calcTotalCharges(charges, amount), currency);
+
+        if (MathUtil.isEmpty(total)) {
+            return;
+        }
+
+        if (creditors == null) {
+            creditors = new HashSet<>(1);
+        }
+        if (debtors == null) {
+            debtors = new HashSet<>(charges.size());
+        }
+        addCreditor(accountWrapper.account.getIdentifier(), total.doubleValue(), creditors);
+        addDebtor(payableAccount.getIdentifier(), total.doubleValue(), debtors);
+    }
+
+    private void bookTransfer(@NotNull InteropTransferCommand request, @NotNull AccountWrapper accountWrapper, @NotNull InteropActionEntity action,
+                              List<Charge> charges, LocalDateTime transactionDate) {
+        boolean isDebit = request.getTransactionRole().isWithdraw();
+        String accountId = accountWrapper.account.getIdentifier();
+        String message = request.getNote();
+        double doubleAmount = request.getAmount().getAmount().doubleValue();
+
+        String loginUser = getLoginUser();
+        String transactionTypeCode = (isDebit ? TransactionType.CURRENCY_WITHDRAWAL : TransactionType.CURRENCY_DEPOSIT).getCode();
+        String transactionDateString = DateConverter.toIsoString(transactionDate);
+
+        InteropTransactionEntity transaction = action.getTransaction();
+        Account nostroAccount = validateAndGetAccount(request, transaction.getNostroAccountIdentifier());
+        Account payableAccount = null;
+
+        double preparedAmount = 0d;
+        double accountNostroAmount = doubleAmount;
+
+        if (isDebit) {
+            InteropActionEntity prepareAction = findAction(transaction, InteropActionType.PREPARE);
+            if (prepareAction != null) {
+                JournalEntry prepareJournal = accountingService.findJournalEntry(prepareAction.getIdentifier());
+                if (prepareJournal == null)
+                    throw new UnsupportedOperationException("Can not find prepare result for " + action.getActionType() +
+                            "/" + request.getIdentifier());
+
+                payableAccount = validateAndGetAccount(request, transaction.getPrepareAccountIdentifier());
+                preparedAmount = prepareJournal.getDebtors().stream().mapToDouble(d -> Double.valueOf(d.getAmount())).sum();
+                if (preparedAmount < doubleAmount)
+                    throw new UnsupportedOperationException("Prepared amount " + preparedAmount + " is less than transfer amount " +
+                            doubleAmount + " for " + request.getIdentifier());
+
+                // now fails if prepared is not enough
+                accountNostroAmount = preparedAmount >= doubleAmount ? 0d : doubleAmount - preparedAmount;
+
+                double fromPrepareToNostroAmount = doubleAmount - accountNostroAmount;
+                preparedAmount -= fromPrepareToNostroAmount;
+
+                if (fromPrepareToNostroAmount > 0) {
+                    final JournalEntry fromPrepareToNostroEntry = createJournalEntry(action.getIdentifier(),
+                            transactionTypeCode, transactionDateString, message + " #commit", loginUser);
+
+                    HashSet<Debtor> debtors = new HashSet<>(1);
+                    HashSet<Creditor> creditors = new HashSet<>(1);
+
+                    addCreditor(payableAccount.getIdentifier(), fromPrepareToNostroAmount, creditors);
+                    addDebtor(nostroAccount.getIdentifier(), fromPrepareToNostroAmount, debtors);
+
+                    fromPrepareToNostroEntry.setDebtors(debtors);
+                    fromPrepareToNostroEntry.setCreditors(creditors);
+                    accountingService.createJournalEntry(fromPrepareToNostroEntry);
+                }
+            }
+        }
+        if (accountNostroAmount > 0) {
+            // can not happen that prepared amount is less than requested transfer amount (identifier and message can be default)
+            final JournalEntry journalEntry = createJournalEntry(action.getIdentifier(), transactionTypeCode,
+                    transactionDateString, message/* + (payableAccount == null ? "" : " #difference")*/, loginUser);
+
+            HashSet<Debtor> debtors = new HashSet<>(1);
+            HashSet<Creditor> creditors = new HashSet<>(1);
+
+            addCreditor(isDebit ? accountId : nostroAccount.getIdentifier(), accountNostroAmount, creditors);
+            addDebtor(isDebit ? nostroAccount.getIdentifier() : accountId, accountNostroAmount, debtors);
+
+            journalEntry.setDebtors(debtors);
+            journalEntry.setCreditors(creditors);
+            accountingService.createJournalEntry(journalEntry);
+        }
+
+        preparedAmount = bookCharges(request, accountWrapper, action, charges, payableAccount, preparedAmount, transactionDate);
+
+        if (preparedAmount > 0) {
+//            throw new UnsupportedOperationException("Prepared amount differs from transfer amount " + doubleAmount + " for " + request.getIdentifier());
+            // transfer back remaining prepared amount TODO: JM maybe fail this case?
+
+            final JournalEntry fromPrepareToAccountEntry = createJournalEntry(action.getIdentifier() + InteropRequestData.IDENTIFIER_SEPARATOR + "diff",
+                    transactionTypeCode, transactionDateString, message + " #release difference", loginUser);
+
+            HashSet<Debtor> debtors = new HashSet<>(1);
+            HashSet<Creditor> creditors = new HashSet<>(1);
+
+            addCreditor(payableAccount.getIdentifier(), preparedAmount, creditors);
+            addDebtor(accountId, preparedAmount, debtors);
+
+            fromPrepareToAccountEntry.setDebtors(debtors);
+            fromPrepareToAccountEntry.setCreditors(creditors);
+            accountingService.createJournalEntry(fromPrepareToAccountEntry);
+        }
+    }
+
+    private double bookCharges(@NotNull InteropTransferCommand request, @NotNull AccountWrapper accountWrapper, @NotNull InteropActionEntity action,
+                               @NotNull List<Charge> charges, Account payableAccount, double preparedAmount, LocalDateTime transactionDate) {
+        boolean isDebit = request.getTransactionRole().isWithdraw();
+        String accountId = accountWrapper.account.getIdentifier();
+        String message = request.getNote();
+        BigDecimal amount = request.getAmount().getAmount();
+        Currency currency = accountWrapper.productDefinition.getCurrency();
+
+        BigDecimal calcFee = MathUtil.normalize(calcTotalCharges(charges, amount), currency);
+        BigDecimal requestFee = request.getFspFee().getAmount();
+        if (!MathUtil.isEqualTo(calcFee, requestFee))
+            throw new UnsupportedOperationException("Quote fee " + requestFee + " differs from transfer fee " + calcFee);
+
+        if (MathUtil.isEmpty(calcFee)) {
+            return preparedAmount;
+        }
+
+        String loginUser = getLoginUser();
+        String transactionTypeCode = (isDebit ? TransactionType.CURRENCY_WITHDRAWAL : TransactionType.CURRENCY_DEPOSIT).getCode();
+        String transactionDateString = DateConverter.toIsoString(transactionDate);
+
+        ArrayList<Charge> unpaidCharges = new ArrayList<>(charges);
+        if (preparedAmount > 0) {
+            InteropActionEntity prepareAction = findAction(action.getTransaction(), InteropActionType.PREPARE);
+            if (prepareAction != null) {
+                final JournalEntry fromPrepareToRevenueEntry = createJournalEntry(action.getIdentifier() + InteropRequestData.IDENTIFIER_SEPARATOR + "fee",
+                        transactionTypeCode, transactionDateString, message + " #commit fee", loginUser);
+
+                double payedAmount = 0d;
+
+                HashSet<Debtor> debtors = new HashSet<>(1);
+                HashSet<Creditor> creditors = new HashSet<>(1);
+
+                for (Charge charge : charges) {
+                    BigDecimal value = calcChargeAmount(amount, charge, currency, true);
+                    if (value == null)
+                        continue;
+
+                    double doubleValue = value.doubleValue();
+                    if (doubleValue > preparedAmount) {
+                        break;
+                    }
+                    unpaidCharges.remove(charge);
+                    preparedAmount -= doubleValue;
+                    payedAmount += doubleValue;
+
+                    addDebtor(charge.getIncomeAccountIdentifier(), doubleValue, debtors);
+                }
+                if (!unpaidCharges.isEmpty())
+                    throw new UnsupportedOperationException("Prepared amount " + preparedAmount + " is less than transfer fee amount for " +
+                            request.getIdentifier());
+
+                if (payedAmount > 0) {
+                    addCreditor(payableAccount.getIdentifier(), payedAmount, creditors);
+
+                    fromPrepareToRevenueEntry.setDebtors(debtors);
+                    fromPrepareToRevenueEntry.setCreditors(creditors);
+                    accountingService.createJournalEntry(fromPrepareToRevenueEntry);
+                }
+            }
+        }
+        if (!unpaidCharges.isEmpty()) {
+            // can not happen that prepared amount is more or less than requested transfer amount (identifier and message can be default)
+            final JournalEntry journalEntry = createJournalEntry(action.getIdentifier() + InteropRequestData.IDENTIFIER_SEPARATOR + "fee",
+                    transactionTypeCode, transactionDateString, message + " #fee", loginUser);
+
+            HashSet<Debtor> debtors = new HashSet<>(1);
+            HashSet<Creditor> creditors = new HashSet<>(1);
+
+            double payedAmount = 0d;
+            for (Charge charge : charges) {
+                BigDecimal value = calcChargeAmount(amount, charge, currency, true);
+                if (value == null)
+                    continue;
+
+                double doubleValue = value.doubleValue();
+                payedAmount += doubleValue;
+
+                addDebtor(charge.getIncomeAccountIdentifier(), doubleValue, debtors);
+            }
+
+            if (payedAmount > 0) {
+                addCreditor(accountId, payedAmount, creditors);
+
+                journalEntry.setDebtors(debtors);
+                journalEntry.setCreditors(creditors);
+                accountingService.createJournalEntry(journalEntry);
+            }
+        }
+
+        return preparedAmount;
+    }
+
+    // Util
+
+    private JournalEntry createJournalEntry(String actionIdentifier, String transactionType, String transactionDate, String message, String loginUser) {
+        final JournalEntry fromPrepareToNostroEntry = new JournalEntry();
+        fromPrepareToNostroEntry.setTransactionIdentifier(actionIdentifier);
+        fromPrepareToNostroEntry.setTransactionType(transactionType);
+        fromPrepareToNostroEntry.setTransactionDate(transactionDate);
+        fromPrepareToNostroEntry.setMessage(message);
+        fromPrepareToNostroEntry.setClerk(loginUser);
+        return fromPrepareToNostroEntry;
+    }
+
+    private void addCreditor(String accountNumber, double amount, HashSet<Creditor> creditors) {
+        Creditor creditor = new Creditor();
+        creditor.setAccountNumber(accountNumber);
+        creditor.setAmount(Double.toString(amount));
+        creditors.add(creditor);
+    }
+
+    private void addDebtor(String accountNumber, double amount, HashSet<Debtor> debtors) {
+        Debtor debtor = new Debtor();
+        debtor.setAccountNumber(accountNumber);
+        debtor.setAmount(Double.toString(amount));
+        debtors.add(debtor);
+    }
+
+    private BigDecimal calcChargeAmount(BigDecimal amount, Charge charge) {
+        return calcChargeAmount(amount, charge, null, false);
+    }
+
+    private BigDecimal calcChargeAmount(@NotNull BigDecimal amount, @NotNull Charge charge, Currency currency, boolean norm) {
+        Double value = charge.getAmount();
+        if (value == null)
+            return null;
+
+        BigDecimal portion = BigDecimal.valueOf(100.00d);
+        MathContext mc = MathUtil.CALCULATION_MATH_CONTEXT;
+        BigDecimal feeAmount = BigDecimal.valueOf(MathUtil.nullToZero(charge.getAmount()));
+        BigDecimal result = charge.getProportional()
+                ? amount.multiply(feeAmount.divide(portion, mc), mc)
+                : feeAmount;
+        return norm ? MathUtil.normalize(result, currency) : result;
+    }
+
+    @NotNull
+    private BigDecimal calcTotalCharges(@NotNull List<Charge> charges, BigDecimal amount) {
+        return charges.stream().map(charge -> calcChargeAmount(amount, charge)).reduce(MathUtil::add).orElse(BigDecimal.ZERO);
+    }
+
+    private Account validateAndGetAccount(@NotNull String accountId) {
+        //TODO: error handling
+        Account account = accountingService.findAccount(accountId);
+        validateAccount(account);
+
+        return account;
+    }
+
+    private AccountWrapper validateAndGetAccount(@NotNull InteropRequestData request) {
+        //TODO: error handling
+        String accountId = request.getAccountId();
+        Account account = accountingService.findAccount(accountId);
+        validateAccount(request, account);
+
+        ProductInstance product = depositService.findProductInstance(accountId);
+        ProductDefinition productDefinition = depositService.findProductDefinition(product.getProductIdentifier());
+
+        Currency currency = productDefinition.getCurrency();
+        if (!currency.getCode().equals(request.getAmount().getCurrency()))
+            throw new UnsupportedOperationException();
+
+        request.normalizeAmounts(currency);
+
+        Double withdrawableBalance = getWithdrawableBalance(account, productDefinition);
+        if (request.getTransactionRole().isWithdraw() && withdrawableBalance < request.getAmount().getAmount().doubleValue())
+            throw new UnsupportedOperationException();
+
+        return new AccountWrapper(account, product, productDefinition, withdrawableBalance);
+    }
+
+    private Account validateAndGetPayableAccount(@NotNull InteropRequestData request, @NotNull AccountWrapper wrapper) {
+        String referenceId = wrapper.account.getReferenceAccount();
+        if (referenceId == null)
+            return null;
+
+        return validateAndGetAccount(request, referenceId);
+    }
+
+    @NotNull
+    private Account validateAndGetNostroAccount(@NotNull InteropRequestData request) {
+        //TODO: error handling
+        List<Account> nostros = fetchAccounts(false, ACCOUNT_NAME_NOSTRO, AccountType.ASSET.name(), false, null, null, null, null);
+        int size = nostros.size();
+        if (size != 1)
+            throw new UnsupportedOperationException("NOSTRO Account " + (size == 0 ? "not found" : "is ambigous"));
+
+        Account nostro = nostros.get(0);
+        validateAccount(request, nostro);
+        return nostro;
+    }
+
+    @NotNull
+    private Account validateAndGetAccount(@NotNull InteropRequestData request, @NotNull String accountId) {
+        //TODO: error handling
+        Account account = accountingService.findAccount(accountId);
+
+        validateAccount(request, account);
+        return account;
+    }
+
+    private void validateAccount(Account account) {
+        if (account == null)
+            throw new UnsupportedOperationException("Account not found");
+        if (!account.getState().equals(Account.State.OPEN.name()))
+            throw new UnsupportedOperationException("Account is in state " + account.getState());
+    }
+
+    private void validateAccount(@NotNull InteropRequestData request, Account account) {
+        validateAccount(account);
+
+        String accountId = account.getIdentifier();
+
+        if (account.getHolders() != null) { // customer account
+            ProductInstance product = depositService.findProductInstance(accountId);
+            ProductDefinition productDefinition = depositService.findProductDefinition(product.getProductIdentifier());
+            if (!Boolean.TRUE.equals(productDefinition.getActive()))
+                throw new UnsupportedOperationException("NOSTRO Product Definition is inactive");
+
+            Currency currency = productDefinition.getCurrency();
+            if (!currency.getCode().equals(request.getAmount().getCurrency()))
+                throw new UnsupportedOperationException();
+        }
+    }
+
+    private BigDecimal validateTransfer(@NotNull InteropTransferRequestData request, @NotNull AccountWrapper accountWrapper) {
+        BigDecimal amount = request.getAmount().getAmount();
+
+        boolean isDebit = request.getTransactionRole().isWithdraw();
+        Currency currency = accountWrapper.productDefinition.getCurrency();
+
+        BigDecimal total = isDebit ? amount : MathUtil.negate(amount);
+        MoneyData fspFee = request.getFspFee();
+        if (fspFee != null) {
+            if (!currency.getCode().equals(fspFee.getCurrency()))
+                throw new UnsupportedOperationException();
+            //TODO: compare with calculated quote fee
+            total = MathUtil.add(total, fspFee.getAmount());
+        }
+        MoneyData fspCommission = request.getFspCommission();
+        if (fspCommission != null) {
+            if (!currency.getCode().equals(fspCommission.getCurrency()))
+                throw new UnsupportedOperationException();
+            //TODO: compare with calculated quote commission
+            total = MathUtil.subtractToZero(total, fspCommission.getAmount());
+        }
+        if (isDebit && accountWrapper.withdrawableBalance < request.getAmount().getAmount().doubleValue())
+            throw new UnsupportedOperationException();
+        return total;
+    }
+
+    public List<Account> fetchAccounts(boolean includeClosed, String term, String type, boolean includeCustomerAccounts,
+                                       Integer pageIndex, Integer size, String sortColumn, String sortDirection) {
+        return accountingService.fetchAccounts(includeClosed, term, type, includeCustomerAccounts, pageIndex, size, sortColumn, sortDirection);
+    }
+
+    public InteropIdentifierEntity findIdentifier(@NotNull InteropIdentifierType idType, @NotNull String idValue, String subIdOrType) {
+        return identifierRepository.findOne(Specifications.where(idTypeEqual(idType)).and(idValueEqual(idValue)).and(subIdOrTypeEqual(subIdOrType)));
+    }
+
+    public static Specification<InteropIdentifierEntity> idTypeEqual(@NotNull InteropIdentifierType idType) {
+        return (Root<InteropIdentifierEntity> root, CriteriaQuery<?> query, CriteriaBuilder cb) -> cb.and(cb.equal(root.get("type"), idType));
+    }
+
+    public static Specification<InteropIdentifierEntity> idValueEqual(@NotNull String idValue) {
+        return (Root<InteropIdentifierEntity> root, CriteriaQuery<?> query, CriteriaBuilder cb) -> cb.and(cb.equal(root.get("value"), idValue));
+    }
+
+    public static Specification<InteropIdentifierEntity> subIdOrTypeEqual(String subIdOrType) {
+        return (Root<InteropIdentifierEntity> root, CriteriaQuery<?> query, CriteriaBuilder cb) -> {
+            Path<Object> path = root.get("subValueOrType");
+            return cb.and(subIdOrType == null ? cb.isNull(path) : cb.equal(path, subIdOrType));
+        };
+    }
+
+    @NotNull
+    private String calcActionIdentifier(@NotNull String actionCode, @NotNull InteropActionType actionType) {
+        return actionType == InteropActionType.PREPARE || actionType == InteropActionType.COMMIT ? actionType + InteropRequestData.IDENTIFIER_SEPARATOR + actionCode : actionCode;
+    }
+
+    private InteropActionEntity validateAndGetAction(@NotNull String transactionCode, @NotNull String actionIdentifier, @NotNull InteropActionType actionType) {
+        return validateAndGetAction(transactionCode, actionIdentifier, actionType, true);
+    }
+
+    private InteropActionEntity validateAndGetAction(@NotNull String transactionCode, @NotNull String actionIdentifier, @NotNull InteropActionType actionType, boolean one) {
+        //TODO: error handling
+        InteropActionEntity action = actionRepository.findByIdentifier(actionIdentifier);
+        if (action == null) {
+            if (one)
+                throw new UnsupportedOperationException("Interperation action " + actionType + '/' + actionIdentifier + " was not found for this transaction " + transactionCode);
+            return null;
+        }
+        if (!action.getTransaction().getIdentifier().equals(transactionCode))
+            throw new UnsupportedOperationException("Interperation action " + actionType + '/' + actionIdentifier + " does not exist in this transaction " + transactionCode);
+        if (action.getActionType() != actionType)
+            throw new UnsupportedOperationException("Interperation action " + actionIdentifier + " is not this type " + actionType);
+
+        return action;
+    }
+
+    @NotNull
+    private InteropTransactionEntity validateAndGetTransaction(@NotNull InteropRequestData request, @NotNull AccountWrapper accountWrapper) {
+        return validateAndGetTransaction(request, accountWrapper, true);
+    }
+
+    @NotNull
+    private InteropTransactionEntity validateAndGetTransaction(@NotNull InteropRequestData request, @NotNull AccountWrapper accountWrapper, boolean create) {
+        return validateAndGetTransaction(request, accountWrapper, getNow(), create);
+    }
+
+    @NotNull
+    private InteropTransactionEntity validateAndGetTransaction(@NotNull InteropRequestData request, @NotNull AccountWrapper accountWrapper,
+                                                               @NotNull LocalDateTime createdOn, boolean create) {
+        //TODO: error handling
+        String transactionCode = request.getTransactionCode();
+        InteropTransactionEntity transaction = transactionRepository.findOneByIdentifier(request.getTransactionCode());
+        InteropState state = InteropStateMachine.handleTransition(transaction == null ? null : transaction.getState(), request.getActionType());
+        LocalDateTime now = getNow();
+        if (transaction == null) {
+            if (!create)
+                throw new UnsupportedOperationException("Interperation transaction " + request.getTransactionCode() + " does not exist ");
+            transaction = new InteropTransactionEntity(transactionCode, accountWrapper.account.getIdentifier(), getLoginUser(), now);
+            transaction.setState(state);
+            transaction.setAmount(request.getAmount().getAmount());
+            transaction.setName(request.getNote());
+            transaction.setTransactionType(request.getTransactionRole().getTransactionType());
+            Account payableAccount = validateAndGetPayableAccount(request, accountWrapper);
+            transaction.setPrepareAccountIdentifier(payableAccount == null ? null : payableAccount.getIdentifier());
+            transaction.setNostroAccountIdentifier(validateAndGetNostroAccount(request).getIdentifier());
+            transaction.setExpirationDate(request.getExpiration());
+        }
+        LocalDateTime expirationDate = transaction.getExpirationDate();
+        if (expirationDate != null && expirationDate.isBefore(now))
+            throw new UnsupportedOperationException("Interperation transaction expired on " + expirationDate);
+        return transaction;
+    }
+
+    private Currency getCurrency(InteropActionEntity action) {
+        ProductInstance product = depositService.findProductInstance(action.getTransaction().getCustomerAccountIdentifier());
+        ProductDefinition productDefinition = depositService.findProductDefinition(product.getProductIdentifier());
+        return productDefinition.getCurrency();
+    }
+
+    private InteropActionEntity addAction(@NotNull InteropTransactionEntity transaction, @NotNull InteropRequestData request) {
+        return addAction(transaction, request, getNow());
+    }
+
+    private InteropActionEntity addAction(@NotNull InteropTransactionEntity transaction, @NotNull InteropRequestData request,
+                                          @NotNull LocalDateTime createdOn) {
+        InteropActionEntity lastAction = getLastAction(transaction);
+
+        InteropActionType actionType = request.getActionType();
+        String actionIdentifier = calcActionIdentifier(request.getIdentifier(), request.getActionType());
+        InteropActionEntity action = new InteropActionEntity(actionIdentifier, transaction, request.getActionType(),
+                (lastAction == null ? 0 : lastAction.getSeqNo() + 1), getLoginUser(),
+                (lastAction == null ? transaction.getCreatedOn() : createdOn));
+        action.setState(InteropActionState.ACCEPTED);
+        action.setAmount(request.getAmount().getAmount());
+        action.setExpirationDate(request.getExpiration());
+        transaction.getActions().add(action);
+
+        InteropState currentState = transaction.getState();
+        if (transaction.getId() != null || InteropStateMachine.isValidAction(currentState, actionType)) // newly created was already set
+            transaction.setState(InteropStateMachine.handleTransition(currentState, actionType));
+        return action;
+    }
+
+    private InteropActionEntity getLastAction(InteropTransactionEntity transaction) {
+        List<InteropActionEntity> actions = transaction.getActions();
+        int size = actions.size();
+        return size == 0 ? null : actions.get(size - 1);
+    }
+
+    private InteropActionEntity findAction(InteropTransactionEntity transaction, InteropActionType actionType) {
+        List<InteropActionEntity> actions = transaction.getActions();
+        for (InteropActionEntity action : actions) {
+            if (action.getActionType() == actionType)
+                return action;
+        }
+        return null;
+    }
+
+    private LocalDateTime getNow() {
+        return LocalDateTime.now(Clock.systemUTC());
+    }
+
+    private String getLoginUser() {
+        return UserContextHolder.checkedGetUser();
+    }
+
+    public static class AccountWrapper {
+        @NotNull
+        private final Account account;
+        @NotNull
+        private final ProductInstance product;
+        @NotNull
+        private final ProductDefinition productDefinition;
+        @NotNull
+        private final Double withdrawableBalance;
+
+        public AccountWrapper(Account account, ProductInstance product, ProductDefinition productDefinition, Double withdrawableBalance) {
+            this.account = account;
+            this.product = product;
+            this.productDefinition = productDefinition;
+            this.withdrawableBalance = withdrawableBalance;
+        }
+    }
+}
diff --git a/service/src/main/java/org/apache/fineract/cn/interoperation/service/internal/service/helper/InteropAccountingService.java b/service/src/main/java/org/apache/fineract/cn/interoperation/service/internal/service/helper/InteropAccountingService.java
new file mode 100644
index 0000000..9d98fbc
--- /dev/null
+++ b/service/src/main/java/org/apache/fineract/cn/interoperation/service/internal/service/helper/InteropAccountingService.java
@@ -0,0 +1,120 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.fineract.cn.interoperation.service.internal.service.helper;
+
+import com.google.common.collect.Lists;
+import org.apache.fineract.cn.accounting.api.v1.client.AccountNotFoundException;
+import org.apache.fineract.cn.accounting.api.v1.client.LedgerManager;
+import org.apache.fineract.cn.accounting.api.v1.client.LedgerNotFoundException;
+import org.apache.fineract.cn.accounting.api.v1.domain.Account;
+import org.apache.fineract.cn.accounting.api.v1.domain.AccountEntry;
+import org.apache.fineract.cn.accounting.api.v1.domain.AccountPage;
+import org.apache.fineract.cn.accounting.api.v1.domain.JournalEntry;
+import org.apache.fineract.cn.accounting.api.v1.domain.Ledger;
+import org.apache.fineract.cn.interoperation.service.ServiceConstants;
+import org.apache.fineract.cn.lang.ServiceException;
+import org.slf4j.Logger;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.stereotype.Service;
+
+import javax.validation.constraints.NotNull;
+import java.math.BigDecimal;
+import java.util.HashSet;
+import java.util.List;
+
+@Service
+public class InteropAccountingService {
+
+    private Logger logger;
+    private LedgerManager ledgerManager;
+
+    @Autowired
+    public InteropAccountingService(@Qualifier(ServiceConstants.LOGGER_NAME) Logger logger,
+                                    LedgerManager ledgerManager) {
+        super();
+        this.logger = logger;
+        this.ledgerManager = ledgerManager;
+    }
+
+    public void createAccount(String equityLedger,
+                              String productName,
+                              String customer,
+                              String accountNumber,
+                              String alternativeAccountNumber,
+                              Double balance) {
+        try {
+            Ledger ledger = ledgerManager.findLedger(equityLedger);
+            Account account = new Account();
+            account.setIdentifier(accountNumber);
+            account.setType(ledger.getType());
+            account.setLedger(equityLedger);
+            account.setName(productName);
+            account.setHolders(new HashSet<>(Lists.newArrayList(customer)));
+            account.setBalance(balance != null ? balance : 0.00D);
+            account.setAlternativeAccountNumber(alternativeAccountNumber);
+
+            ledgerManager.createAccount(account);
+        } catch (LedgerNotFoundException lnfex) {
+            throw ServiceException.notFound("Ledger {0} not found.", equityLedger);
+        }
+    }
+
+    public List<Account> fetchAccounts(boolean includeClosed, String term, String type, boolean includeCustomerAccounts,
+                                     Integer pageIndex, Integer size, String sortColumn, String sortDirection) {
+        return ledgerManager.fetchAccounts(includeClosed, term, type, includeCustomerAccounts, pageIndex, size, sortColumn, sortDirection).getAccounts();
+    }
+
+    public Account findAccount(final String accountNumber) {
+        try {
+            return this.ledgerManager.findAccount(accountNumber);
+        } catch (final AccountNotFoundException anfex) {
+            final AccountPage accountPage = this.ledgerManager.fetchAccounts(true, accountNumber, null, true,
+                    0, 10, null, null);
+
+            return accountPage.getAccounts()
+                    .stream()
+                    .filter(account -> account.getAlternativeAccountNumber().equals(accountNumber))
+                    .findFirst()
+                    .orElseThrow(() -> ServiceException.notFound("Account {0} not found.", accountNumber));
+        }
+    }
+
+    public void modifyAccount(Account account) {
+        ledgerManager.modifyAccount(account.getIdentifier(), account);
+    }
+
+    public List<AccountEntry> fetchAccountEntries(String identifier, String dateRange, String direction) {
+        return ledgerManager
+                .fetchAccountEntries(identifier, dateRange, null, 0, 1, "transactionDate", direction)
+                .getAccountEntries();
+    }
+
+    public List<JournalEntry> fetchJournalEntries(final String dateRange, final String accountNumber, final BigDecimal amount) {
+        return ledgerManager.fetchJournalEntries(dateRange, accountNumber, amount);
+    }
+
+    public JournalEntry findJournalEntry(@NotNull String transactionIdentifier) {
+        return ledgerManager.findJournalEntry(transactionIdentifier);
+    }
+
+    public void createJournalEntry(@NotNull JournalEntry journalEntry) {
+        ledgerManager.createJournalEntry(journalEntry);
+    }
+}
diff --git a/service/src/main/java/org/apache/fineract/cn/interoperation/service/internal/service/helper/InteropDepositService.java b/service/src/main/java/org/apache/fineract/cn/interoperation/service/internal/service/helper/InteropDepositService.java
new file mode 100644
index 0000000..80bfd52
--- /dev/null
+++ b/service/src/main/java/org/apache/fineract/cn/interoperation/service/internal/service/helper/InteropDepositService.java
@@ -0,0 +1,128 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.fineract.cn.interoperation.service.internal.service.helper;
+
+import org.apache.fineract.cn.deposit.api.v1.client.DepositAccountManager;
+import org.apache.fineract.cn.deposit.api.v1.definition.domain.Action;
+import org.apache.fineract.cn.deposit.api.v1.definition.domain.Charge;
+import org.apache.fineract.cn.deposit.api.v1.definition.domain.DividendDistribution;
+import org.apache.fineract.cn.deposit.api.v1.definition.domain.ProductDefinition;
+import org.apache.fineract.cn.deposit.api.v1.instance.domain.AvailableTransactionType;
+import org.apache.fineract.cn.deposit.api.v1.instance.domain.ProductInstance;
+import org.apache.fineract.cn.interoperation.api.v1.domain.TransactionType;
+import org.apache.fineract.cn.interoperation.service.ServiceConstants;
+import org.slf4j.Logger;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.stereotype.Service;
+
+import javax.validation.constraints.NotNull;
+import java.util.List;
+import java.util.Set;
+import java.util.stream.Collectors;
+
+@Service
+public class InteropDepositService {
+
+    private Logger logger;
+    private DepositAccountManager depositAccountManager;
+
+    @Autowired
+    public InteropDepositService(@Qualifier(ServiceConstants.LOGGER_NAME) Logger logger,
+                                 DepositAccountManager depositAccountManager) {
+        super();
+        this.logger = logger;
+        this.depositAccountManager = depositAccountManager;
+    }
+
+    public List<Charge> getWithdrawCharges(String accountIdentifier) {
+        return getCharges(accountIdentifier, TransactionType.CURRENCY_WITHDRAWAL);
+    }
+
+    public List<Charge> getDepositCharges(String accountIdentifier) {
+        return getCharges(accountIdentifier, TransactionType.CURRENCY_DEPOSIT);
+    }
+
+    public List<Charge> getCharges(String accountIdentifier, TransactionType transactionType) {
+        List<Action> actions = depositAccountManager.fetchActions();
+
+        List<String> actionIds = actions
+                .stream()
+                .filter(action -> action.getTransactionType().equals(transactionType.getCode()))
+                .map(Action::getIdentifier)
+                .collect(Collectors.toList());
+
+        ProductInstance productInstance = depositAccountManager.findProductInstance(accountIdentifier);
+        ProductDefinition productDefinition = depositAccountManager.findProductDefinition(productInstance.getProductIdentifier());
+
+        return productDefinition.getCharges()
+                .stream()
+                .filter(charge -> actionIds.contains(charge.getActionIdentifier()))
+                .collect(Collectors.toList());
+    }
+
+    public void createAction(@NotNull Action action) {
+        depositAccountManager.create(action);
+    }
+
+    public List<Action> fetchActions() {
+        return depositAccountManager.fetchActions();
+    }
+
+    public void createProductDefinition(@NotNull ProductDefinition productDefinition) {
+        depositAccountManager.create(productDefinition);
+    }
+
+    public List<ProductDefinition> fetchProductDefinitions() {
+        return depositAccountManager.fetchProductDefinitions();
+    }
+
+    public ProductDefinition findProductDefinition(@NotNull String identifier) {
+        return depositAccountManager.findProductDefinition(identifier);
+    }
+
+    public List<ProductInstance> findProductInstances(@NotNull String identifier) {
+        return depositAccountManager.findProductInstances(identifier);
+    }
+
+    public void createProductInstance(@NotNull ProductInstance productInstance) {
+        depositAccountManager.create(productInstance);
+    }
+
+    public List<ProductInstance> fetchProductInstances(@NotNull String customer) {
+        return depositAccountManager.fetchProductInstances(customer);
+    }
+
+    public Set<AvailableTransactionType> fetchPossibleTransactionTypes(String customer) {
+        return depositAccountManager.fetchPossibleTransactionTypes(customer);
+    }
+
+    public ProductInstance findProductInstance(@NotNull String accountIdentifier) {
+        return depositAccountManager.findProductInstance(accountIdentifier);
+    }
+
+    public void dividendDistribution(@NotNull String identifier, @NotNull DividendDistribution distribution) {
+        depositAccountManager.dividendDistribution(identifier, distribution);
+    }
+
+    public List<DividendDistribution> fetchDividendDistributions(@NotNull String identifier) {
+        return depositAccountManager.fetchDividendDistributions(identifier);
+    }
+}
+
diff --git a/service/src/main/java/org/apache/fineract/cn/interoperation/service/rest/InteropRestController.java b/service/src/main/java/org/apache/fineract/cn/interoperation/service/rest/InteropRestController.java
new file mode 100644
index 0000000..b00fbd5
--- /dev/null
+++ b/service/src/main/java/org/apache/fineract/cn/interoperation/service/rest/InteropRestController.java
@@ -0,0 +1,277 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.fineract.cn.interoperation.service.rest;
+
+import org.apache.fineract.cn.anubis.annotation.AcceptedTokenType;
+import org.apache.fineract.cn.anubis.annotation.Permittable;
+import org.apache.fineract.cn.command.domain.CommandCallback;
+import org.apache.fineract.cn.command.gateway.CommandGateway;
+import org.apache.fineract.cn.interoperation.api.v1.domain.InteropIdentifierType;
+import org.apache.fineract.cn.interoperation.api.v1.domain.InteropTransferActionType;
+import org.apache.fineract.cn.interoperation.api.v1.domain.data.*;
+import org.apache.fineract.cn.interoperation.service.internal.command.InitializeServiceCommand;
+import org.apache.fineract.cn.interoperation.service.internal.service.InteropService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.MediaType;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.ResponseBody;
+import org.springframework.web.bind.annotation.RestController;
+
+import javax.validation.Valid;
+import javax.ws.rs.core.Context;
+import javax.ws.rs.core.UriInfo;
+
+import static org.apache.fineract.cn.interoperation.api.v1.PermittableGroupIds.INTEROPERATION_SINGLE;
+
+@SuppressWarnings("unused")
+@RestController
+@RequestMapping("/") //interoperation/v1
+public class InteropRestController {
+
+    private CommandGateway commandGateway;
+
+    private InteropService interopService;
+
+    @Autowired
+    public InteropRestController(CommandGateway commandGateway,
+                                 InteropService interopService) {
+        this.commandGateway = commandGateway;
+        this.interopService = interopService;
+    }
+
+    @Permittable(value = AcceptedTokenType.SYSTEM)
+    @RequestMapping(
+            value = "/initialize",
+            method = RequestMethod.POST,
+            consumes = MediaType.ALL_VALUE,
+            produces = MediaType.APPLICATION_JSON_VALUE
+    )
+    public
+    @ResponseBody
+    ResponseEntity<Void> initialize() {
+        this.commandGateway.process(new InitializeServiceCommand());
+        return ResponseEntity.accepted().build();
+    }
+
+    @Permittable(value = AcceptedTokenType.TENANT, groupId = INTEROPERATION_SINGLE)
+    @RequestMapping(
+            value = "/health",
+            method = RequestMethod.GET,
+            consumes = MediaType.ALL_VALUE,
+            produces = MediaType.APPLICATION_JSON_VALUE
+    )
+    public ResponseEntity<Void> health(@Context UriInfo uriInfo) {
+        return ResponseEntity.ok().build();
+    }
+
+    @Permittable(value = AcceptedTokenType.TENANT, groupId = INTEROPERATION_SINGLE)
+    @RequestMapping(
+            value = "/parties/{idType}/{idValue}",
+            method = RequestMethod.GET,
+            consumes = MediaType.ALL_VALUE,
+            produces = MediaType.APPLICATION_JSON_VALUE
+    )
+    public ResponseEntity<InteropIdentifierData> getAccountByIdentifier(@PathVariable("idType") InteropIdentifierType idType,
+                                                                        @PathVariable("idValue") String idValue) {
+        InteropIdentifierData account = interopService.getAccountByIdentifier(idType, idValue, null);
+
+        return ResponseEntity.ok(account);
+    }
+
+    @Permittable(value = AcceptedTokenType.TENANT, groupId = INTEROPERATION_SINGLE)
+    @RequestMapping(
+            value = "/parties/{idType}/{idValue}/{subIdOrType}",
+            method = RequestMethod.GET,
+            consumes = MediaType.ALL_VALUE,
+            produces = MediaType.APPLICATION_JSON_VALUE
+    )
+    public ResponseEntity<InteropIdentifierData> getAccountByIdentifier(@PathVariable("idType") InteropIdentifierType idType,
+                                                                        @PathVariable("idValue") String idValue,
+                                                                        @PathVariable(value = "subIdOrType") String subIdOrType) {
+        InteropIdentifierData account = interopService.getAccountByIdentifier(idType, idValue, subIdOrType);
+
+        return ResponseEntity.ok(account);
+    }
+
+    @Permittable(value = AcceptedTokenType.TENANT, groupId = INTEROPERATION_SINGLE)
+    @RequestMapping(
+            value = "/parties/{idType}/{idValue}",
+            method = RequestMethod.POST,
+            consumes = MediaType.APPLICATION_JSON_VALUE,
+            produces = MediaType.APPLICATION_JSON_VALUE
+    )
+    @ResponseBody
+    public ResponseEntity<InteropIdentifierData> registerAccountIdentifier(@PathVariable("idType") InteropIdentifierType idType,
+                                                                           @PathVariable("idValue") String idValue,
+                                                                           @RequestBody @Valid InteropIdentifierData requestData)
+            throws Throwable {
+        CommandCallback<InteropIdentifierData> result = commandGateway.process(new InteropIdentifierCommand(requestData,
+                        idType, idValue, null), InteropIdentifierData.class);
+
+        return ResponseEntity.ok(result.get());
+    }
+
+    @Permittable(value = AcceptedTokenType.TENANT, groupId = INTEROPERATION_SINGLE)
+    @RequestMapping(
+            value = "/parties/{idType}/{idValue}/{subIdOrType}",
+            method = RequestMethod.POST,
+            consumes = MediaType.APPLICATION_JSON_VALUE,
+            produces = MediaType.APPLICATION_JSON_VALUE
+    )
+    @ResponseBody
+    public ResponseEntity<InteropIdentifierData> registerAccountIdentifier(@PathVariable("idType") InteropIdentifierType idType,
+                                                                           @PathVariable("idValue") String idValue,
+                                                                           @PathVariable(value = "subIdOrType", required = false) String subIdOrType,
+                                                                           @RequestBody @Valid InteropIdentifierData requestData)
+            throws Throwable {
+        CommandCallback<InteropIdentifierData> result = commandGateway.process(new InteropIdentifierCommand(requestData,
+                idType, idValue, subIdOrType), InteropIdentifierData.class);
+
+        return ResponseEntity.ok(result.get());
+    }
+
+    @Permittable(value = AcceptedTokenType.TENANT, groupId = INTEROPERATION_SINGLE)
+    @RequestMapping(
+            value = "/parties/{idType}/{idValue}",
+            method = RequestMethod.DELETE,
+            consumes = MediaType.APPLICATION_JSON_VALUE,
+            produces = MediaType.APPLICATION_JSON_VALUE
+    )
+    @ResponseBody
+    public ResponseEntity<InteropIdentifierData> deleteAccountIdentifier(@PathVariable("idType") InteropIdentifierType idType,
+                                                                           @PathVariable("idValue") String idValue)
+            throws Throwable {
+        CommandCallback<InteropIdentifierData> result = commandGateway.process(new InteropIdentifierDeleteCommand(idType, idValue, null), InteropIdentifierData.class);
+
+        return ResponseEntity.ok(result.get());
+    }
+
+    @Permittable(value = AcceptedTokenType.TENANT, groupId = INTEROPERATION_SINGLE)
+    @RequestMapping(
+            value = "/parties/{idType}/{idValue}/{subIdOrType}",
+            method = RequestMethod.DELETE,
+            consumes = MediaType.APPLICATION_JSON_VALUE,
+            produces = MediaType.APPLICATION_JSON_VALUE
+    )
+    @ResponseBody
+    public ResponseEntity<InteropIdentifierData> deleteAccountIdentifier(@PathVariable("idType") InteropIdentifierType idType,
+                                                                         @PathVariable("idValue") String idValue,
+                                                                         @PathVariable(value = "subIdOrType", required = false) String subIdOrType)
+            throws Throwable {
+        CommandCallback<InteropIdentifierData> result = commandGateway.process(new InteropIdentifierDeleteCommand(idType, idValue, subIdOrType), InteropIdentifierData.class);
+
+        return ResponseEntity.ok(result.get());
+    }
+
+    @Permittable(value = AcceptedTokenType.TENANT, groupId = INTEROPERATION_SINGLE)
+    @RequestMapping(
+            value = "transactions/{transactionCode}/requests/{requestCode}",
+            method = RequestMethod.GET,
+            consumes = MediaType.ALL_VALUE,
+            produces = MediaType.APPLICATION_JSON_VALUE
+    )
+    @ResponseBody
+    public ResponseEntity<InteropTransactionRequestResponseData> getTransactionRequest(@PathVariable("transactionCode") String transactionCode,
+                                                                                       @PathVariable("requestCode") String requestCode) {
+        InteropTransactionRequestResponseData result = interopService.getTransactionRequest(transactionCode, requestCode);
+
+        return ResponseEntity.ok(result);
+    }
+
+    @Permittable(value = AcceptedTokenType.TENANT, groupId = INTEROPERATION_SINGLE)
+    @RequestMapping(
+            value = "/requests",
+            method = RequestMethod.POST,
+            consumes = MediaType.APPLICATION_JSON_VALUE,
+            produces = MediaType.APPLICATION_JSON_VALUE
+    )
+    @ResponseBody
+    public ResponseEntity<InteropTransactionRequestResponseData> createTransactionRequest(@RequestBody @Valid InteropTransactionRequestData requestData)
+            throws Throwable {
+        CommandCallback<InteropTransactionRequestResponseData> result = commandGateway.process(requestData, InteropTransactionRequestResponseData.class);
+
+        return ResponseEntity.ok(result.get());
+    }
+
+    @Permittable(value = AcceptedTokenType.TENANT, groupId = INTEROPERATION_SINGLE)
+    @RequestMapping(
+            value = "transactions/{transactionCode}/quotes/{quoteCode}",
+            method = RequestMethod.GET,
+            consumes = MediaType.ALL_VALUE,
+            produces = MediaType.APPLICATION_JSON_VALUE
+    )
+    @ResponseBody
+    public ResponseEntity<InteropQuoteResponseData> getQuote(@PathVariable("transactionCode") String transactionCode,
+                                                             @PathVariable("quoteCode") String quoteCode) {
+        InteropQuoteResponseData result = interopService.getQuote(transactionCode, quoteCode);
+
+        return ResponseEntity.ok(result);
+    }
+
+    @Permittable(value = AcceptedTokenType.TENANT, groupId = INTEROPERATION_SINGLE)
+    @RequestMapping(
+            value = "/quotes",
+            method = RequestMethod.POST,
+            consumes = MediaType.APPLICATION_JSON_VALUE,
+            produces = MediaType.APPLICATION_JSON_VALUE
+    )
+    @ResponseBody
+    public ResponseEntity<InteropQuoteResponseData> createQuote(@RequestBody @Valid InteropQuoteRequestData requestData) throws Throwable {
+        CommandCallback<InteropQuoteResponseData> result = commandGateway.process(requestData, InteropQuoteResponseData.class);
+
+        return ResponseEntity.ok(result.get());
+    }
+
+    @Permittable(value = AcceptedTokenType.TENANT, groupId = INTEROPERATION_SINGLE)
+    @RequestMapping(
+            value = "transactions/{transactionCode}/transfers/{transferCode}",
+            method = RequestMethod.GET,
+            consumes = MediaType.ALL_VALUE,
+            produces = MediaType.APPLICATION_JSON_VALUE
+    )
+    @ResponseBody
+    public ResponseEntity<InteropTransferResponseData> getTransfer(@PathVariable("transactionCode") String transactionCode,
+                                                                   @PathVariable("transferCode") String transferCode) {
+        InteropTransferResponseData result = interopService.getTransfer(transactionCode, transferCode);
+
+        return ResponseEntity.ok(result);
+    }
+
+    @Permittable(value = AcceptedTokenType.TENANT, groupId = INTEROPERATION_SINGLE)
+    @RequestMapping(
+            value = "/transfers",
+            method = RequestMethod.POST,
+            consumes = MediaType.APPLICATION_JSON_VALUE,
+            produces = MediaType.APPLICATION_JSON_VALUE
+    )
+    @ResponseBody
+    public ResponseEntity<InteropTransferResponseData> performTransfer(@RequestParam("action") String action,
+                                                                       @RequestBody @Valid InteropTransferRequestData requestData)
+            throws Throwable {
+        CommandCallback<InteropTransferResponseData> result = commandGateway.process(new InteropTransferCommand(requestData, InteropTransferActionType.valueOf(action)),
+                InteropTransferResponseData.class);
+
+        return ResponseEntity.ok(result.get());
+    }
+}
\ No newline at end of file
diff --git a/service/src/main/resources/application.yml b/service/src/main/resources/application.yml
new file mode 100644
index 0000000..68e0269
--- /dev/null
+++ b/service/src/main/resources/application.yml
@@ -0,0 +1,31 @@
+#
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license agreements.  See the NOTICE file
+# distributed with this work for additional information
+# regarding copyright ownership.  The ASF licenses this file
+# to you under the Apache License, Version 2.0 (the
+# "License"); you may not use this file except in compliance
+# with the License.  You may obtain a copy of the License at
+#
+#   http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing,
+# software distributed under the License is distributed on an
+# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+# KIND, either express or implied.  See the License for the
+# specific language governing permissions and limitations
+# under the License.
+#
+
+server:
+  port: 2034
+  contextPath: /interoperation/v1/*
+
+async:
+  corePoolSize: 32
+  maxPoolSize: 16384
+  queueCapacity: 0
+  threadName: async-processor-
+
+flyway:
+  enabled: false
diff --git a/service/src/main/resources/bootstrap.yml b/service/src/main/resources/bootstrap.yml
new file mode 100644
index 0000000..ce260b0
--- /dev/null
+++ b/service/src/main/resources/bootstrap.yml
@@ -0,0 +1,27 @@
+#
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license agreements.  See the NOTICE file
+# distributed with this work for additional information
+# regarding copyright ownership.  The ASF licenses this file
+# to you under the Apache License, Version 2.0 (the
+# "License"); you may not use this file except in compliance
+# with the License.  You may obtain a copy of the License at
+#
+#   http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing,
+# software distributed under the License is distributed on an
+# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+# KIND, either express or implied.  See the License for the
+# specific language governing permissions and limitations
+# under the License.
+#
+
+spring:
+    application:
+        name: interoperation-v1
+    cloud:
+        config:
+            uri: http://localhost:8761/config
+            username: config
+            password: config1234
diff --git a/service/src/main/resources/db/migrations/mariadb/V1__interop_init.sql b/service/src/main/resources/db/migrations/mariadb/V1__interop_init.sql
new file mode 100644
index 0000000..6a942df
--- /dev/null
+++ b/service/src/main/resources/db/migrations/mariadb/V1__interop_init.sql
@@ -0,0 +1,91 @@
+--
+-- Licensed to the Apache Software Foundation (ASF) under one
+-- or more contributor license agreements.  See the NOTICE file
+-- distributed with this work for additional information
+-- regarding copyright ownership.  The ASF licenses this file
+-- to you under the Apache License, Version 2.0 (the
+-- "License"); you may not use this file except in compliance
+-- with the License.  You may obtain a copy of the License at
+--
+--   http://www.apache.org/licenses/LICENSE-2.0
+--
+-- Unless required by applicable law or agreed to in writing,
+-- software distributed under the License is distributed on an
+-- "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+-- KIND, either express or implied.  See the License for the
+-- specific language governing permissions and limitations
+-- under the License.
+--
+
+CREATE TABLE hathor_identifiers (
+  id                          BIGINT       NOT NULL AUTO_INCREMENT,
+  customer_account_identifier VARCHAR(32)  NOT NULL,
+  type                        VARCHAR(32)  NOT NULL,
+  a_value                     VARCHAR(128) NOT NULL,
+  sub_value_or_type           VARCHAR(128) NULL,
+  created_by                  VARCHAR(32)  NOT NULL,
+  created_on                  TIMESTAMP(3) NOT NULL,
+  last_modified_by            VARCHAR(32)  NULL,
+  last_modified_on            TIMESTAMP(3) NULL,
+  CONSTRAINT pk_hathor_identifiers PRIMARY KEY (id),
+  CONSTRAINT uk_hathor_identifiers_value UNIQUE (type, a_value, sub_value_or_type)
+);
+
+
+CREATE TABLE hathor_transactions (
+  id                          BIGINT         NOT NULL AUTO_INCREMENT,
+  identifier                  VARCHAR(36)    NOT NULL,
+  a_name                      VARCHAR(256)   NULL,
+  description                 VARCHAR(1024)  NULL,
+  transaction_type            VARCHAR(32)    NOT NULL,
+  amount                      NUMERIC(22, 4) NOT NULL,
+  state                       VARCHAR(32)    NOT NULL,
+  customer_account_identifier VARCHAR(32)    NOT NULL,
+  payable_account_identifier  VARCHAR(32)    NULL,
+  nostro_account_identifier   VARCHAR(32)    NOT NULL,
+  transaction_date            TIMESTAMP(3)   NULL,
+  expiration_date             TIMESTAMP(3)   NULL,
+  created_by                  VARCHAR(32)    NOT NULL,
+  created_on                  TIMESTAMP(3)   NOT NULL,
+  last_modified_by            VARCHAR(32)    NULL,
+  last_modified_on            TIMESTAMP(3)   NULL,
+  CONSTRAINT pk_hathor_transactions PRIMARY KEY (id),
+  CONSTRAINT uk_hathor_transactions_id UNIQUE (identifier)
+);
+
+
+CREATE TABLE hathor_actions (
+  id              BIGINT         NOT NULL AUTO_INCREMENT,
+  identifier      VARCHAR(64)    NOT NULL,
+  transaction_id  BIGINT         NOT NULL,
+  action_type     VARCHAR(32)    NOT NULL,
+  seq_no          INT            NOT NULL,
+  state           VARCHAR(32)    NOT NULL,
+  amount          NUMERIC(22, 4) NOT NULL,
+  fee             NUMERIC(22, 4) NULL,
+  commission      NUMERIC(22, 4) NULL,
+  error_code      CHAR(4)        NULL,
+  error_msg       VARCHAR(128)   NULL,
+  expiration_date TIMESTAMP(3)   NULL,
+  created_by      VARCHAR(32)    NOT NULL,
+  created_on      TIMESTAMP(3)   NOT NULL,
+  CONSTRAINT pk_hathor_identifiers PRIMARY KEY (id),
+  CONSTRAINT uk_hathor_actions_id UNIQUE (identifier),
+  CONSTRAINT uk_hathor_actions_type UNIQUE (transaction_id, action_type),
+  CONSTRAINT uk_hathor_actions_seq UNIQUE (transaction_id, seq_no),
+  CONSTRAINT fk_hathor_actions_trans FOREIGN KEY (transaction_id) REFERENCES hathor_transactions (id)
+);
+
+-- data initialization
+
+INSERT INTO thoth_tx_types (identifier, a_name, description)
+VALUES ('FCWD', 'Interoperation withdrawal', 'Demo FCWD Interoperation withdrawal');
+INSERT INTO thoth_tx_types (identifier, a_name, description)
+VALUES ('FCDP', 'Interoperation deposit', 'Demo FCDP Interoperation deposit');
+
+
+INSERT INTO shed_actions (identifier, a_name, description, transaction_type)
+VALUES ('InteropWithdraw', 'Interoperation withdrawal', 'Demo FCWD Interoperation withdrawal', 'FCWD');
+INSERT INTO shed_actions (identifier, a_name, description, transaction_type)
+VALUES ('InteropDeposit', 'Interoperation deposit', 'Demo FCDP Interoperation deposit', 'FCDP');
+
diff --git a/service/src/main/resources/db/migrations/sample_data/interop_sample_data.sql b/service/src/main/resources/db/migrations/sample_data/interop_sample_data.sql
new file mode 100644
index 0000000..503c179
--- /dev/null
+++ b/service/src/main/resources/db/migrations/sample_data/interop_sample_data.sql
@@ -0,0 +1,61 @@
+--
+-- Licensed to the Apache Software Foundation (ASF) under one
+-- or more contributor license agreements.  See the NOTICE file
+-- distributed with this work for additional information
+-- regarding copyright ownership.  The ASF licenses this file
+-- to you under the Apache License, Version 2.0 (the
+-- "License"); you may not use this file except in compliance
+-- with the License.  You may obtain a copy of the License at
+--
+--   http://www.apache.org/licenses/LICENSE-2.0
+--
+-- Unless required by applicable law or agreed to in writing,
+-- software distributed under the License is distributed on an
+-- "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+-- KIND, either express or implied.  See the License for the
+-- specific language governing permissions and limitations
+-- under the License.
+--
+
+-- sample data initialization
+
+INSERT INTO horus_offices (identifier, a_name, description, created_by, created_on)
+VALUES ('Headquarter', 'Headquarter', 'Demo Headquarter', 'operator', CURDATE());
+
+SET @office_id = -1;
+SELECT id INTO @office_id FROM horus_offices WHERE identifier = 'Headquarter';
+
+INSERT INTO horus_addresses (office_id, street, city, country_code, country)
+VALUES (@office_id, 'Headquarter street', 'Headquarter city', 'IC', 'Inclusia');
+
+INSERT INTO maat_addresses (street, city, country_code, country)
+VALUES ('Customer street', 'Customer city', 'IC', 'Inclusia');
+
+
+SET @ledger_1300_id = -1;
+SELECT id INTO @ledger_1300_id FROM thoth_ledgers WHERE identifier = '1300';
+SET @ledger_3700_id = -1;
+SELECT id INTO @ledger_3700_id FROM thoth_ledgers WHERE identifier = '3700';
+SET @ledger_7300_id = -1;
+SELECT id INTO @ledger_7300_id FROM thoth_ledgers WHERE identifier = '7300';
+SET @ledger_7900_id = -1;
+SELECT id INTO @ledger_7900_id FROM thoth_ledgers WHERE identifier = '7900';
+SET @ledger_8100_id = -1;
+SELECT id INTO @ledger_8100_id FROM thoth_ledgers WHERE identifier = '8100';
+SET @ledger_9100_id = -1;
+SELECT id INTO @ledger_9100_id FROM thoth_ledgers WHERE identifier = '9100';
+
+INSERT INTO thoth_accounts (identifier, a_name, a_type, balance, ledger_id, a_state, created_by, created_on)
+VALUES ('97b1470ffd664cb799c3a9', 'Interoperation Payable Liability', 'LIABILITY', 1000000, @ledger_8100_id, 'OPEN', 'operator', CURDATE());
+INSERT INTO thoth_accounts (identifier, a_name, a_type, balance, ledger_id, a_state, created_by, created_on)
+VALUES ('353388f8c343445eac1bd6', 'Interoperation NOSTRO', 'ASSET', 1000000, @ledger_7900_id, 'OPEN', 'operator', CURDATE());
+INSERT INTO thoth_accounts (identifier, a_name, a_type, balance, ledger_id, a_state, created_by, created_on)
+VALUES ('0faaf81e05674f19859f18', 'Interoperation Product Cash', 'ASSET', 0, @ledger_7300_id, 'OPEN', 'operator', CURDATE());
+INSERT INTO thoth_accounts (identifier, a_name, a_type, balance, ledger_id, a_state, created_by, created_on)
+VALUES ('72df4f6613a911e9ab14d6', 'Interoperation Product Expenses', 'EXPENSE', 0, @ledger_3700_id, 'OPEN', 'operator', CURDATE());
+INSERT INTO thoth_accounts (identifier, a_name, a_type, balance, ledger_id, a_state, created_by, created_on)
+VALUES ('65f7de0e13a811e9ab14d6', 'Interoperation Product Accrue Liability', 'LIABILITY', 0, @ledger_8100_id, 'OPEN', 'operator', CURDATE());
+INSERT INTO thoth_accounts (identifier, a_name, a_type, balance, ledger_id, a_state, created_by, created_on)
+VALUES ('020323b613aa11e9ab14d6', 'Interoperation Product Equity', 'EQUITY', 0, @ledger_9100_id, 'OPEN', 'operator', CURDATE());
+INSERT INTO thoth_accounts (identifier, a_name, a_type, balance, ledger_id, a_state, created_by, created_on)
+VALUES ('87d607ba13aa11e9ab14d6', 'Interoperation Product Fees Revenue', 'REVENUE', 1000000, @ledger_1300_id, 'OPEN', 'operator', CURDATE());
\ No newline at end of file
diff --git a/service/src/main/resources/db/migrations/sample_data/tn01_interop_sample_data.sql b/service/src/main/resources/db/migrations/sample_data/tn01_interop_sample_data.sql
new file mode 100644
index 0000000..aa277fb
--- /dev/null
+++ b/service/src/main/resources/db/migrations/sample_data/tn01_interop_sample_data.sql
@@ -0,0 +1,68 @@
+--
+-- Licensed to the Apache Software Foundation (ASF) under one
+-- or more contributor license agreements.  See the NOTICE file
+-- distributed with this work for additional information
+-- regarding copyright ownership.  The ASF licenses this file
+-- to you under the Apache License, Version 2.0 (the
+-- "License"); you may not use this file except in compliance
+-- with the License.  You may obtain a copy of the License at
+--
+--   http://www.apache.org/licenses/LICENSE-2.0
+--
+-- Unless required by applicable law or agreed to in writing,
+-- software distributed under the License is distributed on an
+-- "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+-- KIND, either express or implied.  See the License for the
+-- specific language governing permissions and limitations
+-- under the License.
+--
+
+USE tn01;
+
+INSERT INTO maat_customers (identifier, a_type, given_name, surname, date_of_birth, is_member, current_state, address_id, created_by, created_on)
+  VALUES ('InteropCustomer', 'PERSON', 'Interoperation', 'Customer', '2000-01-01', 1, 'ACTIVE',
+        (SELECT id FROM maat_addresses WHERE street = 'Customer street'),
+        'operator', CURDATE());
+
+
+SET @ledger_7900_id = -1;
+SELECT id INTO @ledger_7900_id FROM thoth_ledgers WHERE identifier = '7900';
+
+SET @account_payable_id = -1;
+SELECT id INTO @account_payable_id FROM thoth_accounts WHERE identifier = '97b1470ffd664cb799c3a9';
+
+SET @account_customer_id = '31d77b06141c11e9ab14d6';
+
+INSERT INTO thoth_accounts (identifier, a_name, a_type, balance, reference_account_id, ledger_id, a_state, created_by, created_on)
+VALUES (@account_customer_id, 'Interoperation Customer Account', 'ASSET', 1000000, @account_payable_id, @ledger_7900_id, 'OPEN', 'operator', CURDATE());
+
+
+INSERT INTO hathor_identifiers (customer_account_identifier, type, a_value, sub_value_or_type, created_by, created_on)
+VALUES (@account_customer_id, 'IBAN', 'IC11in01tn0131d77b06141c11e9ab14d6', null, 'operator', CURDATE());
+INSERT INTO hathor_identifiers (customer_account_identifier, type, a_value, sub_value_or_type, created_by, created_on)
+VALUES (@account_customer_id, 'MSISDN', '27710101999', null, 'operator', CURDATE());
+
+
+SET @action_withdraw_id = -1;
+SELECT id INTO @action_withdraw_id FROM shed_actions WHERE identifier = 'InteropWithdraw';
+
+INSERT INTO shed_product_definitions (identifier, a_name, description, a_type, minimum_balance, equity_ledger_identifier,
+                                      cash_account_identifier, expense_account_identifier, accrue_account_identifier, is_flexible,
+                                      is_active, created_by, created_on)
+  VALUES ('InteropCustomerProduct', 'Interoperation Customer Product', 'Demo Interoperation Product', 'SAVINGS', 100, '9100', '0faaf81e05674f19859f18',
+          '72df4f6613a911e9ab14d6', '65f7de0e13a811e9ab14d6', 0, 1,  'operator', CURDATE());
+
+SET @prod_def_id = -1;
+SELECT id INTO @prod_def_id FROM shed_product_definitions WHERE identifier = 'InteropCustomerProduct';
+
+INSERT INTO shed_currencies (product_definition_id, a_code, a_name, sign, scale)
+  VALUES (@prod_def_id, 'TZS', 'Inclusia Rupee', 'TSh', 2);
+
+INSERT INTO shed_terms (product_definition_id, period, time_unit, interest_payable)
+  VALUES (@prod_def_id, 1, 'YEAR', 'ANNUALLY');
+
+INSERT INTO shed_charges (product_definition_id, action_id, a_name, description, income_account_identifier, proportional, amount)
+VALUES (@prod_def_id, @action_withdraw_id, 'Interoperation Withdraw Fee', 'Interoperation Revenue Fees', '87d607ba13aa11e9ab14d6', 1, 1.00);
+
+INSERT INTO shed_product_instances (product_definition_id, customer_identifier, account_identifier, a_state, opened_on, created_by, created_on)
+VALUES (@prod_def_id, 'InteropCustomer', @account_customer_id, 'ACTIVE', CURDATE(), 'operator', CURDATE());
\ No newline at end of file
diff --git a/service/src/main/resources/db/migrations/sample_data/tn02_interop_sample_data.sql b/service/src/main/resources/db/migrations/sample_data/tn02_interop_sample_data.sql
new file mode 100644
index 0000000..efa3669
--- /dev/null
+++ b/service/src/main/resources/db/migrations/sample_data/tn02_interop_sample_data.sql
@@ -0,0 +1,68 @@
+--
+-- Licensed to the Apache Software Foundation (ASF) under one
+-- or more contributor license agreements.  See the NOTICE file
+-- distributed with this work for additional information
+-- regarding copyright ownership.  The ASF licenses this file
+-- to you under the Apache License, Version 2.0 (the
+-- "License"); you may not use this file except in compliance
+-- with the License.  You may obtain a copy of the License at
+--
+--   http://www.apache.org/licenses/LICENSE-2.0
+--
+-- Unless required by applicable law or agreed to in writing,
+-- software distributed under the License is distributed on an
+-- "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+-- KIND, either express or implied.  See the License for the
+-- specific language governing permissions and limitations
+-- under the License.
+--
+
+USE tn02;
+
+INSERT INTO maat_customers (identifier, a_type, given_name, surname, date_of_birth, is_member, current_state, address_id, created_by, created_on)
+  VALUES ('InteropMerchant', 'PERSON', 'Interoperation', 'Merchant', '2000-01-01', 1, 'ACTIVE',
+        (SELECT id FROM maat_addresses WHERE street = 'Customer street'),
+        'operator', CURDATE());
+
+
+SET @ledger_7900_id = -1;
+SELECT id INTO @ledger_7900_id FROM thoth_ledgers WHERE identifier = '7900';
+
+SET @account_payable_id = -1;
+SELECT id INTO @account_payable_id FROM thoth_accounts WHERE identifier = '97b1470ffd664cb799c3a9';
+
+SET @account_customer_id = '83c4ed1c074b484e85cc79';
+
+INSERT INTO thoth_accounts (identifier, a_name, a_type, balance, reference_account_id, ledger_id, a_state, created_by, created_on)
+VALUES (@account_customer_id, 'Interoperation Merchant Account', 'ASSET', 1000000, @account_payable_id, @ledger_7900_id, 'OPEN', 'operator', CURDATE());
+
+
+INSERT INTO hathor_identifiers (customer_account_identifier, type, a_value, sub_value_or_type, created_by, created_on)
+VALUES (@account_customer_id, 'IBAN', 'IC11in01tn0283c4ed1c074b484e85cc79', null, 'operator', CURDATE());
+INSERT INTO hathor_identifiers (customer_account_identifier, type, a_value, sub_value_or_type, created_by, created_on)
+VALUES (@account_customer_id, 'MSISDN', '27710102999', null, 'operator', CURDATE());
+
+
+SET @action_withdraw_id = -1;
+SELECT id INTO @action_withdraw_id FROM shed_actions WHERE identifier = 'InteropWithdraw';
+
+INSERT INTO shed_product_definitions (identifier, a_name, description, a_type, minimum_balance, equity_ledger_identifier,
+                                      cash_account_identifier, expense_account_identifier, accrue_account_identifier, is_flexible,
+                                      is_active, created_by, created_on)
+  VALUES ('InteropMerchantProduct', 'Interoperation Merchant Product', 'Demo Interoperation Product', 'SAVINGS', 100, '9100', '0faaf81e05674f19859f18',
+          '72df4f6613a911e9ab14d6', '65f7de0e13a811e9ab14d6', 0, 1,  'operator', CURDATE());
+
+SET @prod_def_id = -1;
+SELECT id INTO @prod_def_id FROM shed_product_definitions WHERE identifier = 'InteropMerchantProduct';
+
+INSERT INTO shed_currencies (product_definition_id, a_code, a_name, sign, scale)
+  VALUES (@prod_def_id, 'TZS', 'Inclusia Rupee', 'TSh', 2);
+
+INSERT INTO shed_terms (product_definition_id, period, time_unit, interest_payable)
+  VALUES (@prod_def_id, 1, 'YEAR', 'ANNUALLY');
+
+INSERT INTO shed_charges (product_definition_id, action_id, a_name, description, income_account_identifier, proportional, amount)
+VALUES (@prod_def_id, @action_withdraw_id, 'Interoperation Withdraw Fee', 'Interoperation Revenue Fees', '87d607ba13aa11e9ab14d6', 1, 1.00);
+
+INSERT INTO shed_product_instances (product_definition_id, customer_identifier, account_identifier, a_state, opened_on, created_by, created_on)
+VALUES (@prod_def_id, 'InteropMerchant', @account_customer_id, 'ACTIVE', CURDATE(), 'operator', CURDATE());
\ No newline at end of file
diff --git a/service/src/main/resources/logback.xml b/service/src/main/resources/logback.xml
new file mode 100644
index 0000000..a5b8aa3
--- /dev/null
+++ b/service/src/main/resources/logback.xml
@@ -0,0 +1,58 @@
+<!--
+
+    Licensed to the Apache Software Foundation (ASF) under one
+    or more contributor license agreements.  See the NOTICE file
+    distributed with this work for additional information
+    regarding copyright ownership.  The ASF licenses this file
+    to you under the Apache License, Version 2.0 (the
+    "License"); you may not use this file except in compliance
+    with the License.  You may obtain a copy of the License at
+
+      http://www.apache.org/licenses/LICENSE-2.0
+
+    Unless required by applicable law or agreed to in writing,
+    software distributed under the License is distributed on an
+    "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+    KIND, either express or implied.  See the License for the
+    specific language governing permissions and limitations
+    under the License.
+
+-->
+<configuration>
+    <appender name="FILE" class="ch.qos.logback.core.rolling.RollingFileAppender">
+        <file>logs/interoperation.log</file>
+        <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
+            <fileNamePattern>logs/archive/interoperation.%d{yyyy-MM-dd}.log</fileNamePattern>
+            <maxHistory>7</maxHistory>
+            <totalSizeCap>2GB</totalSizeCap>
+        </rollingPolicy>
+        <encoder>
+            <pattern>%d{HH:mm:ss.SSS} [%thread] %-5level %logger{36} - %msg%n</pattern>
+        </encoder>
+    </appender>
+    <appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">
+        <encoder>
+            <pattern>%d{HH:mm:ss.SSS} [%thread] %-5level %logger{36} - %msg%n</pattern>
+        </encoder>
+    </appender>
+
+    <logger name="com" level="INFO">
+        <appender-ref ref="STDOUT" />
+    </logger>
+
+    <logger name="org" level="INFO">
+        <appender-ref ref="STDOUT" />
+    </logger>
+
+    <logger name="io" level="INFO">
+        <appender-ref ref="STDOUT" />
+    </logger>
+
+    <logger name="net" level="INFO">
+        <appender-ref ref="STDOUT" />
+    </logger>
+
+    <root level="DEBUG">
+        <appender-ref ref="FILE"/>
+    </root>
+</configuration>
\ No newline at end of file
diff --git a/settings.gradle b/settings.gradle
new file mode 100644
index 0000000..f36b432
--- /dev/null
+++ b/settings.gradle
@@ -0,0 +1,22 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+rootProject.name = 'interoperation'
+
+includeBuild 'api'
+includeBuild 'service'
+
diff --git a/shared.gradle b/shared.gradle
new file mode 100644
index 0000000..9d10733
--- /dev/null
+++ b/shared.gradle
@@ -0,0 +1,105 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+group 'org.apache.fineract.cn.interoperation'
+version '0.1.0-BUILD-SNAPSHOT'
+
+ext.versions = [
+        frameworkanubis    : '0.1.0-BUILD-SNAPSHOT',
+        frameworkapi       : '0.1.0-BUILD-SNAPSHOT',
+        frameworklang      : '0.1.0-BUILD-SNAPSHOT',
+        frameworkmariadb   : '0.1.0-BUILD-SNAPSHOT',
+        frameworkcassandra : '0.1.0-BUILD-SNAPSHOT',
+        frameworkcommand   : '0.1.0-BUILD-SNAPSHOT',
+        frameworktest      : '0.1.0-BUILD-SNAPSHOT',
+        frameworkasync     : '0.1.0-BUILD-SNAPSHOT',
+        frameworkcustomer  : '0.1.0-BUILD-SNAPSHOT',
+        frameworkcompany   : '0.1.0-BUILD-SNAPSHOT',
+        frameworkledger    : '0.1.0-BUILD-SNAPSHOT',
+        frameworkdeposit   : '0.1.0-BUILD-SNAPSHOT',
+        frameworkteller    : '0.1.0-BUILD-SNAPSHOT',
+        frameworkinter     : '0.1.0-BUILD-SNAPSHOT',
+        apachecsvreader    : '1.4',
+        validator   : '5.3.0.Final'
+]
+
+apply plugin: 'java'
+apply plugin: 'idea'
+apply plugin: 'maven-publish'
+apply plugin: 'io.spring.dependency-management'
+
+tasks.withType(JavaCompile) {
+    sourceCompatibility = JavaVersion.VERSION_1_8
+    targetCompatibility = JavaVersion.VERSION_1_8
+}
+
+repositories {
+    jcenter()
+    mavenLocal()
+}
+
+dependencyManagement {
+    imports {
+        mavenBom 'io.spring.platform:platform-bom:Athens-RELEASE'
+        mavenBom 'org.springframework.cloud:spring-cloud-dependencies:Camden.SR1'
+    }
+}
+
+// override certain dependency provided by Spring platform using newer releases
+ext['cassandra.version'] = '3.6'
+ext['cassandra-driver.version'] = '3.1.2'
+ext['activemq.version'] = '5.13.2'
+ext['spring-data-releasetrain.version'] = 'Gosling-SR2A'
+
+dependencies {
+    compile(
+            [group: 'com.google.code.findbugs', name: 'jsr305']
+    )
+
+    testCompile(
+            [group: 'org.springframework.boot', name: 'spring-boot-starter-test']
+    )
+}
+
+jar {
+    from sourceSets.main.allSource
+    duplicatesStrategy = DuplicatesStrategy.EXCLUDE
+}
+
+license {
+    header rootProject.file('../HEADER')
+    strictCheck false
+    mapping {
+        java = 'SLASHSTAR_STYLE'
+        xml = 'XML_STYLE'
+        yml = 'SCRIPT_STYLE'
+        yaml = 'SCRIPT_STYLE'
+    }
+}
+
+rat {
+    // List of exclude directives, defaults to ['**/.gradle/**']
+    excludes = [
+            "**/.idea/**",
+            "**/.gradle/**",
+            "**/gradle/**",
+            "**/build/**",
+            "gradlew",
+            "gradlew.bat",
+            "README.md"
+    ]
+}