diff --git a/provider/marathon.go b/provider/marathon.go index 3cd50a1f1..fa78ff03a 100644 --- a/provider/marathon.go +++ b/provider/marathon.go @@ -496,11 +496,6 @@ func (provider *Marathon) getCircuitBreakerExpression(application marathon.Appli func processPorts(application marathon.Application, task marathon.Task) []int { - // First using application ports - if len(application.Ports) > 0 { - return application.Ports - } - // Using default port configuration if task.Ports != nil && len(task.Ports) > 0 { return task.Ports diff --git a/provider/marathon_test.go b/provider/marathon_test.go index 3166ae19e..c4a5b5f98 100644 --- a/provider/marathon_test.go +++ b/provider/marathon_test.go @@ -1077,6 +1077,19 @@ func TestMarathonGetPort(t *testing.T) { Ports: []int{80, 443}, }, expected: "443", + }, { + applications: []marathon.Application{ + { + ID: "application-with-port", + Ports: []int{9999}, + Labels: &map[string]string{}, + }, + }, + task: marathon.Task{ + AppID: "application-with-port", + Ports: []int{7777}, + }, + expected: "7777", }, }