diff --git a/connector-amqp-import/amqp.xml b/connector-amqp-import/amqp.xml
new file mode 100644
index 0000000..0308bcf
--- /dev/null
+++ b/connector-amqp-import/amqp.xml
@@ -0,0 +1,509 @@
+
+ AmqpImport
+
+ 2019-05-10T19:14:32.966Z
+
+ http://midpoint.evolveum.com/xml/ns/public/gui/channels-3#user
+
+
+ 2017-09-21T14:11:32.117Z
+
+
+ modify
+ c:ResourceType
+
+
+ com.evolveum.midpoint.model.impl.lens.ChangeExecutor.executeDelta
+ success
+ 1000000000000000107
+
+ AmqpImport
+
+ success
+
+ http://midpoint.evolveum.com/xml/ns/public/gui/channels-3#user
+
+
+ 2017-09-21T14:11:51.716Z
+
+
+ modify
+ c:ResourceType
+
+
+ com.evolveum.midpoint.model.impl.lens.ChangeExecutor.executeDelta
+ success
+ 1000000000000000156
+
+ AmqpImport
+
+ success
+
+ http://midpoint.evolveum.com/xml/ns/public/gui/channels-3#user
+
+
+ 2017-09-21T14:11:54.743Z
+
+
+ modify
+ c:ResourceType
+
+
+ com.evolveum.midpoint.model.impl.lens.ChangeExecutor.executeDelta
+ success
+ 1000000000000000185
+
+ AmqpImport
+
+ success
+
+ http://midpoint.evolveum.com/xml/ns/public/gui/channels-3#user
+
+
+ 2017-09-21T14:11:57.924Z
+
+
+ modify
+ c:ResourceType
+
+
+ com.evolveum.midpoint.model.impl.lens.ChangeExecutor.executeDelta
+ success
+ 1000000000000000214
+
+ AmqpImport
+
+ success
+
+ http://midpoint.evolveum.com/xml/ns/public/gui/channels-3#user
+
+
+ 2019-05-10T19:14:33.060Z
+
+
+ modify
+ c:ResourceType
+
+
+ com.evolveum.midpoint.model.impl.lens.ChangeExecutor.executeDelta
+ success
+ 1000000000000000640
+
+ AmqpImport
+
+ success
+
+ http://midpoint.evolveum.com/xml/ns/public/gui/channels-3#user
+
+
+ up
+
+
+
+
+ c:connectorType
+ edu.unc.polygon.connector.amqp.AmqpConnector
+
+
+
+
+
+ id
+ sor
+ sor_person
+ payload
+ 5ecr3t
+ mq
+ sor_person
+ mysql
+ id
+
+
+
+
+ 2019-05-10T19:14:33.138Z
+ cccc5a900956c4dc-dda4212a83666460
+
+
+
+
+
+
+
+
+
+
+ icfs:uid
+ icfs:name
+ icfs:name
+ icfs:name
+ MESSAGE_OBJECT_CLASS___ACCOUNT__
+
+
+
+
+
+
+ 120
+ orgId
+
+
+
+
+
+
+ 130
+ active
+
+
+
+
+
+
+ 140
+ subject-id
+ subjectId
+
+
+
+
+
+
+ 150
+ phone
+
+
+
+
+
+
+ 160
+ sourceId
+
+
+
+
+
+
+ 170
+ firstname
+
+
+
+
+
+
+ 180
+ birthDate
+
+
+
+
+
+
+ 190
+ nameType
+
+
+
+
+
+
+ 200
+ email
+
+
+
+
+
+
+ 210
+ personalPronoun
+
+
+
+
+
+
+ 220
+ middleName
+
+
+
+
+
+
+ 230
+ lastname
+
+
+
+
+
+
+ 240
+ login-id
+ loginId
+
+
+
+
+
+
+ 250
+ priorSubject-id
+ priorSubjectId
+
+
+
+
+
+
+ ConnId Name
+ 110
+ __NAME__
+
+
+
+
+
+
+ 260
+ job
+
+
+
+
+
+
+ 270
+ fullname
+
+
+
+
+
+
+ 280
+ givenName
+
+
+
+
+
+
+ 290
+ familyName
+
+
+
+
+
+
+ ConnId UID
+ 100
+ read
+
+
+
+
+
+
+
+
+
+
+ account
+ default
+ true
+ ri:MESSAGE_OBJECT_CLASS___ACCOUNT__
+
+ icfs:name
+ Employee ID
+
+
+ $user/name
+
+
+
+
+ ri:firstname
+
+
+ $user/givenName
+
+
+
+
+ ri:fullname
+
+
+ true
+
+
+
+
+
+ ri:lastname
+
+
+ $user/familyName
+
+
+
+
+ ri:orgId
+
+
+ $user/organizationalUnit
+
+
+
+
+ ri:job
+
+
+ $user/title
+
+
+
+
+ ri:phone
+
+
+ phonetmp
+ $user/phoneNumber
+
+
+ true
+
+
+
+
+
+ ri:email
+
+
+ emailtmp
+ $user/emailAddress
+
+
+ true
+
+
+
+
+
+
+
+ weak
+
+
+
+
+
+
+ weak
+
+
+
+
+
+
+
+
+
+
+ 2019-05-10T19:14:33.136Z
+ b206157efe3db85b-2aa5ea9c80762fd5
+
+
+
+
+
+
+
+ connector
+
+
+
+
+ false
+
+
+
+
+ true
+
+
+ true
+
+
+ true
+
+
+ true
+
+ connector
+
+
+
+ true
+
+
+
+
+ full
+
+
+
+ true
+
+
+ polyStringNorm
+ c:name
+
+ Matches using Name
+ declare namespace ri="http://midpoint.evolveum.com/xml/ns/public/resource/instance-3"; $account/attributes/icfs:name
+
+
+
+
+ linked
+ true
+
+
+ deleted
+ true
+
+ http://midpoint.evolveum.com/xml/ns/public/model/action-3#deleteFocus
+
+
+
+ unlinked
+ true
+
+ http://midpoint.evolveum.com/xml/ns/public/model/action-3#link
+
+
+
+ unmatched
+ true
+
+ http://midpoint.evolveum.com/xml/ns/public/model/action-3#addFocus
+
+
+
+
+
+
diff --git a/connector-amqp-import/amqp2.xml b/connector-amqp-import/amqp2.xml
new file mode 100644
index 0000000..d1e4cb2
--- /dev/null
+++ b/connector-amqp-import/amqp2.xml
@@ -0,0 +1,510 @@
+
+ AmqpImport
+
+ 2019-05-10T19:14:32.966Z
+
+ http://midpoint.evolveum.com/xml/ns/public/gui/channels-3#user
+
+
+ 2017-09-21T14:11:32.117Z
+
+
+ modify
+ c:ResourceType
+
+
+ com.evolveum.midpoint.model.impl.lens.ChangeExecutor.executeDelta
+ success
+ 1000000000000000107
+
+ AmqpImport
+
+ success
+
+ http://midpoint.evolveum.com/xml/ns/public/gui/channels-3#user
+
+
+ 2017-09-21T14:11:51.716Z
+
+
+ modify
+ c:ResourceType
+
+
+ com.evolveum.midpoint.model.impl.lens.ChangeExecutor.executeDelta
+ success
+ 1000000000000000156
+
+ AmqpImport
+
+ success
+
+ http://midpoint.evolveum.com/xml/ns/public/gui/channels-3#user
+
+
+ 2017-09-21T14:11:54.743Z
+
+
+ modify
+ c:ResourceType
+
+
+ com.evolveum.midpoint.model.impl.lens.ChangeExecutor.executeDelta
+ success
+ 1000000000000000185
+
+ AmqpImport
+
+ success
+
+ http://midpoint.evolveum.com/xml/ns/public/gui/channels-3#user
+
+
+ 2017-09-21T14:11:57.924Z
+
+
+ modify
+ c:ResourceType
+
+
+ com.evolveum.midpoint.model.impl.lens.ChangeExecutor.executeDelta
+ success
+ 1000000000000000214
+
+ AmqpImport
+
+ success
+
+ http://midpoint.evolveum.com/xml/ns/public/gui/channels-3#user
+
+
+ 2019-05-10T19:14:33.060Z
+
+
+ modify
+ c:ResourceType
+
+
+ com.evolveum.midpoint.model.impl.lens.ChangeExecutor.executeDelta
+ success
+ 1000000000000000640
+
+ AmqpImport
+
+ success
+
+ http://midpoint.evolveum.com/xml/ns/public/gui/channels-3#user
+
+
+ up
+
+
+
+
+ c:connectorType
+ edu.unc.polygon.connector.amqp.AmqpConnector
+
+
+
+
+
+ id
+ sor
+ sor_person
+ payload
+ 5ecr3t
+ mq
+ sor_person
+ mysql
+ id
+
+
+
+
+ 2019-05-10T19:14:33.138Z
+ cccc5a900956c4dc-dda4212a83666460
+
+
+
+
+
+
+
+
+
+
+ icfs:uid
+ icfs:name
+ icfs:name
+ icfs:name
+ MESSAGE_OBJECT_CLASS___ACCOUNT__
+
+
+
+
+
+
+ 120
+ orgId
+
+
+
+
+
+
+ 130
+ active
+
+
+
+
+
+
+ 140
+ subject-id
+ subjectId
+
+
+
+
+
+
+ 150
+ phone
+
+
+
+
+
+
+ 160
+ sourceId
+
+
+
+
+
+
+ 170
+ firstname
+
+
+
+
+
+
+ 180
+ birthDate
+
+
+
+
+
+
+ 190
+ nameType
+
+
+
+
+
+
+ 200
+ email
+
+
+
+
+
+
+ 210
+ personalPronoun
+
+
+
+
+
+
+ 220
+ middleName
+
+
+
+
+
+
+ 230
+ lastname
+
+
+
+
+
+
+ 240
+ login-id
+ loginId
+
+
+
+
+
+
+ 250
+ priorSubject-id
+ priorSubjectId
+
+
+
+
+
+
+ ConnId Name
+ 110
+ __NAME__
+
+
+
+
+
+
+ 260
+ job
+
+
+
+
+
+
+ 270
+ fullname
+
+
+
+
+
+
+ 280
+ givenName
+
+
+
+
+
+
+ 290
+ familyName
+
+
+
+
+
+
+ ConnId UID
+ 100
+ read
+
+
+
+
+
+
+
+
+
+
+ account
+ default
+ true
+ ri:MESSAGE_OBJECT_CLASS___ACCOUNT__
+
+ icfs:name
+ Employee ID
+
+
+ $user/name
+
+
+
+
+ ri:firstname
+
+
+ $user/givenName
+
+
+
+
+ ri:fullname
+
+
+ true
+
+
+
+ $user/fullName
+
+
+
+
+ ri:lastname
+
+
+ $user/familyName
+
+
+
+
+ ri:orgId
+
+
+ $user/organizationalUnit
+
+
+
+
+ ri:job
+
+
+ $user/title
+
+
+
+
+ ri:phone
+
+
+ true
+
+
+
+ $user/telephoneNumber
+
+
+
+
+ ri:email
+
+
+ true
+
+
+
+ $user/emailAddress
+
+
+
+
+
+
+ weak
+
+
+
+
+
+
+ weak
+
+
+
+
+
+
+
+
+
+
+ 2019-05-10T19:14:33.136Z
+ b206157efe3db85b-2aa5ea9c80762fd5
+
+
+
+
+
+
+
+ connector
+
+
+
+
+ false
+
+
+
+
+ true
+
+
+ true
+
+
+ true
+
+
+ true
+
+ connector
+
+
+
+ true
+
+
+
+
+ full
+
+
+
+ true
+
+
+ polyStringNorm
+ c:name
+
+ Matches using Name
+ declare namespace ri="http://midpoint.evolveum.com/xml/ns/public/resource/instance-3"; $account/attributes/icfs:name
+
+
+
+
+ linked
+ true
+
+
+ deleted
+ true
+
+ http://midpoint.evolveum.com/xml/ns/public/model/action-3#deleteFocus
+
+
+
+ unlinked
+ true
+
+ http://midpoint.evolveum.com/xml/ns/public/model/action-3#link
+
+
+
+ unmatched
+ true
+
+ http://midpoint.evolveum.com/xml/ns/public/model/action-3#addFocus
+
+
+
+
+
+
diff --git a/connector-amqp-import/amqp3.xml b/connector-amqp-import/amqp3.xml
new file mode 100644
index 0000000..d7be0a8
--- /dev/null
+++ b/connector-amqp-import/amqp3.xml
@@ -0,0 +1,510 @@
+
+ AmqpImport
+
+ 2019-05-10T19:14:32.966Z
+
+ http://midpoint.evolveum.com/xml/ns/public/gui/channels-3#user
+
+
+ 2017-09-21T14:11:32.117Z
+
+
+ modify
+ c:ResourceType
+
+
+ com.evolveum.midpoint.model.impl.lens.ChangeExecutor.executeDelta
+ success
+ 1000000000000000107
+
+ AmqpImport
+
+ success
+
+ http://midpoint.evolveum.com/xml/ns/public/gui/channels-3#user
+
+
+ 2017-09-21T14:11:51.716Z
+
+
+ modify
+ c:ResourceType
+
+
+ com.evolveum.midpoint.model.impl.lens.ChangeExecutor.executeDelta
+ success
+ 1000000000000000156
+
+ AmqpImport
+
+ success
+
+ http://midpoint.evolveum.com/xml/ns/public/gui/channels-3#user
+
+
+ 2017-09-21T14:11:54.743Z
+
+
+ modify
+ c:ResourceType
+
+
+ com.evolveum.midpoint.model.impl.lens.ChangeExecutor.executeDelta
+ success
+ 1000000000000000185
+
+ AmqpImport
+
+ success
+
+ http://midpoint.evolveum.com/xml/ns/public/gui/channels-3#user
+
+
+ 2017-09-21T14:11:57.924Z
+
+
+ modify
+ c:ResourceType
+
+
+ com.evolveum.midpoint.model.impl.lens.ChangeExecutor.executeDelta
+ success
+ 1000000000000000214
+
+ AmqpImport
+
+ success
+
+ http://midpoint.evolveum.com/xml/ns/public/gui/channels-3#user
+
+
+ 2019-05-10T19:14:33.060Z
+
+
+ modify
+ c:ResourceType
+
+
+ com.evolveum.midpoint.model.impl.lens.ChangeExecutor.executeDelta
+ success
+ 1000000000000000640
+
+ AmqpImport
+
+ success
+
+ http://midpoint.evolveum.com/xml/ns/public/gui/channels-3#user
+
+
+ up
+
+
+
+
+ c:connectorType
+ edu.unc.polygon.connector.amqp.AmqpConnector
+
+
+
+
+
+ id
+ sor
+ sor_person
+ payload
+ 5ecr3t
+ mq
+ sor_person
+ mysql
+ id
+
+
+
+
+ 2019-05-10T19:14:33.138Z
+ cccc5a900956c4dc-dda4212a83666460
+
+
+
+
+
+
+
+
+
+
+ icfs:uid
+ icfs:name
+ icfs:name
+ icfs:name
+ MESSAGE_OBJECT_CLASS___ACCOUNT__
+
+
+
+
+
+
+ 120
+ orgId
+
+
+
+
+
+
+ 130
+ active
+
+
+
+
+
+
+ 140
+ subject-id
+ subjectId
+
+
+
+
+
+
+ 150
+ phone
+
+
+
+
+
+
+ 160
+ sourceId
+
+
+
+
+
+
+ 170
+ firstname
+
+
+
+
+
+
+ 180
+ birthDate
+
+
+
+
+
+
+ 190
+ nameType
+
+
+
+
+
+
+ 200
+ email
+
+
+
+
+
+
+ 210
+ personalPronoun
+
+
+
+
+
+
+ 220
+ middleName
+
+
+
+
+
+
+ 230
+ lastname
+
+
+
+
+
+
+ 240
+ login-id
+ loginId
+
+
+
+
+
+
+ 250
+ priorSubject-id
+ priorSubjectId
+
+
+
+
+
+
+ ConnId Name
+ 110
+ __NAME__
+
+
+
+
+
+
+ 260
+ job
+
+
+
+
+
+
+ 270
+ fullname
+
+
+
+
+
+
+ 280
+ givenName
+
+
+
+
+
+
+ 290
+ familyName
+
+
+
+
+
+
+ ConnId UID
+ 100
+ read
+
+
+
+
+
+
+
+
+
+
+ account
+ default
+ true
+ ri:MESSAGE_OBJECT_CLASS___ACCOUNT__
+
+ icfs:name
+ Employee ID
+
+
+ $user/name
+
+
+
+
+ ri:givenName
+
+
+ $user/givenName
+
+
+
+
+ ri:fullname
+
+
+ true
+
+
+
+ $user/fullName
+
+
+
+
+ ri:familyName
+
+
+ $user/familyName
+
+
+
+
+ ri:orgId
+
+
+ $user/organizationalUnit
+
+
+
+
+ ri:job
+
+
+ $user/title
+
+
+
+
+ ri:phone
+
+
+ true
+
+
+
+ $user/telephoneNumber
+
+
+
+
+ ri:email
+
+
+ true
+
+
+
+ $user/emailAddress
+
+
+
+
+
+
+ weak
+
+
+
+
+
+
+ weak
+
+
+
+
+
+
+
+
+
+
+ 2019-05-10T19:14:33.136Z
+ b206157efe3db85b-2aa5ea9c80762fd5
+
+
+
+
+
+
+
+ connector
+
+
+
+
+ false
+
+
+
+
+ true
+
+
+ true
+
+
+ true
+
+
+ true
+
+ connector
+
+
+
+ true
+
+
+
+
+ full
+
+
+
+ true
+
+
+ polyStringNorm
+ c:name
+
+ Matches using Name
+ declare namespace ri="http://midpoint.evolveum.com/xml/ns/public/resource/instance-3"; $account/attributes/icfs:name
+
+
+
+
+ linked
+ true
+
+
+ deleted
+ true
+
+ http://midpoint.evolveum.com/xml/ns/public/model/action-3#deleteFocus
+
+
+
+ unlinked
+ true
+
+ http://midpoint.evolveum.com/xml/ns/public/model/action-3#link
+
+
+
+ unmatched
+ true
+
+ http://midpoint.evolveum.com/xml/ns/public/model/action-3#addFocus
+
+
+
+
+
+
diff --git a/connector-amqp-import/amqp4.xml b/connector-amqp-import/amqp4.xml
new file mode 100644
index 0000000..bbaed20
--- /dev/null
+++ b/connector-amqp-import/amqp4.xml
@@ -0,0 +1,508 @@
+
+ AmqpImport
+
+ 2019-05-10T19:14:32.966Z
+
+ http://midpoint.evolveum.com/xml/ns/public/gui/channels-3#user
+
+
+ 2017-09-21T14:11:32.117Z
+
+
+ modify
+ c:ResourceType
+
+
+ com.evolveum.midpoint.model.impl.lens.ChangeExecutor.executeDelta
+ success
+ 1000000000000000107
+
+ AmqpImport
+
+ success
+
+ http://midpoint.evolveum.com/xml/ns/public/gui/channels-3#user
+
+
+ 2017-09-21T14:11:51.716Z
+
+
+ modify
+ c:ResourceType
+
+
+ com.evolveum.midpoint.model.impl.lens.ChangeExecutor.executeDelta
+ success
+ 1000000000000000156
+
+ AmqpImport
+
+ success
+
+ http://midpoint.evolveum.com/xml/ns/public/gui/channels-3#user
+
+
+ 2017-09-21T14:11:54.743Z
+
+
+ modify
+ c:ResourceType
+
+
+ com.evolveum.midpoint.model.impl.lens.ChangeExecutor.executeDelta
+ success
+ 1000000000000000185
+
+ AmqpImport
+
+ success
+
+ http://midpoint.evolveum.com/xml/ns/public/gui/channels-3#user
+
+
+ 2017-09-21T14:11:57.924Z
+
+
+ modify
+ c:ResourceType
+
+
+ com.evolveum.midpoint.model.impl.lens.ChangeExecutor.executeDelta
+ success
+ 1000000000000000214
+
+ AmqpImport
+
+ success
+
+ http://midpoint.evolveum.com/xml/ns/public/gui/channels-3#user
+
+
+ 2019-05-10T19:14:33.060Z
+
+
+ modify
+ c:ResourceType
+
+
+ com.evolveum.midpoint.model.impl.lens.ChangeExecutor.executeDelta
+ success
+ 1000000000000000640
+
+ AmqpImport
+
+ success
+
+ http://midpoint.evolveum.com/xml/ns/public/gui/channels-3#user
+
+
+ up
+
+
+
+
+ c:connectorType
+ edu.unc.polygon.connector.amqp.AmqpConnector
+
+
+
+
+
+ id
+ sor
+ sor_person
+ payload
+ 5ecr3t
+ mq
+ sor_person
+ mysql
+ id
+
+
+
+
+ 2019-05-10T19:14:33.138Z
+ cccc5a900956c4dc-dda4212a83666460
+
+
+
+
+
+
+
+
+
+
+ icfs:uid
+ icfs:name
+ icfs:name
+ icfs:name
+ MESSAGE_OBJECT_CLASS___ACCOUNT__
+
+
+
+
+
+
+ 120
+ orgId
+
+
+
+
+
+
+ 130
+ active
+
+
+
+
+
+
+ 140
+ subject-id
+ subjectId
+
+
+
+
+
+
+ 150
+ phone
+
+
+
+
+
+
+ 160
+ sourceId
+
+
+
+
+
+
+ 170
+ firstname
+
+
+
+
+
+
+ 180
+ birthDate
+
+
+
+
+
+
+ 190
+ nameType
+
+
+
+
+
+
+ 200
+ email
+
+
+
+
+
+
+ 210
+ personalPronoun
+
+
+
+
+
+
+ 220
+ middleName
+
+
+
+
+
+
+ 230
+ lastname
+
+
+
+
+
+
+ 240
+ login-id
+ loginId
+
+
+
+
+
+
+ 250
+ priorSubject-id
+ priorSubjectId
+
+
+
+
+
+
+ ConnId Name
+ 110
+ __NAME__
+
+
+
+
+
+
+ 260
+ job
+
+
+
+
+
+
+ 270
+ fullname
+
+
+
+
+
+
+ 280
+ givenName
+
+
+
+
+
+
+ 290
+ familyName
+
+
+
+
+
+
+ ConnId UID
+ 100
+ read
+
+
+
+
+
+
+
+
+
+
+ account
+ default
+ true
+ ri:MESSAGE_OBJECT_CLASS___ACCOUNT__
+
+ icfs:name
+ Employee ID
+
+
+ $user/name
+
+
+
+
+ ri:givenName
+
+
+ $user/givenName
+
+
+
+
+ ri:fullname
+
+
+
+
+
+ $user/fullName
+
+
+
+
+ ri:familyName
+
+
+ $user/familyName
+
+
+
+
+ ri:orgId
+
+
+ $user/organizationalUnit
+
+
+
+
+ ri:job
+
+
+ $user/title
+
+
+
+
+ ri:phone
+
+
+ true
+
+
+
+ $user/telephoneNumber
+
+
+
+
+ ri:email
+
+
+
+
+
+ $user/emailAddress
+
+
+
+
+
+
+ weak
+
+
+
+
+
+
+ weak
+
+
+
+
+
+
+
+
+
+
+ 2019-05-10T19:14:33.136Z
+ b206157efe3db85b-2aa5ea9c80762fd5
+
+
+
+
+
+
+
+ connector
+
+
+
+
+ false
+
+
+
+
+ true
+
+
+ true
+
+
+ true
+
+
+ true
+
+ connector
+
+
+
+ true
+
+
+
+
+ full
+
+
+
+ true
+
+
+ polyStringNorm
+ c:name
+
+ Matches using Name
+ declare namespace ri="http://midpoint.evolveum.com/xml/ns/public/resource/instance-3"; $account/attributes/icfs:name
+
+
+
+
+ linked
+ true
+
+
+ deleted
+ true
+
+ http://midpoint.evolveum.com/xml/ns/public/model/action-3#deleteFocus
+
+
+
+ unlinked
+ true
+
+ http://midpoint.evolveum.com/xml/ns/public/model/action-3#link
+
+
+
+ unmatched
+ true
+
+ http://midpoint.evolveum.com/xml/ns/public/model/action-3#addFocus
+
+
+
+
+
+
diff --git a/connector-amqp-import/backup/amqp-import.xml b/connector-amqp-import/backup/amqp-import.xml
new file mode 100644
index 0000000..2aa285c
--- /dev/null
+++ b/connector-amqp-import/backup/amqp-import.xml
@@ -0,0 +1,405 @@
+
+ AmqpImport
+
+ 2017-09-21T14:11:57.837Z
+
+ http://midpoint.evolveum.com/xml/ns/public/gui/channels-3#user
+
+
+ 2017-09-21T14:11:32.117Z
+
+
+ modify
+ c:ResourceType
+
+
+ com.evolveum.midpoint.model.impl.lens.ChangeExecutor.executeDelta
+ success
+ 1000000000000000107
+
+ AmqpImport
+
+ success
+
+ http://midpoint.evolveum.com/xml/ns/public/gui/channels-3#user
+
+
+ 2017-09-21T14:11:51.716Z
+
+
+ modify
+ c:ResourceType
+
+
+ com.evolveum.midpoint.model.impl.lens.ChangeExecutor.executeDelta
+ success
+ 1000000000000000156
+
+ AmqpImport
+
+ success
+
+ http://midpoint.evolveum.com/xml/ns/public/gui/channels-3#user
+
+
+ 2017-09-21T14:11:54.743Z
+
+
+ modify
+ c:ResourceType
+
+
+ com.evolveum.midpoint.model.impl.lens.ChangeExecutor.executeDelta
+ success
+ 1000000000000000185
+
+ AmqpImport
+
+ success
+
+ http://midpoint.evolveum.com/xml/ns/public/gui/channels-3#user
+
+
+ 2017-09-21T14:11:57.924Z
+
+
+ modify
+ c:ResourceType
+
+
+ com.evolveum.midpoint.model.impl.lens.ChangeExecutor.executeDelta
+ success
+ 1000000000000000214
+
+ AmqpImport
+
+ success
+
+ http://midpoint.evolveum.com/xml/ns/public/gui/channels-3#user
+
+
+ up
+
+
+
+
+ id
+ midpoint
+ midpoint_hr
+ payload
+ Guest
+ locahost
+ midpoint_hr
+ Guest
+ id
+
+
+
+
+ 2017-09-21T14:11:32.347Z
+ b770289cd65cdc8b-15db7329434d7839
+
+
+
+
+
+
+
+
+
+
+ icfs:name
+ icfs:name
+ icfs:name
+ MESSAGE_OBJECT_CLASS___ACCOUNT__
+
+
+
+
+
+
+ 120
+ orgId
+
+
+
+
+
+
+ 130
+ active
+
+
+
+
+
+
+ 140
+ lastname
+
+
+
+
+
+
+ 150
+ phone
+
+
+
+
+
+
+ 160
+ firstname
+
+
+
+
+
+
+ id
+ 110
+ __NAME__
+
+
+
+
+
+
+ 180
+ job
+
+
+
+
+
+
+ 190
+ email
+
+
+
+
+
+
+ 200
+ fullname
+
+
+
+
+
+
+ ConnId UID
+ 100
+ read
+
+
+
+
+
+
+
+
+
+
+ account
+ default
+ true
+ ri:MESSAGE_OBJECT_CLASS___ACCOUNT__
+
+ icfs:name
+ Employee ID
+
+
+ $user/name
+
+
+
+
+ ri:fullname
+
+
+ $user/fullName
+
+
+
+
+ ri:firstname
+
+
+ $user/givenName
+
+
+
+
+ ri:lastname
+
+
+ $user/familyName
+
+
+
+
+ ri:orgId
+
+
+ $user/organizationalUnit
+
+
+
+
+ ri:job
+
+
+ $user/title
+
+
+
+
+ ri:phone
+
+
+ $user/telephoneNumber
+
+
+
+
+ ri:email
+
+
+ $user/emailAddress
+
+
+
+
+
+
+ weak
+
+
+
+
+
+
+ weak
+
+
+
+
+
+
+
+
+
+
+ 2017-09-21T14:11:32.345Z
+ a0989f9bf0bb5d59-12605cef28272abc
+
+
+
+
+
+
+
+
+ connector
+
+
+
+
+
+
+ true
+
+
+ true
+
+
+ true
+
+
+ true
+
+ connector
+
+
+
+ true
+
+
+
+
+ full
+
+
+
+ true
+
+
+ c:name
+
+ $account/attributes/id
+
+
+
+
+ linked
+ true
+
+
+ deleted
+ true
+
+ http://midpoint.evolveum.com/xml/ns/public/model/action-3#deleteFocus
+
+
+
+ unlinked
+ true
+
+ http://midpoint.evolveum.com/xml/ns/public/model/action-3#link
+
+
+
+ unmatched
+ true
+
+ http://midpoint.evolveum.com/xml/ns/public/model/action-3#addFocus
+
+
+
+
+
diff --git a/connector-amqp-import/connector-amqp-import.tar.2019-04-30 b/connector-amqp-import/connector-amqp-import.tar.2019-04-30
new file mode 100644
index 0000000..25ba0de
Binary files /dev/null and b/connector-amqp-import/connector-amqp-import.tar.2019-04-30 differ
diff --git a/connector-amqp-import/pom.xml b/connector-amqp-import/pom.xml
index 9f81779..53c170f 100644
--- a/connector-amqp-import/pom.xml
+++ b/connector-amqp-import/pom.xml
@@ -28,7 +28,7 @@
edu.unc.polygon
connector-amqp-import
- 0.3-SNAPSHOT
+ 0.4-SNAPSHOT
jar
AMQP Connector
diff --git a/connector-amqp-import/samples/amqp-import.xml b/connector-amqp-import/samples/amqp-import.xml
index 736125d..cccc816 100644
--- a/connector-amqp-import/samples/amqp-import.xml
+++ b/connector-amqp-import/samples/amqp-import.xml
@@ -273,11 +273,11 @@
-
+
270
- fullname
+ fullName
@@ -325,6 +325,30 @@
$user/name
+
+ strong
+
+
+ RoleType
+ c89f31dd-8d4f-4e0a-82cb-58ff9d8c1b2f
+
+ grouper-basic
+
+
+
+
+ assignment
+
+
+
+
+
+
+
ri:givenName
@@ -335,13 +359,8 @@
- ri:fullname
+ ri:fullName
-
-
-
$user/fullName
diff --git a/connector-amqp-import/src/main/java/edu/unc/polygon/connector/amqp/AmqpConnector.java b/connector-amqp-import/src/main/java/edu/unc/polygon/connector/amqp/AmqpConnector.java
index 6a8931c..5d53ddf 100644
--- a/connector-amqp-import/src/main/java/edu/unc/polygon/connector/amqp/AmqpConnector.java
+++ b/connector-amqp-import/src/main/java/edu/unc/polygon/connector/amqp/AmqpConnector.java
@@ -193,14 +193,14 @@ public Schema schema() {
familyName.setRequired(false);
familyName.setMultiValued(false);
attributes.add(familyName.build());
- AttributeInfoBuilder fullname = new AttributeInfoBuilder();
- fullname.setName("fullname");
- fullname.setCreateable(true);
- fullname.setUpdateable(true);
- fullname.setReadable(true);
- fullname.setRequired(false);
- fullname.setMultiValued(false);
- attributes.add(fullname.build());
+ AttributeInfoBuilder fullName = new AttributeInfoBuilder();
+ fullName.setName("fullName");
+ fullName.setCreateable(true);
+ fullName.setUpdateable(true);
+ fullName.setReadable(true);
+ fullName.setRequired(false);
+ fullName.setMultiValued(false);
+ attributes.add(fullName.build());
AttributeInfoBuilder firstname = new AttributeInfoBuilder();
firstname.setName("firstname");
firstname.setCreateable(true);
@@ -360,6 +360,13 @@ public void executeQuery(ObjectClass oc, AmqpFilter filter, ResultsHandler handl
LOG.info(familyName);
builder.addAttribute("familyName", familyName);
}
+ if ( name.containsKey("familyName") && name.containsKey("givenName") ) {
+ String familyName = (String) name.get("familyName");
+ String givenName = (String) name.get("givenName");
+ String fullName = givenName + ' ' + familyName;
+ LOG.info(fullName);
+ builder.addAttribute("fullName", fullName);
+ }
if ( name.containsKey("nameType") ) {
String nameType = (String) name.get("nameType");
LOG.info(nameType);
diff --git a/connector-amqp-import/src/main/java/edu/unc/polygon/connector/amqp/AmqpFilterTranslator.java.2019-04-18 b/connector-amqp-import/src/main/java/edu/unc/polygon/connector/amqp/AmqpFilterTranslator.java.2019-04-18
new file mode 100644
index 0000000..d5024a9
--- /dev/null
+++ b/connector-amqp-import/src/main/java/edu/unc/polygon/connector/amqp/AmqpFilterTranslator.java.2019-04-18
@@ -0,0 +1,33 @@
+package edu.unc.polygon.connector.amqp;
+
+import org.identityconnectors.framework.common.objects.Attribute;
+import org.identityconnectors.framework.common.objects.Uid;
+import org.identityconnectors.framework.common.objects.filter.AbstractFilterTranslator;
+import org.identityconnectors.framework.common.objects.filter.EqualsFilter;
+
+import java.util.List;
+
+public class AmqpFilterTranslator extends AbstractFilterTranslator {
+
+ @Override
+ protected String createEqualsExpression(EqualsFilter filter, boolean not) {
+ if (not) {
+ return null;
+ }
+
+ Attribute attr = filter.getAttribute();
+ if (!attr.is(Uid.NAME)) {
+ return null;
+ }
+
+ List