Skip to content
Permalink
Browse files
Start connection in TestReceiver
git-svn-id: https://svn.apache.org/repos/asf/cxf/trunk@1567938 13f79535-47bb-0310-9956-ffa450edef68
  • Loading branch information
cschneider committed Feb 13, 2014
1 parent 4d0254a commit 5065d9b57a1d5a1fb511190598e40d6683d4b174
Showing 1 changed file with 2 additions and 0 deletions.
@@ -59,6 +59,7 @@ private void drainQueue() {
ResourceCloser closer = new ResourceCloser();
try {
Connection connection = closer.register(connectionFactory.createConnection());
connection.start();
Session session = closer.register(connection.createSession(false, Session.AUTO_ACKNOWLEDGE));
MessageConsumer consumer = closer.register(session.createConsumer(session.createQueue(receiveQueueName)));
javax.jms.Message message = null;
@@ -76,6 +77,7 @@ private void receiveAndRespondWithMessageIdAsCorrelationId() {
ResourceCloser closer = new ResourceCloser();
try {
Connection connection = closer.register(connectionFactory.createConnection());
connection.start();
Session session = closer.register(connection.createSession(false, Session.AUTO_ACKNOWLEDGE));
MessageConsumer consumer = closer.register(session.createConsumer(session
.createQueue(receiveQueueName)));

0 comments on commit 5065d9b

Please sign in to comment.