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 #1279 ARTEMIS-1169 - Implement Interceptors for the AMQP protocol

This commit is contained in:
Francesco Nigro 2017-05-18 10:43:37 +02:00
parent db8c567baa 22f4736c88
commit 72ab99fc62
2 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/broker/AMQPSessionCallback.java
View File

@ -567,6 +567,7 @@ public class AMQPSessionCallback implements SessionCallback {
ProtonServerSenderContext plugSender = (ProtonServerSenderContext) consumer.getProtocolContext(); ProtonServerSenderContext plugSender = (ProtonServerSenderContext) consumer.getProtocolContext();
try { try {
invokeOutgoing((AMQPMessage) message, (ActiveMQProtonRemotingConnection) transportConnection.getProtocolConnection());
return plugSender.deliverMessage(ref, deliveryCount); return plugSender.deliverMessage(ref, deliveryCount);
} catch (Exception e) { } catch (Exception e) {
connection.lock(); connection.lock();

2
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/AmqpSendReceiveInterceptorTest.java
View File

@ -70,7 +70,7 @@ public class AmqpSendReceiveInterceptorTest extends AmqpClientTestSupport {
receiver.flow(2); receiver.flow(2);
AmqpMessage amqpMessage = receiver.receive(5, TimeUnit.SECONDS); AmqpMessage amqpMessage = receiver.receive(5, TimeUnit.SECONDS);
assertNotNull(amqpMessage); assertNotNull(amqpMessage);
assertEquals(latch.getCount(), 0); assertEquals(latch2.getCount(), 0);
receiver.close(); receiver.close();
connection.close(); connection.close();
} }