Author: rajith
Date: Mon Feb 4 18:37:13 2008
New Revision: 618519
URL: http://svn.apache.org/viewvc?rev=618519&view=rev
Log:
Added code to connect the network error exceptions to the JMS Exception
listener.
Modified:
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQConnectionDelegate_0_10.java
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/nclient/Client.java
incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpidity/ErrorCode.java
Modified:
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQConnectionDelegate_0_10.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQConnectionDelegate_0_10.java?rev=618519&r1=618518&r2=618519&view=diff
==============================================================================
---
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQConnectionDelegate_0_10.java
(original)
+++
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQConnectionDelegate_0_10.java
Mon Feb 4 18:37:13 2008
@@ -111,6 +111,7 @@
}
_qpidConnection.connect(brokerDetail.getHost(),
brokerDetail.getPort(), _conn.getVirtualHost(),
_conn.getUsername(), _conn.getPassword());
+ _qpidConnection.setClosedListener(this);
}
catch (QpidException e)
{
Modified:
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/nclient/Client.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/nclient/Client.java?rev=618519&r1=618518&r2=618519&view=diff
==============================================================================
---
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/nclient/Client.java
(original)
+++
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/nclient/Client.java
Mon Feb 4 18:37:13 2008
@@ -56,7 +56,14 @@
public void exception(Throwable t)
{
- // XXX: need to propogate exception
+ if (_closedListner != null)
+ {
+
_closedListner.onClosed(ErrorCode.CONNECTION_ERROR,ErrorCode.CONNECTION_ERROR.getDesc());
+ }
+ else
+ {
+ throw new RuntimeException("Connection closed",t);
+ }
}
@Override public void connectionClose(Channel context,
ConnectionClose connectionClose)
@@ -185,7 +192,9 @@
public void setClosedListener(ClosedListener closedListner)
{
+
_closedListner = closedListner;
+ System.out.println("setting connection listener " + _closedListner);
}
}
Modified:
incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpidity/ErrorCode.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpidity/ErrorCode.java?rev=618519&r1=618518&r2=618519&view=diff
==============================================================================
---
incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpidity/ErrorCode.java
(original)
+++
incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpidity/ErrorCode.java
Mon Feb 4 18:37:13 2008
@@ -4,7 +4,8 @@
{
//Qpid specific - for the time being
UNDEFINED(1,"undefined",true),
- MESSAGE_REJECTED(1,"message_rejected",true),
+ MESSAGE_REJECTED(2,"message_rejected",true),
+ CONNECTION_ERROR(3,"connection was closed",true),
//This might change in the spec, the error class is not applicable
NO_ERROR(200,"reply-success",true),
