Skip to content
This repository was archived by the owner on Apr 1, 2025. It is now read-only.

Commit 5bba449

Browse files
committed
Fix copy-paste error
1 parent 98272bf commit 5bba449

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

extensions/transfer/transfer-demo-protocols/src/test/java/com/microsoft/dagx/transfer/demo/protocols/stream/DemoPushStreamTransferTest.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -18,6 +18,7 @@
1818
import static com.microsoft.dagx.transfer.demo.protocols.spi.DemoProtocols.DESTINATION_NAME;
1919
import static com.microsoft.dagx.transfer.demo.protocols.spi.DemoProtocols.ENDPOINT_ADDRESS;
2020
import static com.microsoft.dagx.transfer.demo.protocols.spi.DemoProtocols.PUSH_STREAM_HTTP;
21+
import static com.microsoft.dagx.transfer.demo.protocols.spi.DemoProtocols.PUSH_STREAM_WS;
2122
import static java.util.concurrent.TimeUnit.MINUTES;
2223

2324
/**
@@ -47,7 +48,7 @@ void verifyWsPushStreamFlow(TransferProcessManager processManager, TopicManager
4748

4849
var dataEntry = DataEntry.Builder.newInstance().id("test123").build();
4950

50-
var destinationWs = DataAddress.Builder.newInstance().type(PUSH_STREAM_HTTP).property(DESTINATION_NAME, destinationName).build();
51+
var destinationWs = DataAddress.Builder.newInstance().type(PUSH_STREAM_WS).property(DESTINATION_NAME, destinationName).build();
5152
var dataRequestWs = DataRequest.Builder.newInstance()
5253
.id(UUID.randomUUID().toString())
5354
.protocol("loopback")

0 commit comments

Comments
 (0)