Adding properties field to activemq.go

aws · Nov 8, 2022 · 35709c2 · 35709c2
1 parent 0f46684
commit 35709c2
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 1 deletion.
diff --git 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
@@ -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
@@ -18,7 +18,8 @@
             "priority": 0,
             "data": "RW50ZXIgc29tZSB0ZXh0IGhlcmUgZm9yIHRoZSBtZXNzYWdlIGJvZHkuLi4=",
             "brokerInTime": 1599863938943,
-            "brokerOutTime": 1599863938944
+            "brokerOutTime": 1599863938944,
+            "properties": {"testKey": "testValue"}
         }
     ]
 }