Merge pull request #470 from lohithpc1/property-feature

Adding properties field to activemq.go

Author: SukanyaHanumanthu

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 {

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)

events/testdata/activemq-event.json

@@ -18,7 +18,8 @@
             "priority": 0,
             "data": "RW50ZXIgc29tZSB0ZXh0IGhlcmUgZm9yIHRoZSBtZXNzYWdlIGJvZHkuLi4=",
             "brokerInTime": 1599863938943,
-            "brokerOutTime": 1599863938944
+            "brokerOutTime": 1599863938944,
+            "properties": {"testKey": "testValue"}
         }
     ]
 }