Apache
/
activemq-artemis
mirror of https://github.com/apache/activemq-artemis.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

This closes #923

This commit is contained in:
Martyn Taylor 2016-12-15 13:40:47 +00:00
parent e8eaf15300 a9b32bdf0b
commit 23e5650d9f
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/proton/ProtonServerSenderContext.java
View File

@ -427,6 +427,7 @@ public class ProtonServerSenderContext extends ProtonInitializable implements Pr
@Override
public void close(boolean remoteLinkClose) throws ActiveMQAMQPException {
try {
closed = true;
sessionSPI.closeSender(brokerConsumer);
// if this is a link close rather than a connection close or detach, we need to delete
// any durable resources for say pub subs
@ -466,6 +467,9 @@ public class ProtonServerSenderContext extends ProtonInitializable implements Pr
@Override
public void onMessage(Delivery delivery) throws ActiveMQAMQPException {
if (closed) {
return;
}
Object message = delivery.getContext();
boolean preSettle = sender.getRemoteSenderSettleMode() == SenderSettleMode.SETTLED;
@ -544,7 +548,6 @@ public class ProtonServerSenderContext extends ProtonInitializable implements Pr
*/
public int deliverMessage(Object message, int deliveryCount) throws Exception {
if (closed) {
System.err.println("Message can't be delivered as it's closed");
return 0;
}