diff --git a/pkg/flow/encoding.go b/pkg/flow/encoding.go
index 8fc83ea0f..1c2f95ae4 100644
--- a/pkg/flow/encoding.go
+++ b/pkg/flow/encoding.go
@@ -329,6 +329,9 @@ func decode(msg *amqp.Message) []interface{} {
 					if v, ok := m["Direction"].(string); ok {
 						link.Direction = &v
 					}
+					if v, ok := m["Location"].(string); ok {
+						link.Location = &v
+					}
 
 					result = append(result, link)
 				case Listener:
diff --git a/pkg/flow/record.go b/pkg/flow/record.go
index 4ccf883ab..3c43ca0d8 100644
--- a/pkg/flow/record.go
+++ b/pkg/flow/record.go
@@ -276,6 +276,7 @@ type LinkRecord struct {
 	Name      *string `json:"name,omitempty"`
 	LinkCost  *uint64 `json:"linkCost,omitempty"`
 	Direction *string `json:"direction,omitempty"`
+	Location  *string `json:"location,omitempty"`
 }
 
 type linkRecordResponse struct {