The problem with that is..
- if you have a remote Server...
- if you don't have a cluster connection factory (i.e. no failover)
The server will hang on a shutdown, case the remote server was shut before the client.
Because that I was checking for FailoverControlCenter on the Exception handler:
| ConnectionState connectionState =
(ConnectionState)(consumerState.getParent().getParent());
| // if ServerPeer is shutdown or
| // if there is no failover in place... we just close the consumerState as
well
| if (proxiedException instanceof MessagingShutdownException ||
| (connectionState.getFailoverCommandCenter() == null))
| {
| if (!consumerState.getClientConsumer().isClosed())
| {
| consumerState.getClientConsumer().close(-1);
| }
| }
| throw proxiedException;
| }
|
View the original post :
http://www.jboss.com/index.html?module=bb&op=viewtopic&p=4099883#...
Reply to the post :
http://www.jboss.com/index.html?module=bb&op=posting&mode=reply&a...