chore: update to latest version of goamqp

client.go

@@ -6,6 +6,8 @@ import (
 	"io/ioutil"
 	"net/http"
 	"reflect"
+
+	"gitlab.com/sparetimecoders/goamqp"
 )
 
 // CompanyPrivileges contains the privileges for a combination of email address and company id
@@ -69,7 +71,7 @@ func (h *PrivilegeHandler) Fetch() error {
 }
 
 // Process privilege-related events and update the internal state
-func (h *PrivilegeHandler) Process(msg interface{}) bool {
+func (h *PrivilegeHandler) Process(msg interface{}, _ goamqp.Headers) (interface{}, error) {
 	switch ev := msg.(type) {
 	case *UserAdded:
 		if priv, exists := h.privileges[ev.Email]; exists {
@@ -79,21 +81,21 @@ func (h *PrivilegeHandler) Process(msg interface{}) bool {
 				ev.CompanyID: {},
 			}
 		}
-		return true
+		return nil, nil
 	case *UserRemoved:
 		if priv, exists := h.privileges[ev.Email]; exists {
 			delete(priv, ev.CompanyID)
 		}
-		return true
+		return nil, nil
 	case *PrivilegeAdded:
 		h.setPrivileges(ev.Email, ev.CompanyID, ev.Privilege, true)
-		return true
+		return nil, nil
 	case *PrivilegeRemoved:
 		h.setPrivileges(ev.Email, ev.CompanyID, ev.Privilege, false)
-		return true
+		return nil, nil
 	default:
 		fmt.Printf("Got unexpected message type (%s): '%+v'\n", reflect.TypeOf(msg).String(), msg)
-		return false
+		return nil, fmt.Errorf("unexpected event type: '%s'", reflect.TypeOf(msg))
 	}
 }