Skip to content

Commit 5a19394

Browse files
authored
Sets streamCache("true") to fix regression in dev. (#432)
1 parent 900999a commit 5a19394

File tree

3 files changed

+2
-2
lines changed

3 files changed

+2
-2
lines changed

src/main/java/no/entur/damu/routes/export/GtfsExportQueueRouteBuilder.java

+1
Original file line numberDiff line numberDiff line change
@@ -92,6 +92,7 @@ public void configure() throws Exception {
9292
from(
9393
"google-pubsub:{{damu.pubsub.project.id}}:DamuExportGtfsQueue?synchronousPull=true"
9494
)
95+
.streamCache("true")
9596
.process(this::setCorrelationIdIfMissing)
9697
.setHeader(DATASET_REFERENTIAL, bodyAs(String.class))
9798
.log(LoggingLevel.INFO, correlation() + "Received GTFS export request")

src/test/java/no/entur/damu/DamuRouteBuilderIntegrationTestBase.java

-1
Original file line numberDiff line numberDiff line change
@@ -69,7 +69,6 @@ public abstract class DamuRouteBuilderIntegrationTestBase {
6969

7070
@PostConstruct
7171
void initInMemoryBlobStoreRepositories() {
72-
context.setStreamCaching(true);
7372
mardukInMemoryBlobStoreRepository.setContainerName(mardukContainerName);
7473
damuInMemoryBlobStoreRepository.setContainerName(damuContainerName);
7574
}

src/test/pubsub/damu.pubsub.http

+1-1
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,7 @@ Content-Type: application/json
3939
{
4040
"messages": [
4141
{
42-
"data": "cmJfcnV0"
42+
"data": "cmJfYXZp"
4343
}
4444
]
4545
}

0 commit comments

Comments
 (0)