Skip to content

Commit b8d2220

Browse files
committed
Fixes a bug with the schema version
1 parent 8516305 commit b8d2220

1 file changed

Lines changed: 6 additions & 3 deletions

File tree

  • src/main/java/com/snowplowanalytics/snowplow/tracker

src/main/java/com/snowplowanalytics/snowplow/tracker/Tracker.java

Lines changed: 6 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -32,6 +32,7 @@ public class Tracker {
3232
private String contextSchema;
3333
private String baseSchemaPath;
3434
private String schemaTag;
35+
private String schemaVersion;
3536
private String unstructSchema;
3637
private Subject subject;
3738

@@ -124,10 +125,11 @@ private void setSubject(Subject subject) {
124125
* @param version Schema version tag
125126
*/
126127
public void setSchema(String vendor, String schemaTag, String version) {
127-
this.contextSchema = vendor + "/contexts/" + schemaTag + version;
128-
this.unstructSchema = vendor + "/unstruct_event/" + schemaTag + version;
128+
this.contextSchema = vendor + "/contexts/" + schemaTag + "/" + version;
129+
this.unstructSchema = vendor + "/unstruct_event/" + schemaTag + "/" + version;
129130
this.baseSchemaPath = vendor;
130131
this.schemaTag = schemaTag;
132+
this.schemaVersion = version;
131133
}
132134

133135
/**
@@ -517,7 +519,8 @@ public void trackScreenView(String name, String id, List<Map> context, long time
517519

518520
SchemaPayload payload = new SchemaPayload();
519521

520-
payload.setSchema( this.baseSchemaPath + "/contexts/" + this.schemaTag + Version.VERSION);
522+
payload.setSchema( this.baseSchemaPath + "/contexts/" +
523+
this.schemaTag + "/" + this.schemaVersion);
521524
payload.setData(screenViewProperties);
522525

523526
trackUnstructuredEvent(payload.getMap(), context, timestamp);

0 commit comments

Comments
 (0)