diff --git a/client/client-multi/client-java-core/src/main/java/org/kaaproject/kaa/client/channel/impl/transports/DefaultProfileTransport.java b/client/client-multi/client-java-core/src/main/java/org/kaaproject/kaa/client/channel/impl/transports/DefaultProfileTransport.java index 18b2b4fef1..bc1c048a90 100644 --- a/client/client-multi/client-java-core/src/main/java/org/kaaproject/kaa/client/channel/impl/transports/DefaultProfileTransport.java +++ b/client/client-multi/client-java-core/src/main/java/org/kaaproject/kaa/client/channel/impl/transports/DefaultProfileTransport.java @@ -61,7 +61,7 @@ public ProfileSyncRequest createProfileRequest() throws IOException { request.setEndpointPublicKey(ByteBuffer.wrap(clientState.getPublicKey().getEncoded())); } request.setProfileBody(ByteBuffer.wrap(serializedProfile)); - request.setVersionInfo(properties.getVersionInfo()); + request.setSdkToken(properties.getSdkToken()); return request; } else { LOG.info("Profile is up to date"); diff --git a/common/endpoint-shared/src/main/avro/endpoint.avsc b/common/endpoint-shared/src/main/avro/endpoint.avsc index b0660d5594..86332d5c4b 100644 --- a/common/endpoint-shared/src/main/avro/endpoint.avsc +++ b/common/endpoint-shared/src/main/avro/endpoint.avsc @@ -270,7 +270,7 @@ "fields": [ {"name": "endpointPublicKey", "type": ["bytes", "null"]}, {"name": "profileBody", "type": "bytes"}, - {"name": "versionInfo", "type": "org.kaaproject.kaa.common.endpoint.gen.EndpointVersionInfo"}, + {"name": "sdkToken", "type": "string"}, {"name": "endpointAccessToken", "type": ["string", "null"]} ] }, diff --git a/common/endpoint-shared/src/main/java/org/kaaproject/kaa/common/endpoint/gen/ProfileSyncRequest.java b/common/endpoint-shared/src/main/java/org/kaaproject/kaa/common/endpoint/gen/ProfileSyncRequest.java index 901d731741..e601db10e1 100644 --- a/common/endpoint-shared/src/main/java/org/kaaproject/kaa/common/endpoint/gen/ProfileSyncRequest.java +++ b/common/endpoint-shared/src/main/java/org/kaaproject/kaa/common/endpoint/gen/ProfileSyncRequest.java @@ -7,11 +7,11 @@ @SuppressWarnings("all") @org.apache.avro.specific.AvroGenerated public class ProfileSyncRequest extends org.apache.avro.specific.SpecificRecordBase implements org.apache.avro.specific.SpecificRecord { - public static final org.apache.avro.Schema SCHEMA$ = new org.apache.avro.Schema.Parser().parse("{\"type\":\"record\",\"name\":\"ProfileSyncRequest\",\"namespace\":\"org.kaaproject.kaa.common.endpoint.gen\",\"fields\":[{\"name\":\"endpointPublicKey\",\"type\":[\"bytes\",\"null\"]},{\"name\":\"profileBody\",\"type\":\"bytes\"},{\"name\":\"versionInfo\",\"type\":{\"type\":\"record\",\"name\":\"EndpointVersionInfo\",\"fields\":[{\"name\":\"configVersion\",\"type\":\"int\"},{\"name\":\"profileVersion\",\"type\":\"int\",\"default\":1},{\"name\":\"systemNfVersion\",\"type\":\"int\",\"default\":0},{\"name\":\"userNfVersion\",\"type\":\"int\",\"default\":0},{\"name\":\"eventFamilyVersions\",\"type\":[{\"type\":\"array\",\"items\":{\"type\":\"record\",\"name\":\"EventClassFamilyVersionInfo\",\"fields\":[{\"name\":\"name\",\"type\":{\"type\":\"string\",\"avro.java.string\":\"String\"}},{\"name\":\"version\",\"type\":\"int\"}],\"direction\":\"out\"}},\"null\"]},{\"name\":\"logSchemaVersion\",\"type\":\"int\",\"default\":0}],\"direction\":\"out\"}},{\"name\":\"endpointAccessToken\",\"type\":[{\"type\":\"string\",\"avro.java.string\":\"String\"},\"null\"]}],\"direction\":\"out\"}"); + public static final org.apache.avro.Schema SCHEMA$ = new org.apache.avro.Schema.Parser().parse("{\"type\":\"record\",\"name\":\"ProfileSyncRequest\",\"namespace\":\"org.kaaproject.kaa.common.endpoint.gen\",\"fields\":[{\"name\":\"endpointPublicKey\",\"type\":[\"bytes\",\"null\"]},{\"name\":\"profileBody\",\"type\":\"bytes\"},{\"name\":\"sdkToken\",\"type\":{\"type\":\"string\",\"avro.java.string\":\"String\"}},{\"name\":\"endpointAccessToken\",\"type\":[{\"type\":\"string\",\"avro.java.string\":\"String\"},\"null\"]}],\"direction\":\"out\"}"); public static org.apache.avro.Schema getClassSchema() { return SCHEMA$; } private java.nio.ByteBuffer endpointPublicKey; private java.nio.ByteBuffer profileBody; - private org.kaaproject.kaa.common.endpoint.gen.EndpointVersionInfo versionInfo; + private java.lang.String sdkToken; private java.lang.String endpointAccessToken; /** @@ -24,10 +24,10 @@ public ProfileSyncRequest() {} /** * All-args constructor. */ - public ProfileSyncRequest(java.nio.ByteBuffer endpointPublicKey, java.nio.ByteBuffer profileBody, org.kaaproject.kaa.common.endpoint.gen.EndpointVersionInfo versionInfo, java.lang.String endpointAccessToken) { + public ProfileSyncRequest(java.nio.ByteBuffer endpointPublicKey, java.nio.ByteBuffer profileBody, java.lang.String sdkToken, java.lang.String endpointAccessToken) { this.endpointPublicKey = endpointPublicKey; this.profileBody = profileBody; - this.versionInfo = versionInfo; + this.sdkToken = sdkToken; this.endpointAccessToken = endpointAccessToken; } @@ -37,7 +37,7 @@ public java.lang.Object get(int field$) { switch (field$) { case 0: return endpointPublicKey; case 1: return profileBody; - case 2: return versionInfo; + case 2: return sdkToken; case 3: return endpointAccessToken; default: throw new org.apache.avro.AvroRuntimeException("Bad index"); } @@ -48,7 +48,7 @@ public void put(int field$, java.lang.Object value$) { switch (field$) { case 0: endpointPublicKey = (java.nio.ByteBuffer)value$; break; case 1: profileBody = (java.nio.ByteBuffer)value$; break; - case 2: versionInfo = (org.kaaproject.kaa.common.endpoint.gen.EndpointVersionInfo)value$; break; + case 2: sdkToken = (java.lang.String)value$; break; case 3: endpointAccessToken = (java.lang.String)value$; break; default: throw new org.apache.avro.AvroRuntimeException("Bad index"); } @@ -85,18 +85,18 @@ public void setProfileBody(java.nio.ByteBuffer value) { } /** - * Gets the value of the 'versionInfo' field. + * Gets the value of the 'sdkToken' field. */ - public org.kaaproject.kaa.common.endpoint.gen.EndpointVersionInfo getVersionInfo() { - return versionInfo; + public java.lang.String getSdkToken() { + return sdkToken; } /** - * Sets the value of the 'versionInfo' field. + * Sets the value of the 'sdkToken' field. * @param value the value to set. */ - public void setVersionInfo(org.kaaproject.kaa.common.endpoint.gen.EndpointVersionInfo value) { - this.versionInfo = value; + public void setSdkToken(java.lang.String value) { + this.sdkToken = value; } /** @@ -137,7 +137,7 @@ public static class Builder extends org.apache.avro.specific.SpecificRecordBuild private java.nio.ByteBuffer endpointPublicKey; private java.nio.ByteBuffer profileBody; - private org.kaaproject.kaa.common.endpoint.gen.EndpointVersionInfo versionInfo; + private java.lang.String sdkToken; private java.lang.String endpointAccessToken; /** Creates a new Builder */ @@ -156,8 +156,8 @@ private Builder(org.kaaproject.kaa.common.endpoint.gen.ProfileSyncRequest.Builde this.profileBody = data().deepCopy(fields()[1].schema(), other.profileBody); fieldSetFlags()[1] = true; } - if (isValidValue(fields()[2], other.versionInfo)) { - this.versionInfo = data().deepCopy(fields()[2].schema(), other.versionInfo); + if (isValidValue(fields()[2], other.sdkToken)) { + this.sdkToken = data().deepCopy(fields()[2].schema(), other.sdkToken); fieldSetFlags()[2] = true; } if (isValidValue(fields()[3], other.endpointAccessToken)) { @@ -177,8 +177,8 @@ private Builder(org.kaaproject.kaa.common.endpoint.gen.ProfileSyncRequest other) this.profileBody = data().deepCopy(fields()[1].schema(), other.profileBody); fieldSetFlags()[1] = true; } - if (isValidValue(fields()[2], other.versionInfo)) { - this.versionInfo = data().deepCopy(fields()[2].schema(), other.versionInfo); + if (isValidValue(fields()[2], other.sdkToken)) { + this.sdkToken = data().deepCopy(fields()[2].schema(), other.sdkToken); fieldSetFlags()[2] = true; } if (isValidValue(fields()[3], other.endpointAccessToken)) { @@ -237,27 +237,27 @@ public org.kaaproject.kaa.common.endpoint.gen.ProfileSyncRequest.Builder clearPr return this; } - /** Gets the value of the 'versionInfo' field */ - public org.kaaproject.kaa.common.endpoint.gen.EndpointVersionInfo getVersionInfo() { - return versionInfo; + /** Gets the value of the 'sdkToken' field */ + public java.lang.String getSdkToken() { + return sdkToken; } - /** Sets the value of the 'versionInfo' field */ - public org.kaaproject.kaa.common.endpoint.gen.ProfileSyncRequest.Builder setVersionInfo(org.kaaproject.kaa.common.endpoint.gen.EndpointVersionInfo value) { + /** Sets the value of the 'sdkToken' field */ + public org.kaaproject.kaa.common.endpoint.gen.ProfileSyncRequest.Builder setSdkToken(java.lang.String value) { validate(fields()[2], value); - this.versionInfo = value; + this.sdkToken = value; fieldSetFlags()[2] = true; return this; } - /** Checks whether the 'versionInfo' field has been set */ - public boolean hasVersionInfo() { + /** Checks whether the 'sdkToken' field has been set */ + public boolean hasSdkToken() { return fieldSetFlags()[2]; } - /** Clears the value of the 'versionInfo' field */ - public org.kaaproject.kaa.common.endpoint.gen.ProfileSyncRequest.Builder clearVersionInfo() { - versionInfo = null; + /** Clears the value of the 'sdkToken' field */ + public org.kaaproject.kaa.common.endpoint.gen.ProfileSyncRequest.Builder clearSdkToken() { + sdkToken = null; fieldSetFlags()[2] = false; return this; } @@ -293,7 +293,7 @@ public ProfileSyncRequest build() { ProfileSyncRequest record = new ProfileSyncRequest(); record.endpointPublicKey = fieldSetFlags()[0] ? this.endpointPublicKey : (java.nio.ByteBuffer) defaultValue(fields()[0]); record.profileBody = fieldSetFlags()[1] ? this.profileBody : (java.nio.ByteBuffer) defaultValue(fields()[1]); - record.versionInfo = fieldSetFlags()[2] ? this.versionInfo : (org.kaaproject.kaa.common.endpoint.gen.EndpointVersionInfo) defaultValue(fields()[2]); + record.sdkToken = fieldSetFlags()[2] ? this.sdkToken : (java.lang.String) defaultValue(fields()[2]); record.endpointAccessToken = fieldSetFlags()[3] ? this.endpointAccessToken : (java.lang.String) defaultValue(fields()[3]); return record; } catch (Exception e) { diff --git a/common/endpoint-shared/src/main/java/org/kaaproject/kaa/common/endpoint/gen/SyncRequest.java b/common/endpoint-shared/src/main/java/org/kaaproject/kaa/common/endpoint/gen/SyncRequest.java index 8f63bab86a..c839aa387f 100644 --- a/common/endpoint-shared/src/main/java/org/kaaproject/kaa/common/endpoint/gen/SyncRequest.java +++ b/common/endpoint-shared/src/main/java/org/kaaproject/kaa/common/endpoint/gen/SyncRequest.java @@ -7,7 +7,7 @@ @SuppressWarnings("all") @org.apache.avro.specific.AvroGenerated public class SyncRequest extends org.apache.avro.specific.SpecificRecordBase implements org.apache.avro.specific.SpecificRecord { - public static final org.apache.avro.Schema SCHEMA$ = new org.apache.avro.Schema.Parser().parse("{\"type\":\"record\",\"name\":\"SyncRequest\",\"namespace\":\"org.kaaproject.kaa.common.endpoint.gen\",\"fields\":[{\"name\":\"requestId\",\"type\":\"int\"},{\"name\":\"syncRequestMetaData\",\"type\":[{\"type\":\"record\",\"name\":\"SyncRequestMetaData\",\"fields\":[{\"name\":\"sdkToken\",\"type\":{\"type\":\"string\",\"avro.java.string\":\"String\"}},{\"name\":\"endpointPublicKeyHash\",\"type\":[\"bytes\",\"null\"]},{\"name\":\"profileHash\",\"type\":[\"bytes\",\"null\"]},{\"name\":\"timeout\",\"type\":[\"long\",\"null\"]}],\"direction\":\"out\"},\"null\"]},{\"name\":\"bootstrapSyncRequest\",\"type\":[{\"type\":\"record\",\"name\":\"BootstrapSyncRequest\",\"fields\":[{\"name\":\"requestId\",\"type\":\"int\"},{\"name\":\"supportedProtocols\",\"type\":{\"type\":\"array\",\"items\":{\"type\":\"record\",\"name\":\"ProtocolVersionPair\",\"fields\":[{\"name\":\"id\",\"type\":\"int\"},{\"name\":\"version\",\"type\":\"int\"}]}}}],\"direction\":\"out\"},\"null\"]},{\"name\":\"profileSyncRequest\",\"type\":[{\"type\":\"record\",\"name\":\"ProfileSyncRequest\",\"fields\":[{\"name\":\"endpointPublicKey\",\"type\":[\"bytes\",\"null\"]},{\"name\":\"profileBody\",\"type\":\"bytes\"},{\"name\":\"versionInfo\",\"type\":{\"type\":\"record\",\"name\":\"EndpointVersionInfo\",\"fields\":[{\"name\":\"configVersion\",\"type\":\"int\"},{\"name\":\"profileVersion\",\"type\":\"int\",\"default\":1},{\"name\":\"systemNfVersion\",\"type\":\"int\",\"default\":0},{\"name\":\"userNfVersion\",\"type\":\"int\",\"default\":0},{\"name\":\"eventFamilyVersions\",\"type\":[{\"type\":\"array\",\"items\":{\"type\":\"record\",\"name\":\"EventClassFamilyVersionInfo\",\"fields\":[{\"name\":\"name\",\"type\":{\"type\":\"string\",\"avro.java.string\":\"String\"}},{\"name\":\"version\",\"type\":\"int\"}],\"direction\":\"out\"}},\"null\"]},{\"name\":\"logSchemaVersion\",\"type\":\"int\",\"default\":0}],\"direction\":\"out\"}},{\"name\":\"endpointAccessToken\",\"type\":[{\"type\":\"string\",\"avro.java.string\":\"String\"},\"null\"]}],\"direction\":\"out\"},\"null\"]},{\"name\":\"configurationSyncRequest\",\"type\":[{\"type\":\"record\",\"name\":\"ConfigurationSyncRequest\",\"fields\":[{\"name\":\"appStateSeqNumber\",\"type\":\"int\"},{\"name\":\"configurationHash\",\"type\":[\"bytes\",\"null\"]},{\"name\":\"resyncOnly\",\"type\":[\"boolean\",\"null\"]}],\"direction\":\"out\"},\"null\"]},{\"name\":\"notificationSyncRequest\",\"type\":[{\"type\":\"record\",\"name\":\"NotificationSyncRequest\",\"fields\":[{\"name\":\"appStateSeqNumber\",\"type\":\"int\"},{\"name\":\"topicListHash\",\"type\":[\"bytes\",\"null\"]},{\"name\":\"topicStates\",\"type\":[{\"type\":\"array\",\"items\":{\"type\":\"record\",\"name\":\"TopicState\",\"fields\":[{\"name\":\"topicId\",\"type\":{\"type\":\"string\",\"avro.java.string\":\"String\"}},{\"name\":\"seqNumber\",\"type\":\"int\"}],\"direction\":\"out\"}},\"null\"]},{\"name\":\"acceptedUnicastNotifications\",\"type\":[{\"type\":\"array\",\"items\":{\"type\":\"string\",\"avro.java.string\":\"String\"}},\"null\"]},{\"name\":\"subscriptionCommands\",\"type\":[{\"type\":\"array\",\"items\":{\"type\":\"record\",\"name\":\"SubscriptionCommand\",\"fields\":[{\"name\":\"topicId\",\"type\":{\"type\":\"string\",\"avro.java.string\":\"String\"}},{\"name\":\"command\",\"type\":{\"type\":\"enum\",\"name\":\"SubscriptionCommandType\",\"symbols\":[\"ADD\",\"REMOVE\"]}}],\"direction\":\"out\"}},\"null\"]}],\"direction\":\"out\"},\"null\"]},{\"name\":\"userSyncRequest\",\"type\":[{\"type\":\"record\",\"name\":\"UserSyncRequest\",\"fields\":[{\"name\":\"userAttachRequest\",\"type\":[{\"type\":\"record\",\"name\":\"UserAttachRequest\",\"fields\":[{\"name\":\"userVerifierId\",\"type\":{\"type\":\"string\",\"avro.java.string\":\"String\"}},{\"name\":\"userExternalId\",\"type\":{\"type\":\"string\",\"avro.java.string\":\"String\"}},{\"name\":\"userAccessToken\",\"type\":{\"type\":\"string\",\"avro.java.string\":\"String\"}}],\"direction\":\"out\"},\"null\"]},{\"name\":\"endpointAttachRequests\",\"type\":[{\"type\":\"array\",\"items\":{\"type\":\"record\",\"name\":\"EndpointAttachRequest\",\"fields\":[{\"name\":\"requestId\",\"type\":\"int\"},{\"name\":\"endpointAccessToken\",\"type\":{\"type\":\"string\",\"avro.java.string\":\"String\"}}],\"direction\":\"out\"}},\"null\"]},{\"name\":\"endpointDetachRequests\",\"type\":[{\"type\":\"array\",\"items\":{\"type\":\"record\",\"name\":\"EndpointDetachRequest\",\"fields\":[{\"name\":\"requestId\",\"type\":\"int\"},{\"name\":\"endpointKeyHash\",\"type\":{\"type\":\"string\",\"avro.java.string\":\"String\"}}],\"direction\":\"out\"}},\"null\"]}],\"direction\":\"out\"},\"null\"]},{\"name\":\"eventSyncRequest\",\"type\":[{\"type\":\"record\",\"name\":\"EventSyncRequest\",\"fields\":[{\"name\":\"eventSequenceNumberRequest\",\"type\":[{\"type\":\"record\",\"name\":\"EventSequenceNumberRequest\",\"fields\":[],\"direction\":\"out\"},\"null\"]},{\"name\":\"eventListenersRequests\",\"type\":[{\"type\":\"array\",\"items\":{\"type\":\"record\",\"name\":\"EventListenersRequest\",\"fields\":[{\"name\":\"requestId\",\"type\":\"int\"},{\"name\":\"eventClassFQNs\",\"type\":{\"type\":\"array\",\"items\":{\"type\":\"string\",\"avro.java.string\":\"String\"}}}],\"direction\":\"out\"}},\"null\"]},{\"name\":\"events\",\"type\":[{\"type\":\"array\",\"items\":{\"type\":\"record\",\"name\":\"Event\",\"fields\":[{\"name\":\"seqNum\",\"type\":\"int\"},{\"name\":\"eventClassFQN\",\"type\":{\"type\":\"string\",\"avro.java.string\":\"String\"}},{\"name\":\"eventData\",\"type\":\"bytes\"},{\"name\":\"source\",\"type\":[{\"type\":\"string\",\"avro.java.string\":\"String\"},\"null\"]},{\"name\":\"target\",\"type\":[{\"type\":\"string\",\"avro.java.string\":\"String\"},\"null\"]}]}},\"null\"]}],\"direction\":\"out\"},\"null\"]},{\"name\":\"logSyncRequest\",\"type\":[{\"type\":\"record\",\"name\":\"LogSyncRequest\",\"fields\":[{\"name\":\"requestId\",\"type\":\"int\"},{\"name\":\"logEntries\",\"type\":[{\"type\":\"array\",\"items\":{\"type\":\"record\",\"name\":\"LogEntry\",\"fields\":[{\"name\":\"data\",\"type\":\"bytes\"}],\"direction\":\"out\"}},\"null\"]}],\"direction\":\"out\"},\"null\"]}],\"direction\":\"out\"}"); + public static final org.apache.avro.Schema SCHEMA$ = new org.apache.avro.Schema.Parser().parse("{\"type\":\"record\",\"name\":\"SyncRequest\",\"namespace\":\"org.kaaproject.kaa.common.endpoint.gen\",\"fields\":[{\"name\":\"requestId\",\"type\":\"int\"},{\"name\":\"syncRequestMetaData\",\"type\":[{\"type\":\"record\",\"name\":\"SyncRequestMetaData\",\"fields\":[{\"name\":\"sdkToken\",\"type\":{\"type\":\"string\",\"avro.java.string\":\"String\"}},{\"name\":\"endpointPublicKeyHash\",\"type\":[\"bytes\",\"null\"]},{\"name\":\"profileHash\",\"type\":[\"bytes\",\"null\"]},{\"name\":\"timeout\",\"type\":[\"long\",\"null\"]}],\"direction\":\"out\"},\"null\"]},{\"name\":\"bootstrapSyncRequest\",\"type\":[{\"type\":\"record\",\"name\":\"BootstrapSyncRequest\",\"fields\":[{\"name\":\"requestId\",\"type\":\"int\"},{\"name\":\"supportedProtocols\",\"type\":{\"type\":\"array\",\"items\":{\"type\":\"record\",\"name\":\"ProtocolVersionPair\",\"fields\":[{\"name\":\"id\",\"type\":\"int\"},{\"name\":\"version\",\"type\":\"int\"}]}}}],\"direction\":\"out\"},\"null\"]},{\"name\":\"profileSyncRequest\",\"type\":[{\"type\":\"record\",\"name\":\"ProfileSyncRequest\",\"fields\":[{\"name\":\"endpointPublicKey\",\"type\":[\"bytes\",\"null\"]},{\"name\":\"profileBody\",\"type\":\"bytes\"},{\"name\":\"sdkToken\",\"type\":{\"type\":\"string\",\"avro.java.string\":\"String\"}},{\"name\":\"endpointAccessToken\",\"type\":[{\"type\":\"string\",\"avro.java.string\":\"String\"},\"null\"]}],\"direction\":\"out\"},\"null\"]},{\"name\":\"configurationSyncRequest\",\"type\":[{\"type\":\"record\",\"name\":\"ConfigurationSyncRequest\",\"fields\":[{\"name\":\"appStateSeqNumber\",\"type\":\"int\"},{\"name\":\"configurationHash\",\"type\":[\"bytes\",\"null\"]},{\"name\":\"resyncOnly\",\"type\":[\"boolean\",\"null\"]}],\"direction\":\"out\"},\"null\"]},{\"name\":\"notificationSyncRequest\",\"type\":[{\"type\":\"record\",\"name\":\"NotificationSyncRequest\",\"fields\":[{\"name\":\"appStateSeqNumber\",\"type\":\"int\"},{\"name\":\"topicListHash\",\"type\":[\"bytes\",\"null\"]},{\"name\":\"topicStates\",\"type\":[{\"type\":\"array\",\"items\":{\"type\":\"record\",\"name\":\"TopicState\",\"fields\":[{\"name\":\"topicId\",\"type\":{\"type\":\"string\",\"avro.java.string\":\"String\"}},{\"name\":\"seqNumber\",\"type\":\"int\"}],\"direction\":\"out\"}},\"null\"]},{\"name\":\"acceptedUnicastNotifications\",\"type\":[{\"type\":\"array\",\"items\":{\"type\":\"string\",\"avro.java.string\":\"String\"}},\"null\"]},{\"name\":\"subscriptionCommands\",\"type\":[{\"type\":\"array\",\"items\":{\"type\":\"record\",\"name\":\"SubscriptionCommand\",\"fields\":[{\"name\":\"topicId\",\"type\":{\"type\":\"string\",\"avro.java.string\":\"String\"}},{\"name\":\"command\",\"type\":{\"type\":\"enum\",\"name\":\"SubscriptionCommandType\",\"symbols\":[\"ADD\",\"REMOVE\"]}}],\"direction\":\"out\"}},\"null\"]}],\"direction\":\"out\"},\"null\"]},{\"name\":\"userSyncRequest\",\"type\":[{\"type\":\"record\",\"name\":\"UserSyncRequest\",\"fields\":[{\"name\":\"userAttachRequest\",\"type\":[{\"type\":\"record\",\"name\":\"UserAttachRequest\",\"fields\":[{\"name\":\"userVerifierId\",\"type\":{\"type\":\"string\",\"avro.java.string\":\"String\"}},{\"name\":\"userExternalId\",\"type\":{\"type\":\"string\",\"avro.java.string\":\"String\"}},{\"name\":\"userAccessToken\",\"type\":{\"type\":\"string\",\"avro.java.string\":\"String\"}}],\"direction\":\"out\"},\"null\"]},{\"name\":\"endpointAttachRequests\",\"type\":[{\"type\":\"array\",\"items\":{\"type\":\"record\",\"name\":\"EndpointAttachRequest\",\"fields\":[{\"name\":\"requestId\",\"type\":\"int\"},{\"name\":\"endpointAccessToken\",\"type\":{\"type\":\"string\",\"avro.java.string\":\"String\"}}],\"direction\":\"out\"}},\"null\"]},{\"name\":\"endpointDetachRequests\",\"type\":[{\"type\":\"array\",\"items\":{\"type\":\"record\",\"name\":\"EndpointDetachRequest\",\"fields\":[{\"name\":\"requestId\",\"type\":\"int\"},{\"name\":\"endpointKeyHash\",\"type\":{\"type\":\"string\",\"avro.java.string\":\"String\"}}],\"direction\":\"out\"}},\"null\"]}],\"direction\":\"out\"},\"null\"]},{\"name\":\"eventSyncRequest\",\"type\":[{\"type\":\"record\",\"name\":\"EventSyncRequest\",\"fields\":[{\"name\":\"eventSequenceNumberRequest\",\"type\":[{\"type\":\"record\",\"name\":\"EventSequenceNumberRequest\",\"fields\":[],\"direction\":\"out\"},\"null\"]},{\"name\":\"eventListenersRequests\",\"type\":[{\"type\":\"array\",\"items\":{\"type\":\"record\",\"name\":\"EventListenersRequest\",\"fields\":[{\"name\":\"requestId\",\"type\":\"int\"},{\"name\":\"eventClassFQNs\",\"type\":{\"type\":\"array\",\"items\":{\"type\":\"string\",\"avro.java.string\":\"String\"}}}],\"direction\":\"out\"}},\"null\"]},{\"name\":\"events\",\"type\":[{\"type\":\"array\",\"items\":{\"type\":\"record\",\"name\":\"Event\",\"fields\":[{\"name\":\"seqNum\",\"type\":\"int\"},{\"name\":\"eventClassFQN\",\"type\":{\"type\":\"string\",\"avro.java.string\":\"String\"}},{\"name\":\"eventData\",\"type\":\"bytes\"},{\"name\":\"source\",\"type\":[{\"type\":\"string\",\"avro.java.string\":\"String\"},\"null\"]},{\"name\":\"target\",\"type\":[{\"type\":\"string\",\"avro.java.string\":\"String\"},\"null\"]}]}},\"null\"]}],\"direction\":\"out\"},\"null\"]},{\"name\":\"logSyncRequest\",\"type\":[{\"type\":\"record\",\"name\":\"LogSyncRequest\",\"fields\":[{\"name\":\"requestId\",\"type\":\"int\"},{\"name\":\"logEntries\",\"type\":[{\"type\":\"array\",\"items\":{\"type\":\"record\",\"name\":\"LogEntry\",\"fields\":[{\"name\":\"data\",\"type\":\"bytes\"}],\"direction\":\"out\"}},\"null\"]}],\"direction\":\"out\"},\"null\"]}],\"direction\":\"out\"}"); public static org.apache.avro.Schema getClassSchema() { return SCHEMA$; } private int requestId; private org.kaaproject.kaa.common.endpoint.gen.SyncRequestMetaData syncRequestMetaData;