jbi/cluster/requestor/src/main/java/org/apache/servicemix/jbi/cluster/requestor/AbstractPollingRequestorPool.java [248:261]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                        } else if (transacted == Transacted.ClientAck) {
                            if (message != null) {
                                if (!rollbackOnly) {
                                    message.acknowledge();
                                } else {
                                    destroyConsumer();
                                }
                            }
                            afterClose();
                        } else {
                            afterClose();
                        }
                    } catch (JMSException e) {
                        destroy();
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



jbi/cluster/requestor/src/main/java/org/apache/servicemix/jbi/cluster/requestor/ActiveMQJmsRequestorPool.java [305:318]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                    } else if (transacted == Transacted.ClientAck) {
                        if (message != null) {
                            if (!rollbackOnly) {
                                message.acknowledge();
                            } else {
                                destroyConsumer();
                            }
                        }
                        afterClose();
                    } else {
                        afterClose();
                    }
                } catch (JMSException e) {
                    destroy();
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -