You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tuscany.apache.org by na...@apache.org on 2008/02/18 17:41:27 UTC
svn commit: r628802 -
/incubator/tuscany/java/sca/itest/transaction/src/main/java/org/apache/tuscany/sca/itest/transaction/CheckingAccountServiceImpl.java
Author: nash
Date: Mon Feb 18 08:41:25 2008
New Revision: 628802
URL: http://svn.apache.org/viewvc?rev=628802&view=rev
Log:
Add timeout delay to receive() call
Modified:
incubator/tuscany/java/sca/itest/transaction/src/main/java/org/apache/tuscany/sca/itest/transaction/CheckingAccountServiceImpl.java
Modified: incubator/tuscany/java/sca/itest/transaction/src/main/java/org/apache/tuscany/sca/itest/transaction/CheckingAccountServiceImpl.java
URL: http://svn.apache.org/viewvc/incubator/tuscany/java/sca/itest/transaction/src/main/java/org/apache/tuscany/sca/itest/transaction/CheckingAccountServiceImpl.java?rev=628802&r1=628801&r2=628802&view=diff
==============================================================================
--- incubator/tuscany/java/sca/itest/transaction/src/main/java/org/apache/tuscany/sca/itest/transaction/CheckingAccountServiceImpl.java (original)
+++ incubator/tuscany/java/sca/itest/transaction/src/main/java/org/apache/tuscany/sca/itest/transaction/CheckingAccountServiceImpl.java Mon Feb 18 08:41:25 2008
@@ -119,7 +119,7 @@
conn.start();
ActiveMQSession session = (ActiveMQSession)conn.createSession(true, Session.AUTO_ACKNOWLEDGE);
MessageConsumer consumer = session.createConsumer(queue, "accountNumber = '" + accountNumber + "'");
- Message msg = consumer.receiveNoWait();
+ Message msg = consumer.receive(1000);
if (msg == null) {
conn.close();
throw new AccountNotFoundException(accountNumber);
---------------------------------------------------------------------
To unsubscribe, e-mail: tuscany-commits-unsubscribe@ws.apache.org
For additional commands, e-mail: tuscany-commits-help@ws.apache.org