Skip to content

Commit 5a1cf51

Browse files
Update SolaceSparkStreamingSourceIT.java
1 parent 492d158 commit 5a1cf51

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/test/java/com/solacecoe/connectors/spark/SolaceSparkStreamingSourceIT.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -63,7 +63,7 @@ public void beforeAll() throws ApiException {
6363
sempV2Api = new SempV2Api(String.format("http://%s:%d", solaceContainer.getHost(), solaceContainer.getMappedPort(8080)), "admin", "admin");
6464
MsgVpnQueue queue = new MsgVpnQueue();
6565
queue.queueName("Solace/Queue/0");
66-
queue.accessType(MsgVpnQueue.AccessTypeEnum.EXCLUSIVE);
66+
queue.accessType(MsgVpnQueue.AccessTypeEnum.NON_EXCLUSIVE);
6767
queue.permission(MsgVpnQueue.PermissionEnum.DELETE);
6868
queue.ingressEnabled(true);
6969
queue.egressEnabled(true);

0 commit comments

Comments
 (0)