Skip to content

Commit cd7ef97

Browse files
committed
Make sure AMQP client is authenticated
1 parent 400db27 commit cd7ef97

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

amqp-quickstart/amqp-quickstart-processor/src/test/java/org/acme/amqp/processor/QuoteProcessorTest.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -23,11 +23,13 @@ public class QuoteProcessorTest {
2323

2424
@ConfigProperty(name = "amqp-host") String host;
2525
@ConfigProperty(name = "amqp-port") int port;
26+
@ConfigProperty(name = "amqp-username") String username;
27+
@ConfigProperty(name = "amqp-password") String password;
2628
private AmqpClient client;
2729

2830
@BeforeEach
2931
void setUp() {
30-
client = AmqpClient.create(new AmqpClientOptions().setHost(host).setPort(port));
32+
client = AmqpClient.create(new AmqpClientOptions().setHost(host).setPort(port).setUsername(username).setPassword(password));
3133
}
3234

3335
@AfterEach

0 commit comments

Comments
 (0)