Skip to content

Commit 224f07a

Browse files
Merge branch 'main' into Working-Branch
2 parents 7d813d7 + 75b4150 commit 224f07a

File tree

2 files changed

+10
-0
lines changed

2 files changed

+10
-0
lines changed

extras/queue-manager-replicated/tests/src/test/java/io/a2a/extras/queuemanager/replicated/tests/KafkaReplicationIntegrationTest.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -41,13 +41,15 @@
4141
import org.eclipse.microprofile.reactive.messaging.Channel;
4242
import org.eclipse.microprofile.reactive.messaging.Emitter;
4343
import org.junit.jupiter.api.BeforeEach;
44+
import org.junit.jupiter.api.Disabled;
4445
import org.junit.jupiter.api.Test;
4546

4647
/**
4748
* Integration test for Kafka replication functionality.
4849
* Tests the full A2A message flow with Kafka replication verification.
4950
*/
5051
@QuarkusTest
52+
@Disabled
5153
public class KafkaReplicationIntegrationTest {
5254

5355
@Inject

server-common/src/main/java/io/a2a/server/tasks/TaskUpdater.java

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -58,6 +58,14 @@ private void updateStatus(TaskState state, Message message, boolean isFinal) {
5858
}
5959
}
6060

61+
public String getContextId() {
62+
return this.contextId;
63+
}
64+
65+
public void addArtifact(List<Part<?>> parts) {
66+
addArtifact(parts, null, null, null);
67+
}
68+
6169
public void addArtifact(List<Part<?>> parts, String artifactId, String name, Map<String, Object> metadata) {
6270
addArtifact(parts, artifactId, name, metadata, null, null);
6371
}

0 commit comments

Comments
 (0)