diff --git a/test/e2e-tests.sh b/test/e2e-tests.sh index 9952415e4b..bc57ec6b53 100755 --- a/test/e2e-tests.sh +++ b/test/e2e-tests.sh @@ -37,7 +37,7 @@ fi # Eventing main config path from HEAD. readonly EVENTING_CONFIG="./config/" -readonly EVENTING_CHANNEL_BROKER_CONFIG="./config/brokers/channel-broker" +readonly EVENTING_MT_CHANNEL_BROKER_CONFIG="./config/brokers/mt-channel-broker" # Vendored eventing test iamges. readonly VENDOR_EVENTING_TEST_IMAGES="vendor/knative.dev/eventing/test/test_images/" @@ -84,8 +84,8 @@ function knative_setup() { git clone https://github.com/knative/eventing cd eventing ko apply -f ${EVENTING_CONFIG} - # Install Channel Based Broker - ko apply -f ${EVENTING_CHANNEL_BROKER_CONFIG} + # Install MT Channel Based Broker + ko apply -f ${EVENTING_MT_CHANNEL_BROKER_CONFIG} popd fi wait_until_pods_running knative-eventing || fail_test "Knative Eventing did not come up" diff --git a/test/e2e/broker_channel_flow_test.go b/test/e2e/broker_channel_flow_test.go index 0bccb92add..674c1748f1 100644 --- a/test/e2e/broker_channel_flow_test.go +++ b/test/e2e/broker_channel_flow_test.go @@ -24,5 +24,5 @@ import ( ) func TestBrokerChannelFlow(t *testing.T) { - helpers.BrokerChannelFlowTestHelper(t, "ChannelBasedBroker" /*brokerClass*/, channelTestRunner) + helpers.BrokerChannelFlowTestHelper(t, "MTChannelBasedBroker" /*brokerClass*/, channelTestRunner) } diff --git a/test/e2e/broker_dls_test.go b/test/e2e/broker_dls_test.go index 705b29bf34..e2d3cf5d06 100644 --- a/test/e2e/broker_dls_test.go +++ b/test/e2e/broker_dls_test.go @@ -31,5 +31,5 @@ func TestBrokerDeadLetterSink(t *testing.T) { {APIVersion: "messaging.knative.dev/v1alpha1", Kind: "KafkaChannel"}, } - helpers.TestBrokerWithConfig(t, "ChannelBasedBroker" /*brokerClass*/, channelTestRunner) + helpers.TestBrokerWithConfig(t, "MTChannelBasedBroker" /*brokerClass*/, channelTestRunner) } diff --git a/test/e2e/broker_event_transformation_test.go b/test/e2e/broker_event_transformation_test.go index dbeecdf45c..a7f7f8e2cb 100644 --- a/test/e2e/broker_event_transformation_test.go +++ b/test/e2e/broker_event_transformation_test.go @@ -24,5 +24,5 @@ import ( ) func TestEventTransformationForTrigger(t *testing.T) { - helpers.EventTransformationForTriggerTestHelper(t, "ChannelBasedBroker" /*brokerClass*/, channelTestRunner) + helpers.EventTransformationForTriggerTestHelper(t, "MTChannelBasedBroker" /*brokerClass*/, channelTestRunner) }