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: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
