diff --git a/events/activemq.go b/events/activemq.go index 3e9ffb87..fec67c44 100644 --- a/events/activemq.go +++ b/events/activemq.go @@ -23,6 +23,7 @@ type ActiveMQMessage struct { Data string `json:"data"` BrokerInTime int64 `json:"brokerInTime"` BrokerOutTime int64 `json:"brokerOutTime"` + Properties map[string]string `json:"properties"` } type ActiveMQDestination struct { diff --git a/events/activemq_test.go b/events/activemq_test.go index 231408ac..7b967893 100644 --- a/events/activemq_test.go +++ b/events/activemq_test.go @@ -30,6 +30,7 @@ func TestActiveMQEventMarshaling(t *testing.T) { assert.Equal(t, 1, message.DeliveryMode) assert.Equal(t, "testQueue", message.Destination.PhysicalName) assert.Equal(t, false, message.Redelivered) + assert.Equal(t, "testValue", message.Properties["testKey"]) // 4. serialize to JSON outputJSON, err := json.Marshal(inputEvent) diff --git a/events/testdata/activemq-event.json b/events/testdata/activemq-event.json index 6ae6d625..1aca9ad6 100644 --- a/events/testdata/activemq-event.json +++ b/events/testdata/activemq-event.json @@ -18,7 +18,8 @@ "priority": 0, "data": "RW50ZXIgc29tZSB0ZXh0IGhlcmUgZm9yIHRoZSBtZXNzYWdlIGJvZHkuLi4=", "brokerInTime": 1599863938943, - "brokerOutTime": 1599863938944 + "brokerOutTime": 1599863938944, + "properties": {"testKey": "testValue"} } ] } \ No newline at end of file